ChannelRegistry

getChannels(): ChannelEntry[]

getChannelInstances(): ChannelInstance[]

findByName(name: string): ChannelInstance | undefined

hasAny(): boolean

get size(): number

getCapabilities(): Partial<ServerCapabilities>

subscribe(
  opts: { immediate?: boolean },
  cb: (e: ChannelChangeEvent) => void
): () => void

type ChannelChangeEvent = {
  kind: 'added' | 'updated' | 'removed' | 'reset';
  changeScope: 'global' | 'session';
  sessionId?: string;
  version: number;
  snapshot: readonly ChannelEntry[];
};

// From a tool context
const scope = this.scope as unknown as { channels?: ChannelRegistry };
const channels = scope.channels;

if (channels?.hasAny()) {
  const allChannels = channels.getChannels();
  const chatBridge = channels.findByName('chat-bridge');
}

scope.notifications.subscribeChannel(sessionId: string, channelName: string): boolean

scope.notifications.unsubscribeChannel(sessionId: string, channelName: string): boolean

scope.notifications.subscribeAllChannels(sessionId: string, channelNames: string[]): void

scope.notifications.isChannelSubscribed(sessionId: string, channelName: string): boolean

scope.notifications.getSubscribersForChannel(channelName: string): string[]

scope.notifications.getChannelSubscriptions(sessionId: string): string[]

// ChannelInstance.pushNotification() with targetSessionId
channel.pushNotification('Job completed', { job: 'daily-report' }, targetSessionId);
//                                                                  ^^^^^^^^^^^^^^^^
//                                                            only this session receives it

channel.replayBufferedEvents(sessionId: string): number

channel.clearReplayBuffer(): void

const scope = this.scope as unknown as {
  channelNotifications?: ChannelNotificationService;
};

// Send to all sessions subscribed to 'status' channel
scope.channelNotifications?.send('status', 'Deployment complete');

// Send to a specific session only
scope.channelNotifications?.sendToSession(sessionId, 'Job result', { source: 'jobs' });

const scope = this.scope as unknown as { channelEventBus?: ChannelEventBus };

// Emit an event that channels with matching app-event source receive
scope.channelEventBus?.emit('app:error', {
  message: 'Connection refused',
  level: 'critical',
});