server.js

const WebSocket = require("ws");
const jwt = require("jsonwebtoken");

function getRandomIntInclusive(min, max) {
  const minCeiled = Math.ceil(min);
  const maxFloored = Math.floor(max);
  return Math.floor(Math.random() * (maxFloored - minCeiled + 1) + minCeiled); // The maximum is inclusive and the minimum is inclusive
}

var globalCount = 0;

function joinGame(myid) {
  return function() {

    if (globalCount > 75)  return;

  const userId = myid || getRandomIntInclusive(1, 100000);
  console.log("userId", userId);
  const ws = new WebSocket("wss://staging.question.house/ws", {
    headers: {},
  });

  ws.userId = userId;

  ws.on("error", function (e) {
    globalCount--;
    clearInterval(ws.pInterval);
    console.log("socket error", e);
    setTimeout(joinGame(ws.userId), 1000);
  });

  ws.on("close", function (ree) {
    globalCount--;
    clearInterval(ws.pInterval);
    console.log("socket close", ree);
    setTimeout(joinGame(ws.userId), 1000);
  });

  ws.on("open", function open() {
    globalCount++;
    ws.pInterval = setInterval(() => {
      e.ping()
    }, 4000);
    ws.send(
      JSON.stringify({
        type: "subscribe",
      })
    );
    console.log("Connected");
  });

  ws.on("message", function message(data) {
    try {
      var message = JSON.parse(data);
    } catch (e) {
      console.log(data);
    }

    if (!["question", "questionClosed", "questionResult", "questionSummary", "questionFinished", "dynamicPot", "interaction", "gameStatus", "broadcastStats", "submittedAnswer", "winners", "postGame"].includes(message.type)) console.log(message);

    if (message.type == "question") {
      ws.send(
        JSON.stringify({
          type: "answer",
          answerId: message.answers[Math.floor(Math.random() * message.answers.length)].answerId,
        })
      );
    }
    //console.log('received: %s', data);
  });
  }
}

  setInterval(() => {
    joinGame()();
  }, 1000);

var http = require("http");

http
  .createServer(function (req, res) {
    res.write("Hello World!");
    res.end();
  })
  .listen(8080);