diff --git a/sources/app/api/socket/rpcHandler.ts b/sources/app/api/socket/rpcHandler.ts index 4a7d740..9892bce 100644 --- a/sources/app/api/socket/rpcHandler.ts +++ b/sources/app/api/socket/rpcHandler.ts @@ -17,15 +17,15 @@ export function rpcHandler(userId: string, socket: Socket, rpcListeners: Map ${socket.id}`); + // log({ module: 'websocket-rpc' }, `RPC method ${method} re-registered: ${previousSocket.id} -> ${socket.id}`); } // Register this socket as the listener for this method rpcListeners.set(method, socket); socket.emit('rpc-registered', { method }); - log({ module: 'websocket-rpc' }, `RPC method registered: ${method} on socket ${socket.id} (user: ${userId})`); - log({ module: 'websocket-rpc' }, `Active RPC methods for user ${userId}: ${Array.from(rpcListeners.keys()).join(', ')}`); + // log({ module: 'websocket-rpc' }, `RPC method registered: ${method} on socket ${socket.id} (user: ${userId})`); + // log({ module: 'websocket-rpc' }, `Active RPC methods for user ${userId}: ${Array.from(rpcListeners.keys()).join(', ')}`); } catch (error) { log({ module: 'websocket', level: 'error' }, `Error in rpc-register: ${error}`); socket.emit('rpc-error', { type: 'register', error: 'Internal error' }); @@ -44,16 +44,16 @@ export function rpcHandler(userId: string, socket: Socket, rpcListeners: Map ${method} (target: ${targetSocket.id})`); + // log({ module: 'websocket-rpc' }, `RPC call initiated: ${socket.id} -> ${method} (target: ${targetSocket.id})`); // Forward the RPC request to the target socket using emitWithAck try { @@ -114,7 +114,7 @@ export function rpcHandler(userId: string, socket: Socket, rpcListeners: Map 0) { - log({ module: 'websocket-rpc' }, `Cleaning up RPC methods on disconnect for socket ${socket.id}: ${methodsToRemove.join(', ')}`); + // log({ module: 'websocket-rpc' }, `Cleaning up RPC methods on disconnect for socket ${socket.id}: ${methodsToRemove.join(', ')}`); methodsToRemove.forEach(method => rpcListeners.delete(method)); } if (rpcListeners.size === 0) { rpcListeners.delete(userId); - log({ module: 'websocket-rpc' }, `All RPC listeners removed for user ${userId}`); + // log({ module: 'websocket-rpc' }, `All RPC listeners removed for user ${userId}`); } }); } \ No newline at end of file