From 5f660a440586cf49abfc4b9d09bda0cd497dff15 Mon Sep 17 00:00:00 2001 From: 4 Bytes Robby Date: Sun, 14 Jun 2026 16:56:11 +0200 Subject: [PATCH] feat: migrate to scoped bus API (forService/forSession) --- src/bus-publisher.ts | 2 +- src/tui.tsx | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/bus-publisher.ts b/src/bus-publisher.ts index 86bb8a3..c9cd1db 100644 --- a/src/bus-publisher.ts +++ b/src/bus-publisher.ts @@ -39,7 +39,7 @@ export class BusPublisher { else if (cumulative >= config.softLimit) status = "soft_exceeded"; try { - await this.bus.publish(`tbg/${sessionID}/status`, { + await this.bus.forService("tbg").forSession(sessionID).publish("status", { sessionID, cumulative, softLimit: config.softLimit, diff --git a/src/tui.tsx b/src/tui.tsx index 5ddd20a..d2c180b 100644 --- a/src/tui.tsx +++ b/src/tui.tsx @@ -27,7 +27,7 @@ function TokenMeterView(props: { session_id: string }) { const bus = await BusTui.connect(5000); setConnected(true); - bus.subscribe(`tbg/${props.session_id}/status`, (msg) => { + bus.forService("tbg").forSession(props.session_id).subscribe("status", (msg) => { const p = msg.payload as any; if (typeof p.cumulative === "number") { setTokens(p.cumulative);