github-mirrors/netris-nestri
1
0
Fork 0
mirror of https://github.com/nestriness/nestri.git synced 2026-08-01 17:34:15 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix: Remove unnecessary code in Event Bus

Browse Source
This commit is contained in:
Wanjohi
2025-11-05 19:02:36 +03:00
parent d1295aa4ad
commit 138852f87b
1 changed files with 0 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
packages/core/src/bus/index.ts
View File

@@ -35,27 +35,6 @@ export namespace Bus {
subClient.connect().catch(() => Promise.resolve()), subClient.connect().catch(() => Promise.resolve()),
]); ]);
// global dispatcher for incoming messages
subClient.subscribe("message", (channel: string, message: string) => {
const handlers = subscribers.get(channel);
if (!handlers?.length) return;
try {
const parsed = JSON.parse(message);
for (const h of handlers) {
// call handlers without awaiting so one slow handler doesn't block the dispatcher
try {
const r = h(parsed.detail, parsed) as any;
if (r instanceof Promise)
r.catch((e) => log.error("bus handler error", e));
} catch (e: any) {
log.error("bus handler error", e);
}
}
} catch (e: any) {
log.error("bus: failed to parse message", e);
}
});
return { pubClient, subClient }; return { pubClient, subClient };
} catch (err: any) { } catch (err: any) {
log.error("bus: failed to connect to redis", err); log.error("bus: failed to connect to redis", err);