summaryrefslogtreecommitdiffhomepage
path: root/packages/message-queue/src/extension.ts
diff options
context:
space:
mode:
authorAdam Malczewski <[email protected]>2026-06-27 01:12:40 +0900
committerAdam Malczewski <[email protected]>2026-06-27 01:12:40 +0900
commit98b0638838a8e754927d8c030ce8bded18d63e7d (patch)
tree0d4e21c3d4792fcd77e1040373b260e38efa34ce /packages/message-queue/src/extension.ts
parentd92a4af6191d7d20acf861adf605ad0227b6b287 (diff)
parent61e45e60d699ed1ca46f94a8f181c92a940317c6 (diff)
downloaddispatch-98b0638838a8e754927d8c030ce8bded18d63e7d.tar.gz
dispatch-98b0638838a8e754927d8c030ce8bded18d63e7d.zip
Merge branch 'dev' into feature/heartbeat
# Conflicts: # packages/host-bin/package.json # packages/host-bin/src/main.ts # packages/session-orchestrator/src/orchestrator.ts # packages/system-prompt/src/service.test.ts # packages/system-prompt/src/service.ts # packages/system-prompt/src/types.ts # packages/transport-contract/package.json # packages/transport-http/package.json # packages/transport-http/src/app.test.ts # packages/transport-http/src/app.ts # packages/transport-http/src/extension.ts # packages/transport-http/tsconfig.json # tsconfig.json
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,
};