From 44c60280ef60ad5c26ecc3b413b46eaa0c2ea1b0 Mon Sep 17 00:00:00 2001 From: DecDuck Date: Sat, 16 Nov 2024 16:27:38 +1100 Subject: [PATCH] refactor: rename admin socket session map --- server/api/v1/task/index.get.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/server/api/v1/task/index.get.ts b/server/api/v1/task/index.get.ts index f511c51..a9e0c18 100644 --- a/server/api/v1/task/index.get.ts +++ b/server/api/v1/task/index.get.ts @@ -5,7 +5,7 @@ import taskHandler, { TaskMessage } from "~/server/internal/tasks"; // TODO add web socket sessions for horizontal scaling // ID to admin -const socketSessions: { [key: string]: boolean } = {}; +const adminSocketSessions: { [key: string]: boolean } = {}; export default defineWebSocketHandler({ open(peer) { @@ -22,7 +22,7 @@ export default defineWebSocketHandler({ return; } const admin = session.getAdminUser(dummyEvent); - socketSessions[peer.id] = admin !== undefined; + adminSocketSessions[peer.id] = admin !== undefined; const rtMsg: TaskMessage = { id: "connect", @@ -36,17 +36,17 @@ export default defineWebSocketHandler({ }, message(peer, message) { if (!peer.id) return; - if (socketSessions[peer.id] === undefined) return; + if (adminSocketSessions[peer.id] === undefined) return; const text = message.text(); if (text.startsWith("connect/")) { const id = text.substring("connect/".length); - taskHandler.connect(peer.id, id, peer, socketSessions[peer.id]); + taskHandler.connect(peer.id, id, peer, adminSocketSessions[peer.id]); return; } }, close(peer, details) { if (!peer.id) return; - if (socketSessions[peer.id] === undefined) return; - delete socketSessions[peer.id]; + if (adminSocketSessions[peer.id] === undefined) return; + delete adminSocketSessions[peer.id]; }, });