index.ts

import express from 'express';
import http from 'http';
import WebSocket from 'ws';
import bodyParser from 'body-parser';
import * as fs from "fs";

const PORT = process.env.PORT || 8000

const app = express();

app.use(bodyParser.text({type:"*/*"}))

//initialize a simple http server
const server = http.createServer(app);

//initialize the WebSocket server instance
const wss = new WebSocket.Server({ server });

wss.on('connection', (ws: WebSocket) => {

    //connection is up, let's add a simple simple event
    ws.on('message', (message: string) => {

        //log the received message and send it back to the client
        console.log('received: %s', message);
    });

    //send immediatly a feedback to the incoming connection
    ws.send('Connected');
});

//start our server
server.listen(PORT, () => {
    console.log(`Server started on port ${PORT} 💥`);
});

app.get('/', (req, res) => {
    fs.readFile(__dirname + '/templates/index.html', 'utf8', (err, text) => {
        res.send(text.replace('{{PORT}}', PORT.toString()));
    });
})

app.post('/', (req: express.Request, res: express.Response) => {
  wss.clients.forEach((ws: any) => {
      ws.send(req.body)
  });

  res.send('ok');
})