app.js

// server.js
const express = require("express")
const app = express()
const estimateFunctions = require("./src/models/estimateFunctions")

const redisClient = require("./src/redis/redis-client")
const http = require("http").createServer(app)
const io = require("socket.io")(http)

const CronJob = require("cron").CronJob
new CronJob(
  "*/15 * 6-24,0-1 * * *",
  function() {
    estimateFunctions.fetchEstimates(redisClient, io)
  },
  null,
  true,
  "America/New_York"
)

io.on("connection", function(client) {
  // once a client has connected, we expect to get a ping from them saying what room they want to join
  client.on("room", function(route) {
    client.join(route)
    redisClient
      .getAsync(route)
      .then(estimate => io.sockets.in(route).emit("estimate", estimate))
  })

  client.on("leaveRoom", function(route) {
    client.leave(route)
  })
})

const port = 8000
io.listen(port)
console.log("Socket.io listening on port", port)