summaryrefslogtreecommitdiffhomepage
path: root/packages/message-queue/src/extension.ts
diff options
context:
space:
mode:
authorAdam Malczewski <[email protected]>2026-06-27 01:09:39 +0900
committerAdam Malczewski <[email protected]>2026-06-27 01:09:39 +0900
commit61e45e60d699ed1ca46f94a8f181c92a940317c6 (patch)
tree2892d9773c5a8e367e1e58cdb1e88d9c6ad3fe6d /packages/message-queue/src/extension.ts
parent63c7e64532e85e0bbdd6d9ac6825d8f86be98e7a (diff)
parent727c98c9dae516a2070eb950410314380a20c974 (diff)
downloaddispatch-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.ts106
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,
};