sockets.js

// const server = require('./app');
let server;
let letUsController;

const updateClientsCount = (socket, count) => {
  socket.emit('update connection', count);
};

const checkInvite = (socket, nsp) => {
  if (!letUsController) {
    console.log('Loaded DB Controller');
    letUsController = require('./db/letUsController');
  }
  const hash = socket.nsp.name.split('/')[2];
  socket.on('check invite', (userData) => {
    const user = {
      id: userData.id,
      name: userData.name,
      linkHash: hash,
    };
    letUsController.handleNewEventAttendees(user)
      .then((updatedAttendees) => {
        // console.log('SOCKET: sending client updated attendees list:', updatedAttendees);
        if (updatedAttendees) {
          nsp.emit('update peerlist', updatedAttendees);
        }
      });
  });
};

const updateData = (socket, nsp, liveData) => {
  if (!letUsController) {
    // console.log('Loaded DB Controller');
    letUsController = require('./db/letUsController');
  }
  const hash = socket.nsp.name.split('/')[2];
  // console.log(`SOCKET: event hash: ${hash}`);
  letUsController.handleClientVotes(hash, liveData)
    .then((data) => {
      // console.log('SOCKET: sending live data...');
      // console.log(data);
      nsp.emit('update livedata', data);
    });
};

const handleLiveData = (socket, nsp) => {
  console.log('SOCKET: loaded event listeners');
  // console.log(socket);
  socket.on('submit livedata', (liveData) => {
    // console.log('SERVER: recieved liveData');
    updateData(socket, nsp, liveData);
  });
};

const add = (hash) => {
  let connectionsCounter = 0;
  if (!server) {
    // console.log('SOCKETS: loaded server dependancies');
    server = require('./app');
  }
  const io = server.io;
  const nsp = io.of(`/event/${hash}`);
  nsp.on('connection', (socket) => {
    connectionsCounter++;
    // console.log('SOCKET TEST');
    // console.log(socket.nsp.server.sockets);
    // const clientsCount = socket.conn.server.clientsCount;
    console.log(`SOCKET: user connected to: /event/${hash} || ${connectionsCounter}`);
    updateClientsCount(nsp, connectionsCounter);
    handleLiveData(socket, nsp);
    checkInvite(socket, nsp);
    socket.on('disconnect', () => {
      connectionsCounter--;
      console.log(`SOCKET: user disconnected from: /event/${hash} || ${connectionsCounter}`);
      updateClientsCount(nsp, connectionsCounter);
    });
  });
  // handleLiveData(nsp);
};

module.exports = {
  add,
};