diff options
| author | Adam Malczewski <[email protected]> | 2026-06-27 01:09:39 +0900 |
|---|---|---|
| committer | Adam Malczewski <[email protected]> | 2026-06-27 01:09:39 +0900 |
| commit | 61e45e60d699ed1ca46f94a8f181c92a940317c6 (patch) | |
| tree | 2892d9773c5a8e367e1e58cdb1e88d9c6ad3fe6d /packages/message-queue/src/extension.ts | |
| parent | 63c7e64532e85e0bbdd6d9ac6825d8f86be98e7a (diff) | |
| parent | 727c98c9dae516a2070eb950410314380a20c974 (diff) | |
| download | dispatch-61e45e60d699ed1ca46f94a8f181c92a940317c6.tar.gz dispatch-61e45e60d699ed1ca46f94a8f181c92a940317c6.zip | |
Merge branch 'feature/indent-change' into dev
Diffstat (limited to 'packages/message-queue/src/extension.ts')
| -rw-r--r-- | packages/message-queue/src/extension.ts | 106 |
1 files changed, 53 insertions, 53 deletions
diff --git a/packages/message-queue/src/extension.ts b/packages/message-queue/src/extension.ts index 26d19ca..29979be 100644 --- a/packages/message-queue/src/extension.ts +++ b/packages/message-queue/src/extension.ts @@ -12,71 +12,71 @@ import { buildQueueSpec, MESSAGE_QUEUE_SURFACE_ID } from "./pure.js"; import { createMessageQueueService, messageQueueHandle } from "./service.js"; export const manifest: Manifest = { - id: "message-queue", - name: "Message Queue", - version: "0.0.0", - apiVersion: "^0.1.0", - trust: "bundled", - activation: "eager", - dependsOn: ["surface-registry"], - capabilities: {}, - contributes: { - services: ["message-queue"], - }, + id: "message-queue", + name: "Message Queue", + version: "0.0.0", + apiVersion: "^0.1.0", + trust: "bundled", + activation: "eager", + dependsOn: ["surface-registry"], + capabilities: {}, + contributes: { + services: ["message-queue"], + }, }; export function activate(host: HostAPI): void { - const registry = host.getService(surfaceRegistryHandle); + const registry = host.getService(surfaceRegistryHandle); - const subscribers = new Set<() => void>(); + const subscribers = new Set<() => void>(); - const service = createMessageQueueService({ - id: () => crypto.randomUUID(), - now: () => Date.now(), - notify: () => { - for (const sub of subscribers) { - sub(); - } - }, - logger: host.logger, - }); + const service = createMessageQueueService({ + id: () => crypto.randomUUID(), + now: () => Date.now(), + notify: () => { + for (const sub of subscribers) { + sub(); + } + }, + logger: host.logger, + }); - host.provideService(messageQueueHandle, service); + host.provideService(messageQueueHandle, service); - function getSpec(context?: SurfaceContext): SurfaceSpec { - const convId = context?.conversationId; - const messages = convId === undefined ? [] : service.getQueue(convId); - return buildQueueSpec(messages); - } + function getSpec(context?: SurfaceContext): SurfaceSpec { + const convId = context?.conversationId; + const messages = convId === undefined ? [] : service.getQueue(convId); + return buildQueueSpec(messages); + } - function invoke(_actionId: string, _payload?: unknown, _context?: SurfaceContext): void { - // The message-queue surface is read-only: a client renders the queue and - // the session-orchestrator drains it. No client-facing actions. - } + function invoke(_actionId: string, _payload?: unknown, _context?: SurfaceContext): void { + // The message-queue surface is read-only: a client renders the queue and + // the session-orchestrator drains it. No client-facing actions. + } - const provider: SurfaceProvider = { - catalogEntry: { - id: MESSAGE_QUEUE_SURFACE_ID, - region: "side", - title: "Message Queue", - scope: "conversation", - }, - getSpec, - invoke, - subscribe(onChange) { - subscribers.add(onChange); - return () => { - subscribers.delete(onChange); - }; - }, - }; + const provider: SurfaceProvider = { + catalogEntry: { + id: MESSAGE_QUEUE_SURFACE_ID, + region: "side", + title: "Message Queue", + scope: "conversation", + }, + getSpec, + invoke, + subscribe(onChange) { + subscribers.add(onChange); + return () => { + subscribers.delete(onChange); + }; + }, + }; - registry.register(provider); + registry.register(provider); - host.logger.info("message-queue: registered"); + host.logger.info("message-queue: registered"); } export const extension: Extension = { - manifest, - activate, + manifest, + activate, }; |
