server.js.save

require("dotenv").config();
const express = require("express");
const app = express();
const cors = require("cors");
const session = require("express-session");
const passport = require("passport");
const PORT = process.env.PORT || 4000;
const socket = require("socket.io");
const bodyParser = require("body-parser");

// database connection
require("./database/connection")();

// CORS policy
app.use(
  cors({
    origin:
	 [
      "http://localhost:3000",
      "http://localhost:5173",
      "http://3.110.90.35:3000",
      "http://3.109.78.94:3000",
      "http://frontend.ayatrio.com",	
      "https://www.ayatrio.com",
      "http://ayatrio-admin.s3-website.ap-south-1.amazonaws.com",
      "https://main.d2e7lk624os6uh.amplifyapp.com",
    ],
    methods: "GET,POST,PUT,DELETE,PATCH",
    credentials: true,
  })
);

app.use(express.json());
app.use(express.text());
app.use(express.urlencoded({ extended: true }));
app.use(bodyParser.json());

// setup session
app.use(
  session({
    secret: process.env.SECRET_KEY,
    resave: false,
    saveUninitialized: true,
  })
);

// // setuppassport
app.use(passport.initialize());
app.use(passport.session());

// // passport strategy for Google login
require("./config/passport")(passport);

// passport auth routes
app.use("/auth", require("./routes/googleAuth"));

// other routes
app.use("/api", require("./routes/routes"));

// home page routes
app.use("/api", require("./routes/homepageRoutes"));

// admin routes
app.use("/admin", require("./routes/admin"));

// admin routes
app.use("/indexing", require("./routes/indexing"));

// payment routes
app.use("/payment", require("./routes/paymentRoutes"));

// socket connection
const server = app.listen(PORT, () => {
  console.log(`server started on http://localhost:${PORT}`);
});

const io = socket(server, {
  cors: {
    origin: ["http://localhost:3000", "http://frontend.ayatrio.com", "http://3.109.78.94:3000", "http://3.110.90.35:3000", "https://www.ayatrio.com", "http://localhost:5173"],
 
},
});

const roomToUsers = new Map();

io.on("connection", (socket) => {
  socket.on("join-room", ({ roomId }) => {
    if (!roomToUsers.has(roomId)) {
      roomToUsers.set(roomId, new Set());
    }
    roomToUsers.get(roomId).add(socket.id);
    socket.join(roomId);

    io.to(roomId).emit("user-joined", {
      userId: socket.id,
      users: Array.from(roomToUsers.get(roomId)),
    });
  });

  socket.on("leave-room", ({ roomId }) => {
    if (roomToUsers.has(roomId)) {
      roomToUsers.get(roomId).delete(socket.id);
      io.to(roomId).emit("user-left", { userId: socket.id });
    }
    socket.leave(roomId);
  });

  socket.on("disconnect", () => {
    roomToUsers.forEach((users, roomId) => {
      if (users.has(socket.id)) {
        users.delete(socket.id);
        io.to(roomId).emit("user-left", { userId: socket.id });
      }
    });
  });

  socket.on("offer", ({ to, offer }) => {
    io.to(to).emit("offer", { from: socket.id, offer });
  });

  socket.on("answer", ({ to, answer }) => {
    io.to(to).emit("answer", { from: socket.id, answer });
  });

  socket.on("ice-candidate", ({ to, candidate }) => {
    io.to(to).emit("ice-candidate", { from: socket.id, candidate });
  });

  socket.on("request_join", (data) => {
    console.log("Join request received:", data);
    io.emit("join_request", { socketId: socket.id, ...data });
  });

  socket.on("admin_response", (response) => {
    console.log("Admin response received:", response);
    const { socketId, accepted, roomId } = response;
    if (accepted) {
      io.to(socketId).emit("join_accepted", { roomId });
      socket.join(roomId);
      io.to(roomId).emit("join_accepted_admin", { roomId });
    } else {
      io.to(socketId).emit("join_rejected");
    }
  });
});