Function getWorkflowService

src/workflow/service.ts:98–111

()

/** Process singleton. Tool and panel share the same ports/registry/store. */
export function getWorkflowService(): WorkflowService {
  if (cached) return cached
  const bus = createProgressBus()
  const store = createProgressStoreFromBus(bus)
  const ports = createWorkflowPorts({ bus, store })
  const service = makeService(ports, store)
  // Subscribe to run_done to write the terminal snapshot to disk (shared entry for completed/failed/killed; shutdown-kill also routes here).
  // The store registers to the bus before this subscription, so when the listener runs store.get(runId) is already terminal.
  attachRunStatePersistence(bus, store)
  // Install the state-change notification bridge (commit 0768d4dc promised "auto-notify on completion" but the old implementation left it unfulfilled)
  installWorkflowNotifications(service)
  cached = service
  return cached
}

/**
 * Construct the service (inject ports + store).