+
{ t.onClick?.(); setItems((s) => s.filter((x) => x.id !== t.id)); } } : {})}
+ >
{t.title}
{t.desc &&
{t.desc}
}
diff --git a/src/lib/crm-messaging-adapter.ts b/src/lib/crm-messaging-adapter.ts
index c1f7f1e..791b3b6 100644
--- a/src/lib/crm-messaging-adapter.ts
+++ b/src/lib/crm-messaging-adapter.ts
@@ -45,6 +45,8 @@ export class CrmMessagingAdapter implements MessagingAdapter {
private readonly listeners = new Map
void>>();
private readonly polls = new Map();
private readonly joined = new Set();
+ /** Cross-thread activity listeners (live unread + in-app notifications). */
+ private readonly activity = new Set<(e: { threadId: string; message: Message }) => void>();
/** messageId → emoji → userSet, so a single annotation delta can be re-emitted as a full set. */
private readonly reactions = new Map>>();
@@ -59,7 +61,10 @@ export class CrmMessagingAdapter implements MessagingAdapter {
if (socket) {
socket.on("message", (m) => {
this.ingestReactions(m);
- void this.toKernelMessage(m).then((message) => this.emit(m.threadId, { kind: "message", message }));
+ void this.toKernelMessage(m).then((message) => {
+ this.emit(m.threadId, { kind: "message", message });
+ for (const cb of this.activity) cb({ threadId: m.threadId, message });
+ });
});
socket.on("typing", (e) => this.emit(e.threadId, { kind: "typing", userId: e.userId }));
// Receipts carry no threadId → fan to all open threads; the UI filters by messageId.
@@ -79,6 +84,37 @@ export class CrmMessagingAdapter implements MessagingAdapter {
return this.me;
}
+ /** Report the foregrounded thread to IIOS presence (suppresses push for what you're viewing). */
+ setFocus(threadId: string | null): void {
+ this.socket?.focus(threadId);
+ }
+
+ /** Fire `cb` for every incoming message across ALL the caller's threads (live unread + toasts). */
+ subscribeActivity(cb: (e: { threadId: string; message: Message }) => void): Unsubscribe {
+ this.activity.add(cb);
+ void this.joinAllThreads();
+ return () => {
+ this.activity.delete(cb);
+ };
+ }
+
+ /** Join every thread the user belongs to so their messages arrive over the socket, not just the
+ * open one. Idempotent (the `joined` set guards re-joins). */
+ private async joinAllThreads(): Promise {
+ if (!this.socket) return;
+ try {
+ const convs = await this.sdk.query("crm.messenger.conversation.list", {});
+ for (const c of convs) {
+ if (!this.joined.has(c.threadId)) {
+ this.joined.add(c.threadId);
+ void this.socket.openThread(c.threadId).catch(() => this.joined.delete(c.threadId));
+ }
+ }
+ } catch {
+ /* best-effort — activity just won't cover un-joined threads */
+ }
+ }
+
async listConversations(): Promise {
const [convs, names] = await Promise.all([
this.sdk.query("crm.messenger.conversation.list", {}),
diff --git a/src/lib/realtime.tsx b/src/lib/realtime.tsx
new file mode 100644
index 0000000..d9f7d4c
--- /dev/null
+++ b/src/lib/realtime.tsx
@@ -0,0 +1,43 @@
+"use client";
+
+// One shared IIOS message socket for the whole dashboard, so the messenger tab AND the app-wide
+// notification center use a single connection (not one each). Opened at the dashboard level and
+// kept alive across tab switches; the messenger tab reuses it via useRealtime().
+
+import { createContext, useContext, useEffect, useState, type ReactNode } from "react";
+import { useQuery } from "@abe-kap/appshell-sdk/react";
+import { MessageSocket } from "@insignia/iios-kernel-client";
+import { isShellConfigured } from "./appshell";
+
+const RealtimeContext = createContext(null);
+interface RealtimeDTO { url: string; audience: string; token?: string }
+const SHELL = isShellConfigured();
+
+function LiveRealtimeProvider({ children }: { children: ReactNode }) {
+ const rt = useQuery("crm.messenger.realtime", {});
+ const [socket, setSocket] = useState(null);
+ const url = rt.data?.url;
+ const token = rt.data?.token;
+ useEffect(() => {
+ if (!url || !token) return;
+ const s = new MessageSocket({ serviceUrl: url, token, autoConnect: false });
+ s.connect();
+ setSocket(s);
+ return () => {
+ s.disconnect();
+ setSocket(null);
+ };
+ }, [url, token]);
+ return {children};
+}
+
+export function RealtimeProvider({ children }: { children: ReactNode }) {
+ // SHELL is a build-time constant, so the same branch runs every render (Rules-of-Hooks safe).
+ if (!SHELL) return <>{children};
+ return {children};
+}
+
+/** The shared socket, or null (demo mode / not yet connected). */
+export function useRealtime(): MessageSocket | null {
+ return useContext(RealtimeContext);
+}