|
|
@ -46,7 +46,7 @@ const activeCalls: activeCallMapType = new Map(); |
|
|
|
|
|
|
|
// Handle WebSocket connections
|
|
|
|
io.on("connection", (socket: Socket) => { |
|
|
|
console.log("User connected", socket.id); |
|
|
|
// console.log("User connected", socket.id);
|
|
|
|
|
|
|
|
// Handle user-online event
|
|
|
|
socket.on("user-online", (user: UserDetails) => { |
|
|
@ -66,7 +66,7 @@ io.on("connection", (socket: Socket) => { |
|
|
|
const { caller, callee, userName, image } = user; |
|
|
|
// Now we store the socket ID along with the user details
|
|
|
|
const details = onlineUsers.get(String(callee)); |
|
|
|
console.log("connect-req", details, onlineUsers, user); |
|
|
|
// console.log("connect-req", details, onlineUsers, user);
|
|
|
|
if (details) { |
|
|
|
socket.to(details.socketId).emit("connect-res", { |
|
|
|
userId: caller, |
|
|
@ -80,11 +80,11 @@ io.on("connection", (socket: Socket) => { |
|
|
|
// Handle user-online event
|
|
|
|
socket.on("connect-reject-req", (data: { users: number[] }) => { |
|
|
|
const { users } = data; |
|
|
|
console.log("connect-reject-req", data); |
|
|
|
// console.log("connect-reject-req", data);
|
|
|
|
// Now we store the socket ID along with the user details
|
|
|
|
for (const user of users) { |
|
|
|
const details = onlineUsers.get(String(user)); |
|
|
|
console.log("connect-reject-req", details); |
|
|
|
// console.log("connect-reject-req", details);
|
|
|
|
if (details) { |
|
|
|
socket.to(details.socketId).emit("connect-reject-res", { |
|
|
|
reject: true, |
|
|
@ -96,7 +96,7 @@ io.on("connection", (socket: Socket) => { |
|
|
|
// Handle user disconnect event
|
|
|
|
socket.on("disconnect", async () => { |
|
|
|
const user = activeCalls.get(socket.id); |
|
|
|
console.log("disconnect", user); |
|
|
|
// console.log("disconnect", user);
|
|
|
|
if (user) { |
|
|
|
if (user?.from) { |
|
|
|
const calleeU = socketToUserId.get(socket.id); |
|
|
@ -152,7 +152,7 @@ io.on("connection", (socket: Socket) => { |
|
|
|
const { candidate, to } = data; |
|
|
|
const calledTo = onlineUsers.get(to); |
|
|
|
if (calledTo) { |
|
|
|
console.log("get-ice-candidate", to); |
|
|
|
// console.log("get-ice-candidate", to);
|
|
|
|
// Emit to the recipient's socket ID
|
|
|
|
socket.to(calledTo.socketId).emit("get-ice-candidate", candidate); |
|
|
|
} |
|
|
@ -197,7 +197,7 @@ io.on("connection", (socket: Socket) => { |
|
|
|
from: calledFrom.socketId, |
|
|
|
callTime: new Date(), |
|
|
|
}); |
|
|
|
console.log("call-accept", activeCalls); |
|
|
|
// console.log("call-accept", activeCalls);
|
|
|
|
socket.to(calledTo.socketId).emit("call-accepted"); |
|
|
|
} |
|
|
|
}); |
|
|
|