~NAXC~

File Content: `server.mts`

import { createServer } from "node:http";
import next from "next";
import { initializeSocket } from "./socket.mjs"; // Import the shared socket module

const dev = process.env.NODE_ENV !== "production";
const hostname = "localhost";
const port = (process.env.NEXT_PUBLIC_PORT as unknown as number) || 3019;

const app = next({ dev, hostname, port });
const handler = app.getRequestHandler();

app.prepare().then(() => {
  const httpServer = createServer(handler);

  // Initialize Socket.IO
  const io = initializeSocket(httpServer);

  io.on("connection", (socket) => {
    const userId = socket.handshake.query.userId;
    if (userId) {
      socket.join(userId);
    }

    socket.on("backend-message", ({ event, data, room }) => {
      console.log("backend-message", event, data, room);
      socket.to(room).emit(event, data);
    });

    socket.on("disconnect", () => {
      console.log("user disconnected:", socket.id);
    });
  });

  httpServer
    .once("error", (err) => {
      console.error(err);
      process.exit(1);
    })
    .listen(port, () => {
      console.log(`> Ready on http://${hostname}:${port}`);

      fetch(`${process.env.NEXT_PUBLIC_APP_URL}/api/services/scheduler`, {
        method: "POST",
      });
    });
});
File Content: server.mts

File Content: `server.mts`
