diff --git a/server/src/lib/socket/socket.ts b/server/src/lib/socket/socket.ts index 6bc6bd1f..423e1008 100644 --- a/server/src/lib/socket/socket.ts +++ b/server/src/lib/socket/socket.ts @@ -13,24 +13,24 @@ export function initializeSocket(server: Server, corsOptions: CorsOptions) { }); io.on("connection", (socket) => { - console.log(`New connection created of id ${socket.id}`); + console.log(`[log:ws] New connection created of id ${socket.id}`); socket.on("register", async (token) => { const userId = await getUserIdFromToken(token); if (userId) { users.set(userId, socket); console.log( - `The user of id ${socket.id} turned out to have id ${userId}`, + `[log:ws] The user of id ${socket.id} turned out to have id ${userId}`, ); } else { - console.log("Invalid token or failed to retrieve user ID"); + console.log("[log:ws] Invalid token or failed to retrieve user ID"); } }); socket.on("disconnect", () => { - console.log(`A user disconnected of id ${socket.id}`); + console.log(`[log:ws] A user disconnected of id ${socket.id}`); for (const [id, socket2] of users.entries()) { if (socket2.id === socket.id) { - console.log(`... whose userId is ${id}`); + console.log(`[log:ws] ... whose userId is ${id}`); users.delete(id); break; } @@ -40,22 +40,28 @@ export function initializeSocket(server: Server, corsOptions: CorsOptions) { } export function sendMessage(message: Message, friendId: UserID) { + console.log("[log:ws] got request for creating message."); const socket = users.get(friendId); if (socket) { + console.log("[log:ws] Sending message..."); socket.emit("newMessage", message); } } export function updateMessage(message: Message, friendId: UserID) { + console.log("[log:ws] got request for updating message."); const socket = users.get(friendId); if (socket) { + console.log("[log:ws] Updating message..."); socket.emit("updateMessage", message); } } export function deleteMessage(messageId: number, friendId: UserID) { + console.log("[log:ws] got request for deleting message."); const socket = users.get(friendId); if (socket) { + console.log("[log:ws] Deleting message..."); socket.emit("deleteMessage", messageId); } }