// Express ও Socket.io দিয়ে signaling server
const express = require("express");
const http = require("http");
const { Server } = require("socket.io");
 
const app = express();
const server = http.createServer(app);
const io = new Server(server);
 
io.on("connection", (socket) => {
  socket.on("signal", (data) => {
    socket.broadcast.emit("signal", data);
  });
});
 
server.listen(3000, () => {
  console.log("Signaling server running on port 3000");
});

// ক্লায়েন্ট সাইড উদাহরণ (ব্রাউজার)
const socket = io("http://localhost:3000");
const peer = new RTCPeerConnection();
 
peer.onicecandidate = (event) => {
  if (event.candidate) {
    socket.emit("signal", { candidate: event.candidate });
  }
};
 
socket.on("signal", async (data) => {
  if (data.offer) {
    await peer.setRemoteDescription(new RTCSessionDescription(data.offer));
    const answer = await peer.createAnswer();
    await peer.setLocalDescription(answer);
    socket.emit("signal", { answer });
  } else if (data.answer) {
    await peer.setRemoteDescription(new RTCSessionDescription(data.answer));
  } else if (data.candidate) {
    await peer.addIceCandidate(new RTCIceCandidate(data.candidate));
  }
});

navigator.mediaDevices
  .getUserMedia({ video: true, audio: true })
  .then((stream) => {
    stream.getTracks().forEach((track) => peer.addTrack(track, stream));
  });