calvin.erfmann/pangolin
1
0
Fork 0
mirror of https://github.com/fosrl/pangolin.git synced 2026-07-06 12:19:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: tighten ws batch typing and queue cleanup logging

Browse Source
This commit is contained in:
copilot-swe-agent[bot]
2026-06-16 22:50:03 +00:00
committed by Owen
parent d09668b20b
commit 22ac711dc6
3 changed files with 38 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/private/routers/ws/ws.ts
View File

@@ -188,7 +188,7 @@ const wss: WebSocketServer = new WebSocketServer({ noServer: true });
const NODE_ID = uuidv4();
const REDIS_CHANNEL = "websocket_messages";
const REDIS_DIRECT_BATCH_SIZE = 250;
const REDIS_DIRECT_FLUSH_MS = 10;
const REDIS_DIRECT_FLUSH_INTERVAL_MS = 10;
// Client tracking map (local to this node)
const connectedClients: Map<string, AuthenticatedWebSocket[]> = new Map();
@@ -234,10 +234,6 @@ const publishDirectBatch = async (
targetClientId: entry.targetClientId,
message: entry.message
})),
message: {
type: "batch",
data: {}
},
fromNodeId: NODE_ID
};
@@ -289,7 +285,7 @@ const enqueueRedisDirectMessage = async (
if (!redisDirectFlushTimer) {
redisDirectFlushTimer = setTimeout(() => {
void flushPendingRedisDirectMessages();
}, REDIS_DIRECT_FLUSH_MS);
}, REDIS_DIRECT_FLUSH_INTERVAL_MS);
}
});
};