songtianlun/happy-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add ping

Browse Source
This commit is contained in:
Steve Korshakov 2025-07-16 22:37:28 -07:00
parent 652f435307
commit 1ace32e5c3
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
sources/app/api.ts
View File

@ -426,7 +426,7 @@ export async function startApi() {
methodsToRemove.push(method); methodsToRemove.push(method);
} }
} }
if (methodsToRemove.length > 0) { if (methodsToRemove.length > 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 => userRpcMap.delete(method)); methodsToRemove.forEach(method => userRpcMap.delete(method));
@ -829,7 +829,7 @@ export async function startApi() {
if (userRpcMap && userRpcMap.get(method) === socket) { if (userRpcMap && userRpcMap.get(method) === socket) {
userRpcMap.delete(method); userRpcMap.delete(method);
log({ module: 'websocket-rpc' }, `RPC method unregistered: ${method} from socket ${socket.id} (user: ${userId})`); log({ module: 'websocket-rpc' }, `RPC method unregistered: ${method} from socket ${socket.id} (user: ${userId})`);
if (userRpcMap.size === 0) { if (userRpcMap.size === 0) {
rpcListeners.delete(userId); rpcListeners.delete(userId);
log({ module: 'websocket-rpc' }, `All RPC methods unregistered for user ${userId}`); log({ module: 'websocket-rpc' }, `All RPC methods unregistered for user ${userId}`);
@ -920,7 +920,7 @@ export async function startApi() {
const duration = Date.now() - startTime; const duration = Date.now() - startTime;
const errorMsg = error instanceof Error ? error.message : 'RPC call failed'; const errorMsg = error instanceof Error ? error.message : 'RPC call failed';
log({ module: 'websocket-rpc' }, `RPC call failed: ${method} - ${errorMsg} (${duration}ms)`); log({ module: 'websocket-rpc' }, `RPC call failed: ${method} - ${errorMsg} (${duration}ms)`);
// Timeout or error occurred // Timeout or error occurred
if (callback) { if (callback) {
callback({ callback({
@ -931,6 +931,10 @@ export async function startApi() {
} }
}); });
socket.on('ping', async (callback: (response: any) => void) => {
callback({});
});
socket.emit('auth', { success: true, user: userId }); socket.emit('auth', { success: true, user: userId });
log({ module: 'websocket' }, `User connected: ${userId}`); log({ module: 'websocket' }, `User connected: ${userId}`);
}); });