Interface HubTopology

interface HubTopology {
forwardSubscribe(tenantId: string, request: Request): Promise<Response>;
publish(event: ApprovalStreamEvent): Promise<void>;
}

Index

Methods

forwardSubscribe publish

Methods

forwardSubscribe

forwardSubscribe(tenantId: string, request: Request): Promise<Response>
Forward an already-verified WebSocket upgrade Request to a tenant's hub. The caller (stream-router.ts) has rewritten it to /subscribe with the ticket's actorId/role as query params; this only routes it to idFromName(tenantId).
Parameters
- tenantId: string
- request: Request
Returns Promise<Response>
- Defined in packages/flowsafe/src/host-kit/hub-topology.ts:55

publish

publish(event: ApprovalStreamEvent): Promise<void>
Forward one approval stream event to its tenant's hub, POSTing it to the hub's /internal/event route. Routed by event.record.tenantId, which the hub re-asserts against its own id.name (defense in depth).
Parameters
- event: ApprovalStreamEvent
Returns Promise<void>
- Defined in packages/flowsafe/src/host-kit/hub-topology.ts:49