server.js

const http = require("http");
const path = require("path");
const express = require("express");
const { Server } = require("socket.io");
const quoteEngine = require("./lib/quoteEngine");
const { registerTransports } = require("./transport");

const app = express();
const server = http.createServer(app);
const io = new Server(server);

app.use(express.json({ limit: "32kb" }));

const publicDir = path.join(__dirname, "public");
app.use(express.static(publicDir));

app.post("/api/quote/inject", (req, res) => {
  const { text, author } = req.body || {};
  const result = quoteEngine.injectQuote(text, author);
  if (!result.ok) {
    return res.status(400).json({ error: result.error });
  }
  res.json(result.payload);
});

const transportNames = registerTransports({ app, io, quoteEngine });

const PORT = Number(process.env.PORT) || 8000;
server.listen(PORT, () => {
  console.log(
    `Quotes server on http://localhost:${PORT} (${quoteEngine.poolSize} quotes, rotate every ${quoteEngine.ROTATE_MS / 1000}s)`
  );
  console.log(
    "Transports: " +
      transportNames.map((n) => `/transport/${n}`).join(", ")
  );
});