fix(workflow): bundle build & register workflow

- Add missing agent deps to template package.json so bun workspace
  resolution works during `bun build` (workflow-agent-cursor for develop,
  workflow-agent-hermes + workflow-execute for solve-issue)
- Create scripts/build-bundles.sh that builds both template bundles into
  dist/*.esm.js with correct --external flags for runtime-symlinked packages
- Add build:bundles script to root package.json
- Extend ensureUncagedWorkflowSymlink to also symlink workflow-util,
  workflow-execute, and workflow-register (needed by externalized bundles)
- Defer agent creation in develop bundle-entry.ts via lazy init so
  requireEnv('WORKFLOW_LLM_API_KEY') only throws at first invocation,
  not at import() time (fixes workflowAsAgent crash)
- Document that env vars must be set before the first worker spawn
  (workers are persistent and don't inherit later env changes)

Fixes #206

Co-authored-by: Cursor <cursoragent@cursor.com>

.changeset/README.md

@@ -1,8 +0,0 @@
-# Changesets
-
-Hello and welcome! This folder has been automatically generated by `@changesets/cli`, a build tool that works
-with multi-package repos, or single-package repos to help you version and publish your code. You can
-find the full documentation for it [in our repository](https://github.com/changesets/changesets).
-
-We have a quick list of common questions to get you started engaging with this project in
-[our documentation](https://github.com/changesets/changesets/blob/main/docs/common-questions.md).

.changeset/config.json

@@ -1,11 +0,0 @@
-{
-  "$schema": "https://unpkg.com/@changesets/config@3.1.4/schema.json",
-  "changelog": "@changesets/cli/changelog",
-  "commit": false,
-  "fixed": [["@uncaged/*"]],
-  "linked": [],
-  "access": "public",
-  "baseBranch": "main",
-  "updateInternalDependencies": "patch",
-  "ignore": ["@uncaged/workflow-dashboard"]
-}

.changeset/env-api-unify.md

@@ -1,5 +0,0 @@
----
-"@uncaged/workflow-util": patch
----
-
-Replace optionalEnv/requireEnv with unified env(name, fallback) API

.changeset/fix-internal-deps.md

@@ -1,5 +0,0 @@
----
-"@uncaged/workflow-protocol": patch
----
-
-fix: correct internal dependency versions for prerelease

.changeset/fix-publish-src.md

@@ -1,5 +0,0 @@
----
-"@uncaged/workflow-util-agent": patch
----
-
-fix: include create-agent-adapter.ts in published src

.changeset/fix-workspace-deps.md

@@ -1,5 +0,0 @@
----
-"@uncaged/workflow-protocol": patch
----
-
-fix: use npm publish with pinned deps instead of bun publish (workspace:^ resolution bug)

.changeset/pre.json

@@ -1,30 +0,0 @@
-{
-  "mode": "pre",
-  "tag": "alpha",
-  "initialVersions": {
-    "@uncaged/cli-workflow": "0.4.5",
-    "@uncaged/workflow-agent-cursor": "0.4.5",
-    "@uncaged/workflow-agent-hermes": "0.4.5",
-    "@uncaged/workflow-agent-llm": "0.4.5",
-    "@uncaged/workflow-agent-react": "0.4.5",
-    "@uncaged/workflow-cas": "0.4.5",
-    "@uncaged/workflow-dashboard": "0.1.0",
-    "@uncaged/workflow-execute": "0.4.5",
-    "@uncaged/workflow-gateway": "0.4.5",
-    "@uncaged/workflow-protocol": "0.4.5",
-    "@uncaged/workflow-reactor": "0.4.5",
-    "@uncaged/workflow-register": "0.4.5",
-    "@uncaged/workflow-runtime": "0.4.5",
-    "@uncaged/workflow-template-develop": "0.4.5",
-    "@uncaged/workflow-template-solve-issue": "0.4.5",
-    "@uncaged/workflow-util": "0.4.5",
-    "@uncaged/workflow-util-agent": "0.4.5"
-  },
-  "changesets": [
-    "env-api-unify",
-    "fix-internal-deps",
-    "fix-publish-src",
-    "fix-workspace-deps",
-    "rfc-252-agent-fn"
-  ]
-}

.changeset/rfc-252-agent-fn.md

@@ -1,5 +0,0 @@
----
-"@uncaged/workflow-protocol": minor
----
-
-feat: AgentFn<Opt> type boundary and createAgentAdapter bridging function (RFC #252)

.githooks/pre-push

@@ -1,10 +0,0 @@
-#!/usr/bin/env bash
-set -euo pipefail
-
-echo "🔍 Running check (tsc + biome + lint-log-tags)..."
-bun run check
-
-echo "🧪 Running tests..."
-bun run test
-
-echo "✅ All checks passed!"

.gitignore

@@ -5,11 +5,3 @@ bun.lock
 tsconfig.tsbuildinfo
 .npmrc
 
-bunfig.toml
-xiaoju/
-solve-issue-entry.ts
-packages/workflow-template-develop/develop.esm.js
-.DS_Store
-*.py
-.claude
-tmp

.plan/335-setup-validate.md

@@ -1,83 +0,0 @@
-# Test Spec: uwf setup model connectivity validation (#335)
-
-## Context
-
-File: `packages/cli-workflow/src/commands/setup.ts`
-Test file: `packages/cli-workflow/src/__tests__/setup-validate.test.ts`
-
-After `cmdSetup` writes config, it should send a test chat completion request to verify the configured model is reachable. If validation fails, warn the user (don't abort — config is already saved).
-
-## Implementation Notes
-
-- Add a `validateModel(baseUrl, apiKey, model)` function that sends a minimal chat completion request (`POST /chat/completions` with `messages: [{role:"user",content:"hi"}]`, `max_tokens: 1`)
-- Returns `Result<void, string>` — ok if 2xx response, error with reason string otherwise
-- Use `AbortSignal.timeout(15_000)` for the request
-- Both `cmdSetup` and `cmdSetupInteractive` should call it after saving config
-- `cmdSetup` returns validation result in its return object: `{ ...existing, validation: { ok: true } | { ok: false, error: string } }`
-- `cmdSetupInteractive` prints a warning to console if validation fails, success message if it passes
-- Use the project logger (`createLogger`) — no raw `console.log` except in interactive CLI output (per CLAUDE.md)
-
-## Test Cases (vitest)
-
-### 1. `validateModel` — success path
-- Mock `fetch` to return `{ status: 200, ok: true, json: () => ({}) }`
-- Call `validateModel(baseUrl, apiKey, model)`
-- Assert returns `{ ok: true, value: undefined }`
-- Assert fetch was called with correct URL (`${baseUrl}/chat/completions`), correct headers (`Authorization: Bearer ${apiKey}`), correct body (model, messages, max_tokens: 1)
-
-### 2. `validateModel` — HTTP error (401 unauthorized)
-- Mock `fetch` to return `{ status: 401, ok: false, statusText: "Unauthorized" }`
-- Call `validateModel(baseUrl, apiKey, model)`
-- Assert returns `{ ok: false, error: <string containing "401"> }`
-
-### 3. `validateModel` — HTTP error (404 model not found)
-- Mock `fetch` to return `{ status: 404, ok: false, statusText: "Not Found" }`
-- Assert returns `{ ok: false, error: <string containing "404"> }`
-
-### 4. `validateModel` — network timeout
-- Mock `fetch` to throw `DOMException` with name `AbortError`
-- Assert returns `{ ok: false, error: <string containing "timeout" or "unreachable"> }`
-
-### 5. `validateModel` — network error (DNS failure, connection refused)
-- Mock `fetch` to throw `TypeError("fetch failed")`
-- Assert returns `{ ok: false, error: <string mentioning connectivity> }`
-
-### 6. `cmdSetup` — includes validation result on success
-- Mock global `fetch` for `/chat/completions` to succeed
-- Call `cmdSetup({ provider, baseUrl, apiKey, model, storageRoot })`
-- Assert returned object has `validation: { ok: true, value: undefined }`
-- Assert config files are still written (existing behavior preserved)
-
-### 7. `cmdSetup` — includes validation result on failure (config still saved)
-- Mock global `fetch` for `/chat/completions` to return 401
-- Call `cmdSetup({ ... })`
-- Assert returned object has `validation: { ok: false, error: ... }`
-- Assert `config.yaml` and `.env` are still written (validation failure doesn't prevent saving)
-
-### 8. `cmdSetupInteractive` — prints success message on validation pass
-- Mock `fetch` for both `/models` and `/chat/completions` to succeed
-- Mock stdin to provide valid selections
-- Capture console output
-- Assert output contains a success message like "Model verified" or "✓"
-
-### 9. `cmdSetupInteractive` — prints warning on validation failure
-- Mock `fetch`: `/models` succeeds, `/chat/completions` returns 401
-- Mock stdin for valid selections
-- Capture console output
-- Assert output contains a warning about model not being reachable and suggests trying a different model
-
-### 10. `validateModel` — request body correctness
-- Mock `fetch` to capture the request body
-- Call `validateModel(baseUrl, apiKey, "test-model")`
-- Assert body is `{ model: "test-model", messages: [{role: "user", content: "hi"}], max_tokens: 1 }`
-
-## Export Requirements
-
-- `validateModel` must be exported (for direct unit testing)
-- Signature: `async function validateModel(baseUrl: string, apiKey: string, model: string): Promise<Result<void, string>>`
-- `Result` type: `{ ok: true; value: T } | { ok: false; error: E }` (project convention)
-
-## Files to Create/Modify
-
-- **New**: `packages/cli-workflow/src/__tests__/setup-validate.test.ts` — all test cases above
-- **Modify**: `packages/cli-workflow/src/commands/setup.ts` — add `validateModel`, integrate into `cmdSetup` and `cmdSetupInteractive`

.workflows/solve-issue.yaml

@@ -1,196 +0,0 @@
-name: "solve-issue"
-description: "TDD-driven issue resolution for small, focused changes. Loop protection relies on engine maxRounds."
-roles:
-  planner:
-    description: "Analyzes issue and outputs a TDD test spec"
-    goal: "You are a planning agent. You analyze Gitea issues and produce a TDD test specification that downstream roles will implement and verify."
-    capabilities:
-      - issue-analysis
-      - planning
-    procedure: |
-      On first run (no previous steps):
-      1. Read the issue and all comments from Gitea using `tea issues <number> -r <owner/repo>`
-      2. Read CLAUDE.md (or equivalent project conventions file) to understand coding standards
-      3. Assess whether the issue has enough information to produce a test spec
-      4. If insufficient info: comment on the issue via `echo "..." | tea comment <number> -r <owner/repo>` (skip if you already commented), then output status=insufficient_info and terminate
-      5. If sufficient: produce a detailed TDD test spec in markdown covering all scenarios
-
-      On subsequent runs (bounced back by tester with fix_spec):
-      1. Read the tester's output from the previous step to understand what's wrong with the spec
-      2. Revise the test spec accordingly
-
-      After producing the test spec:
-      1. Store it via `uwf cas put-text "<markdown content>"` and capture the returned hash
-      2. Put the hash in frontmatter.plan (required when status=ready)
-    output: "Output a brief summary of the test spec. Frontmatter must include: status (ready or insufficient_info) and plan (CAS hash of the test spec, required when status=ready)."
-    frontmatter:
-      type: object
-      properties:
-        status:
-          type: string
-          enum: [ready, insufficient_info]
-        plan:
-          type: string
-      required: [status]
-  developer:
-    description: "TDD implementation per test spec"
-    goal: "You are a developer agent. You implement code changes following TDD — write tests first, then implementation."
-    capabilities:
-      - coding
-    procedure: |
-      Before starting any work, ensure a clean worktree:
-      1. `git checkout main && git pull` to get the latest code
-      2. `git checkout -b fix/<issue-number>-<short-description>` to create a fresh branch
-         - If bounced back from reviewer or tester, reuse the existing branch instead
-
-      Then implement TDD:
-      3. Read the test spec from CAS: `uwf cas get <plan hash>` (find the hash from the latest planner step's frontmatter.plan)
-      4. If bounced back from reviewer or tester: read the previous role's output to understand what needs fixing
-      5. Write tests first based on the spec
-      6. Implement the code to make tests pass
-      7. Ensure `bun run build` passes with no errors
-      8. Run `bun test` to verify all tests pass
-    output: "List all files changed and provide a summary. Frontmatter must include: status (done or failed)."
-    frontmatter:
-      type: object
-      properties:
-        status:
-          type: string
-          enum: [done, failed]
-      required: [status]
-  reviewer:
-    description: "Code standards compliance check"
-    goal: "You are a code reviewer. You verify code standards compliance — NOT functionality (that's the tester's job)."
-    capabilities:
-      - code-review
-      - static-analysis
-    procedure: |
-      Before reviewing, verify the git branch:
-      1. Run `git branch --show-current` — confirm the branch name references the issue number being worked on
-      2. If the branch doesn't correspond to the issue, flag it in your output and reject
-
-      Then perform code review:
-      Hard checks (must all pass):
-      3. `bun run build` — no build errors
-      4. `bunx biome check` — no lint violations
-      5. TypeScript strict mode — no type errors
-
-      Soft checks (review against CLAUDE.md conventions):
-      - Functional-first: `function` + `type`, not `class` + `interface`
-      - No optional properties (`?:`) — use `T | null`
-      - Naming conventions (kebab-case files, PascalCase types, camelCase functions)
-      - Module boundary discipline (folder exports via index.ts)
-      - No `console.log` (use structured logger)
-      - No dynamic imports in production code
-
-      Only review standards compliance. Do NOT test functionality.
-      If rejecting, you MUST explain the specific reason in your output.
-    output: "Explain your decision with specific file/line references. Frontmatter must include: approved (true or false)."
-    frontmatter:
-      type: object
-      properties:
-        approved:
-          type: boolean
-      required: [approved]
-  tester:
-    description: "Functional correctness verification"
-    goal: "You are a tester agent. You verify that the implementation correctly satisfies every scenario in the test spec."
-    capabilities:
-      - testing
-    procedure: |
-      1. Run `bun test` for automated test verification
-      2. Read the test spec from CAS: `uwf cas get <plan hash>` (find the hash from the latest planner step's frontmatter.plan)
-      3. Verify each scenario in the spec is covered and passing
-      4. Determine outcome:
-         - passed: all scenarios verified, tests pass
-         - fix_code: tests fail or implementation doesn't match spec → send back to developer
-         - fix_spec: the spec itself is wrong or incomplete → send back to planner
-    output: "Report test results per scenario. Frontmatter must include: status (passed, fix_code, or fix_spec)."
-    frontmatter:
-      type: object
-      properties:
-        status:
-          type: string
-          enum: [passed, fix_code, fix_spec]
-      required: [status]
-  committer:
-    description: "Commits and creates PR"
-    goal: "You are a committer agent. You create a clean commit and push a PR linking the original issue."
-    capabilities: []
-    procedure: |
-      Note: You inherit the developer's worktree and branch. Do NOT create a new branch.
-      1. Stage all changes: `git add -A`
-      2. Commit with a descriptive message referencing the issue: `git commit -m "type: description\n\nFixes #N"`
-      3. Push the branch: `git push -u origin <branch-name>`
-         - If push hook fails: capture the error log in your output, mark hook_failed
-      4. On push success: create a PR via `tea pr create --title "..." --description "..."`
-         - PR description must follow the project template: What / Why / Changes / Ref sections, with `Fixes #N` in Ref
-    output: "Include PR URL on success or error log on failure. Frontmatter must include: success (true or false)."
-    frontmatter:
-      type: object
-      properties:
-        success:
-          type: boolean
-      required: [success]
-conditions:
-  insufficientInfo:
-    description: "Planner determined there's not enough info to proceed"
-    expression: "$last('planner').status = 'insufficient_info'"
-  devFailed:
-    description: "Developer failed to implement"
-    expression: "$last('developer').status = 'failed'"
-  rejected:
-    description: "Reviewer rejected the implementation"
-    expression: "$last('reviewer').approved = false"
-  fixCode:
-    description: "Tester found code issues"
-    expression: "$last('tester').status = 'fix_code'"
-  fixSpec:
-    description: "Tester found spec issues"
-    expression: "$last('tester').status = 'fix_spec'"
-  hookFailed:
-    description: "Push hook failed"
-    expression: "$last('committer').success = false"
-graph:
-  $START:
-    - role: "planner"
-      condition: null
-      prompt: "Analyze the issue and produce an implementation plan."
-  planner:
-    - role: "$END"
-      condition: "insufficientInfo"
-      prompt: "Insufficient information to proceed; end the workflow."
-    - role: "developer"
-      condition: null
-      prompt: "Implement the plan from the planner."
-  developer:
-    - role: "$END"
-      condition: "devFailed"
-      prompt: "Development failed; end the workflow."
-    - role: "reviewer"
-      condition: null
-      prompt: "Send the implementation to the reviewer."
-  reviewer:
-    - role: "developer"
-      condition: "rejected"
-      prompt: "Reviewer rejected the implementation; fix the issues."
-    - role: "tester"
-      condition: null
-      prompt: "Review passed; run tests on the implementation."
-  tester:
-    - role: "developer"
-      condition: "fixCode"
-      prompt: "Tests found code issues; return to developer."
-    - role: "planner"
-      condition: "fixSpec"
-      prompt: "Tests found spec issues; return to planner."
-    - role: "committer"
-      condition: null
-      prompt: "Tests passed; commit and push the changes."
-  committer:
-    - role: "developer"
-      condition: "hookFailed"
-      prompt: "Push hook failed; return to developer to fix."
-    - role: "$END"
-      condition: null
-      prompt: "Commit succeeded; complete the workflow."

CLAUDE.md

@@ -2,41 +2,45 @@
 
 ## Project Overview
 
-This monorepo implements a stateless workflow engine driven by a single-step CLI (`uwf`). Workflows are **YAML definitions** stored as CAS nodes; threads are immutable chains of CAS-linked step nodes. No daemon — each `uwf thread step` invocation runs one moderator→agent→extract cycle and exits.
+This monorepo implements a workflow engine that executes single-file ESM bundles. Each workflow is a self-contained `.esm.js` file with an XXH64 hash as its version identifier. Shared types live in `@uncaged/workflow-protocol`; bundle authors typically depend on `@uncaged/workflow-runtime`.
 
 ### Key Terms
 
 | Concept | What it is |
 |---------|-----------|
-| **Workflow** | A YAML definition (`WorkflowPayload`) with roles, conditions, and a routing graph. Stored as a CAS node, identified by its XXH64 hash. |
-| **Thread** | A single execution of a workflow, identified by a ULID. State is an immutable CAS chain; active threads indexed in `threads.yaml`; completed threads in `history.jsonl`. |
-| **Role** | A named actor within a workflow. Each role has a system prompt and a JSON Schema `outputSchema`. |
-| **Moderator** | JSONata-based graph evaluator — determines the next role (or `$END`) with zero LLM cost. |
-| **Agent** | An external CLI command (`uwf-hermes`, etc.) spawned by `uwf thread step`. Produces frontmatter markdown output. |
-| **CAS** | Content-Addressed Storage via `@uncaged/json-cas` — all workflow definitions, thread nodes, and outputs are immutable CAS nodes. |
-| **Registry** | `~/.uncaged/workflow/registry.yaml` — maps workflow names to current CAS hashes. |
+| **Workflow** | A single-file ESM module that exports `run` (workflow function) and `descriptor` (metadata). Identified by its XXH64 hash (Crockford Base32). |
+| **Bundle** | The physical `.esm.js` file stored in `~/.uncaged/workflow/bundles/`. |
+| **Thread** | A single execution of a workflow, identified by a ULID. State lives in CAS (linked nodes); active threads indexed in `threads.json`; completed rows in `history/*.jsonl`. Debug logs use `.info.jsonl`. |
+| **Role** | A named actor within a workflow. Each role produces output with typed `meta`. |
+| **Registry** | `workflow.yaml` — maps workflow names to current/historical bundle hashes. |
 
 ### Monorepo Structure
 
 ```
 workflow/
   packages/
-    workflow-protocol/    # @uncaged/workflow-protocol — shared types (WorkflowPayload, StepNodePayload, WorkflowConfig, etc.)
-    workflow-util/        # @uncaged/workflow-util — Crockford Base32, ULID, logger, frontmatter parsing/validation
-    workflow-moderator/   # @uncaged/workflow-moderator — JSONata graph evaluator
-    workflow-agent-kit/   # @uncaged/workflow-agent-kit — createAgent factory, context builder, extract pipeline
-    workflow-agent-hermes/ # @uncaged/workflow-agent-hermes — uwf-hermes CLI binary (spawns hermes chat)
-    cli-workflow/         # @uncaged/cli-workflow — uwf CLI binary
-  legacy-packages/       # Archived packages (preserved for reference, not active)
-  examples/              # Workflow YAML examples (solve-issue.yaml)
-  docs/                  # Architecture docs
-  biome.json             # root Biome config
-  tsconfig.json          # root TypeScript config
+    workflow-protocol/              # @uncaged/workflow-protocol — shared types + Result
+    workflow-runtime/               # @uncaged/workflow-runtime — createWorkflow, type re-exports
+    workflow-util/                  # @uncaged/workflow-util — Base32, ULID, logger, storage paths, refs helpers
+    workflow-reactor/               # @uncaged/workflow-reactor — LLM fn + thread reactor (tool calls)
+    workflow-cas/                   # @uncaged/workflow-cas — CAS store, hash, Merkle
+    workflow-register/              # @uncaged/workflow-register — bundle validation, registry YAML, model resolution
+    workflow-execute/               # @uncaged/workflow-execute — engine, extract, fork, GC, workflowAsAgent
+    cli-workflow/                   # @uncaged/cli-workflow — uncaged-workflow CLI
+    workflow-agent-cursor/          # @uncaged/workflow-agent-cursor
+    workflow-agent-hermes/          # @uncaged/workflow-agent-hermes
+    workflow-agent-llm/             # @uncaged/workflow-agent-llm
+    workflow-util-agent/            # @uncaged/workflow-util-agent — buildAgentPrompt, spawnCli
+    workflow-template-develop/      # @uncaged/workflow-template-develop
+    workflow-template-solve-issue/  # @uncaged/workflow-template-solve-issue
+    workflow-dashboard/             # @uncaged/workflow-dashboard — React dashboard (private app)
+  docs/             # RFCs, conventions
+  biome.json        # root Biome config
+  tsconfig.json     # root TypeScript config
 ```
 
-- Dependency layers: `workflow-protocol` → (`workflow-util`, `workflow-moderator`) → `workflow-agent-kit` → `workflow-agent-hermes` / `cli-workflow`
-- Packages use `workspace:^` protocol (resolves to `^x.y.z` on publish)
-- External CAS: `@uncaged/json-cas` (store API, hashing, schema validation) + `@uncaged/json-cas-fs` (filesystem backend)
+- Execution stack layers: `workflow-protocol` → (`workflow-runtime`, `workflow-util`, `workflow-reactor`) → (`workflow-cas`, `workflow-register`) → `workflow-execute` → `cli-workflow`
+- Packages use `workspace:*` protocol
 
 ## Language & Paradigm
 
@@ -104,6 +108,8 @@ type WorkflowEntry = {
 - Always named exports, never default exports
 - One module = one responsibility, filename = purpose
 
+Workflow bundles (`.esm.js`) follow the same rule: export `const run` and `const descriptor`, not `export default`.
+
 ### Folder Module Discipline
 
 Every folder under `src/` is a **module boundary**. Four rules:
@@ -129,10 +135,10 @@ export { createCasStore } from "../cas/cas.js";
 
 // ❌ Bad — types defined in index.ts
 // in cas/index.ts:
-export type CasStore = { ... }; // should be in cas/types.ts
+export type CasStore = { ... };  // should be in cas/types.ts
 ```
 
-**Exception**: The package-level `src/index.ts` is the public API surface and re-exports from folder `index.ts` files. Files that remain at `src/` root (e.g. `types.ts`) are not inside a folder module and follow normal rules.
+**Exception**: The package-level `src/index.ts` is the public API surface and re-exports from folder `index.ts` files. Files that remain at `src/` root (e.g. `types.ts`, `workflow-as-agent.ts`) are not inside a folder module and follow normal rules.
 
 ## Naming
 
@@ -153,7 +159,7 @@ Workflow names use **verb-first** kebab-case:
 ### ID Encoding
 
 All IDs use **Crockford Base32**:
-- CAS hash: XXH64 → 13-char Crockford Base32
+- Bundle hash: XXH64 → 13-char Crockford Base32
 - Thread ID: ULID → 26-char Crockford Base32 (10 timestamp + 16 random)
 
 ## Error Handling
@@ -182,7 +188,7 @@ import { createLogger } from "@uncaged/workflow-util";
 const log = createLogger();
 
 // Each call site has a fixed 8-char Crockford Base32 tag
-log("4KNMR2PX", "Loading workflow...");
+log("4KNMR2PX", "Loading workflow bundle...");
 log("7BQST3VW", `Role ${role} started`);
 ```
 
@@ -197,7 +203,7 @@ log("7BQST3VW", `Role ${role} started`);
 
 ### Why fixed tags?
 
-- `grep "4KNMR2PX"` in logs → instant code location
+- `grep "4KNMR2PX"` in `.info.jsonl` → instant code location
 - No need for file/line info in the log — tag is the locator
 - Survives refactoring (tag stays the same when code moves)
 
@@ -214,82 +220,36 @@ console.log(result);
 
 Do NOT use `await import()` in production code. Always use static top-level `import`.
 
+**Exception**: The bundle loader and `extractBundleExports` dynamically import user workflow files at runtime.
+
+```ts
+// Dynamic import required: user bundle path resolved at runtime
+const mod = await import(bundlePath);
+```
+
 Test files (`__tests__/**`) are exempt.
 
 ## Toolchain
 
 | Tool | Purpose |
 |------|---------|
-| **bun** | Package manager + runtime |
+| **bun** | Package manager + runtime + test runner |
 | **TypeScript** | Type checking (strict mode) |
 | **Biome** | Lint + format (replaces ESLint + Prettier) |
-| **vitest** | Test runner (`cli-workflow` uses vitest; other packages use `bun test`) |
 
-### Development Workflow
+### Commands
 
 ```bash
-# ── Setup ──
-bun install                 # install all workspace dependencies
-
-# ── Daily development ──
-bun run build               # tsc --build (all packages, dependency order)
-bun run check               # tsc --build + biome check + lint-log-tags
-bun run format              # biome format --write
-bun test                    # run tests across all packages
-
-# ── Before committing ──
-bun run check               # must pass — typecheck + lint + log tag validation
-bun test                    # must pass — all package tests
+bun run check       # tsc --build + biome check
+bun run format      # biome format --write
+bun test            # run tests
 ```
 
-### Publishing
-
-All public `@uncaged/*` packages are published to **npmjs.org** with **fixed mode** (all packages share the same version number).
-
-```bash
-# 1. Add a changeset describing the change
-bun changeset
-
-# 2. Bump all package versions + generate CHANGELOGs
-bun version
-
-# 3. Build, test, and publish (runs scripts/publish-all.mjs)
-bun release
-
-# Or publish manually with a tag:
-node scripts/publish-all.mjs --tag alpha
-node scripts/publish-all.mjs --dry-run    # preview without publishing
-```
-
-- `workspace:^` dependencies resolve to `^x.y.z` on publish
-- Publish order defined in `scripts/publish-all.mjs` (dependency order)
-- Changesets config: `.changeset/config.json` (fixed mode, public access)
-
-### End-to-end: Author → Register → Run
-
-```
-examples/solve-issue.yaml       — write a workflow YAML definition
-  │  uwf workflow put
-  ▼
-~/.uncaged/workflow/cas/        — Workflow stored as CAS node
-~/.uncaged/workflow/registry.yaml — name → hash mapping updated
-  │  uwf thread start <name> -p "..."
-  ▼
-~/.uncaged/workflow/threads.yaml — new thread head pointer
-  │  uwf thread step <thread-id>
-  ▼
-moderator → agent → extract      — one step per invocation, repeat until $END
-```
-
-1. **Author** — write a workflow YAML file with roles, conditions, and graph
-2. **Register** — `uwf workflow put <file.yaml>` parses YAML, registers output schemas, stores `WorkflowPayload` in CAS
-3. **Run** — `uwf thread start` creates a thread, `uwf thread step` executes one cycle per invocation
-
 ## Commit Convention
 
 ```
 <type>(<scope>): <description>
 
 type: feat | fix | refactor | docs | chore | test
-scope: workflow | cli | moderator | agent-kit | hermes | util | protocol | ...
+scope: workflow | cli | rfc-001 | ...
 ```

README.md

@@ -1,93 +1,71 @@
 # @uncaged/workflow
 
-A stateless workflow engine driven by a single-step CLI. Workflows are YAML definitions with roles, JSONata routing conditions, and a directed graph. Threads are immutable CAS-linked chains — each `uwf thread step` runs one moderator→agent→extract cycle and exits.
+A workflow engine that executes single-file ESM bundles. Each workflow is a self-contained `.esm.js` file identified by its XXH64 hash (Crockford Base32).
 
-## Package Map
+## Core Concepts
 
-| Package | npm | Role |
-|---------|-----|------|
-| `cli-workflow` | `@uncaged/cli-workflow` | `uwf` CLI binary — thread lifecycle, workflow registry, CAS inspection, setup |
-| `workflow-protocol` | `@uncaged/workflow-protocol` | Shared TypeScript types (`WorkflowPayload`, `StepNodePayload`, `WorkflowConfig`, etc.) |
-| `workflow-moderator` | `@uncaged/workflow-moderator` | JSONata graph evaluator — determines next role or `$END` |
-| `workflow-agent-kit` | `@uncaged/workflow-agent-kit` | `createAgent` factory, context builder, two-layer extract pipeline |
-| `workflow-agent-hermes` | `@uncaged/workflow-agent-hermes` | `uwf-hermes` agent — spawns Hermes chat, captures session |
-| `workflow-util` | `@uncaged/workflow-util` | Crockford Base32, ULID, logger, frontmatter parsing |
+| Concept | Description |
+|---------|-------------|
+| **Workflow** | A single-file ESM module exporting `run` (workflow function) and `descriptor` (metadata). Identified by its XXH64 hash. |
+| **Bundle** | The physical `.esm.js` file stored in `~/.uncaged/workflow/bundles/`. |
+| **Thread** | A single execution of a workflow, identified by a ULID. CAS-backed chain plus `threads.json` / `history/*.jsonl`; `.info.jsonl` for debug logs. |
+| **Role** | A named actor within a workflow. Each role produces output with typed `meta`. Roles live inside template packages (`src/roles/`). |
+| **Registry** | `workflow.yaml` — maps workflow names to current/historical bundle hashes. |
+| **CAS** | Content-Addressed Storage — bundles are immutable and addressed by hash. |
 
-External: [`@uncaged/json-cas`](https://www.npmjs.com/package/@uncaged/json-cas) (CAS store + JSON Schema validation) + `@uncaged/json-cas-fs` (filesystem backend).
+## Monorepo Packages
+
+```
+packages/
+  workflow/                      # @uncaged/workflow — core lib (types, engine, hash, ULID, registry)
+  cli-workflow/                  # @uncaged/cli-workflow — CLI (`uncaged-workflow` command)
+  workflow-template-develop/     # @uncaged/workflow-template-develop — develop workflow template (includes roles)
+  workflow-template-solve-issue/ # @uncaged/workflow-template-solve-issue — solve-issue workflow template (includes roles)
+  workflow-agent-hermes/         # @uncaged/workflow-agent-hermes — Hermes agent adapter
+  workflow-agent-cursor/         # @uncaged/workflow-agent-cursor — Cursor agent adapter
+  workflow-agent-llm/            # @uncaged/workflow-agent-llm — LLM agent adapter
+  workflow-util-agent/           # @uncaged/workflow-util-agent — agent utilities (buildAgentPrompt, spawnCli)
+```
+
+Managed with **bun workspace** using the `workspace:*` protocol.
 
 ## Quick Start
 
 ```bash
-# 1. Configure provider and model
-uwf setup
+# Install dependencies
+bun install
 
-# 2. Register a workflow from YAML
-uwf workflow put examples/solve-issue.yaml
+# Build all packages
+bun run build
 
-# 3. Start a thread
-uwf thread start solve-issue -p "Fix the login redirect bug"
+# Register a workflow bundle
+uncaged-workflow workflow add solve-issue dist/packages/workflow-template-solve-issue/solve-issue.esm.js
 
-# 4. Execute steps (one at a time, until done)
-uwf thread step <thread-id>
+# Run a workflow
+uncaged-workflow run solve-issue --prompt "Fix bug #42"
 ```
 
-## CLI Commands
+## CLI Usage
 
-### Thread
+```bash
+uncaged-workflow                   # Print full command usage (exits with status 1)
+uncaged-workflow workflow list     # List registered workflows
+uncaged-workflow run <name>        # Start a workflow thread
+uncaged-workflow thread list       # List all threads
+uncaged-workflow thread show <id>  # Inspect a thread
+uncaged-workflow skill             # Agent-consumable reference docs
+```
 
-| Command | Description |
-|---------|-------------|
-| `uwf thread start <workflow> -p <prompt>` | Create a thread (no execution) |
-| `uwf thread step <thread-id> [--agent <cmd>]` | Execute one moderator→agent→extract cycle |
-| `uwf thread show <thread-id>` | Show head pointer and done status |
-| `uwf thread list [--all]` | List threads (`--all` includes archived) |
-| `uwf thread steps <thread-id>` | List all steps chronologically |
-| `uwf thread read <thread-id> [--quota N]` | Render thread as readable markdown |
-| `uwf thread fork <step-hash>` | Fork from a specific step |
-| `uwf thread step-details <step-hash>` | Dump full detail node |
-| `uwf thread kill <thread-id>` | Terminate and archive |
-
-### Workflow
-
-| Command | Description |
-|---------|-------------|
-| `uwf workflow put <file.yaml>` | Register a workflow from YAML |
-| `uwf workflow show <name-or-hash>` | Show workflow definition |
-| `uwf workflow list` | List registered workflows |
-
-### CAS
-
-| Command | Description |
-|---------|-------------|
-| `uwf cas get <hash>` | Read a CAS node |
-| `uwf cas put <type-hash> <data>` | Store a node |
-| `uwf cas has <hash>` | Check existence |
-| `uwf cas refs <hash>` | List direct references |
-| `uwf cas walk <hash>` | Recursive traversal |
-| `uwf cas reindex` | Rebuild type index |
-| `uwf cas schema list` | List schemas |
-| `uwf cas schema get <hash>` | Show a schema |
-
-### Setup
-
-| Command | Description |
-|---------|-------------|
-| `uwf setup` | Interactive provider/model/agent configuration |
-| `uwf setup --provider ... --base-url ... --api-key ... --model ...` | Non-interactive setup |
-
-Config stored in `~/.uncaged/workflow/config.yaml`. API keys in `~/.uncaged/workflow/.env`.
+Run `uncaged-workflow` with no arguments to print usage, or `uncaged-workflow skill cli` for the full CLI skill reference.
 
 ## Development
 
 ```bash
-bun install --no-cache     # Install dependencies
-bun run check              # tsc + biome + lint-log-tags
-bun run format             # Auto-format with Biome
-bun test                   # Run all tests
+bun run check    # Biome lint + format check
+bun run format   # Auto-format with Biome
+bun test         # Run tests
 ```
 
-Managed with **bun workspace**. See [CLAUDE.md](CLAUDE.md) for coding conventions.
-
 ## Architecture
 
-See [docs/architecture.md](docs/architecture.md) for the full design — three-phase engine loop, CAS node types, storage layout, agent CLI protocol, and design decisions.
+See [docs/architecture.md](docs/architecture.md) for the full design — three-phase engine loop, bundle contract, storage layout, and design decisions.

biome.json

@@ -1,15 +1,7 @@
 {
-  "$schema": "https://biomejs.dev/schemas/2.4.15/schema.json",
+  "$schema": "https://biomejs.dev/schemas/2.4.14/schema.json",
   "files": {
-    "includes": [
-      "**",
-      "!**/dist",
-      "!**/node_modules",
-      "!**/legacy-packages",
-      "!scripts",
-      "!packages/workflow/workflow",
-      "!xiaoju/scripts/bundle.ts"
-    ]
+    "includes": ["**", "!**/dist", "!**/node_modules", "!packages/workflow/workflow"]
   },
   "assist": { "actions": { "source": { "organizeImports": "on" } } },
   "formatter": {
@@ -38,7 +30,7 @@
       }
     },
     {
-      "includes": ["**/*.d.ts", "**/vitest.config.*"],
+      "includes": ["**/*.d.ts"],
       "linter": {
         "rules": {
           "style": {
@@ -46,16 +38,6 @@
           }
         }
       }
-    },
-    {
-      "includes": ["**/cli.ts", "**/setup.ts"],
-      "linter": {
-        "rules": {
-          "suspicious": {
-            "noConsole": "off"
-          }
-        }
-      }
     }
   ],
   "linter": {

bunfig.toml

@@ -0,0 +1,2 @@
+[test]
+pathIgnorePatterns = ["dist/**"]

docs/architecture.md

@@ -1,495 +1,268 @@
-# Workflow Engine — Architecture
+# Uncaged workflow — Architecture
 
-**Last updated:** 2026-05-19
+**Last updated:** 2026-05-09
 
 ---
 
 ## Overview
 
-A stateless workflow engine driven by a single-step CLI. Workflows are YAML definitions stored as CAS nodes; threads are immutable chains of CAS-linked step nodes. No daemon — each `uwf thread step` invocation runs one moderator→agent→extract cycle and exits.
+A workflow engine that executes single-file ESM bundles. Each workflow is a self-contained `.esm.js` file identified by its XXH64 hash (Crockford Base32). No daemon — processes start on demand and exit when done.
 
-The implementation lives in **6** active packages under `packages/`, plus two external CAS packages (`@uncaged/json-cas`, `@uncaged/json-cas-fs`). Legacy packages reside in `legacy-packages/` and are not part of the active stack.
+The implementation lives in **15** Bun workspace packages under `packages/`, using the `workspace:*` protocol.
 
 ## Package map
 
+Grouped by responsibility (npm name → folder).
+
 | Layer | Package | One-line role |
-|-------|---------|---------------|
-| Contract | `@uncaged/workflow-protocol` → `workflow-protocol` | Shared TypeScript types (`WorkflowPayload`, `StepNodePayload`, `ModeratorContext`, `WorkflowConfig`, etc.). No runtime deps beyond `@uncaged/json-cas-fs`. |
-| Shared infra | `@uncaged/workflow-util` → `workflow-util` | Crockford Base32, ULID generation, `createLogger`, frontmatter parsing/validation. |
-| Moderator | `@uncaged/workflow-moderator` → `workflow-moderator` | JSONata-based graph evaluator: given a `WorkflowPayload` and `ModeratorContext`, returns the next role or `$END`. |
-| Agent framework | `@uncaged/workflow-agent-kit` → `workflow-agent-kit` | `createAgent` entrypoint factory, context builder, frontmatter fast-path extractor, LLM extract fallback, output format instruction builder. |
-| Agent: Hermes | `@uncaged/workflow-agent-hermes` → `workflow-agent-hermes` | `uwf-hermes` CLI binary — spawns `hermes chat`, pipes prompt, captures session detail. |
-| CLI | `@uncaged/cli-workflow` → `cli-workflow` | `uwf` binary — thread lifecycle, workflow registry, CAS inspection, setup. |
+|-------|---------|----------------|
+| Contract | `@uncaged/workflow-protocol` → `workflow-protocol` | Shared TypeScript types and `Result` helpers; peer `zod` only — no other workspace deps. |
+| Author API | `@uncaged/workflow-runtime` → `workflow-runtime` | `createWorkflow` and re-exports of protocol workflow types for bundle authors. |
+| Shared infra | `@uncaged/workflow-util` → `workflow-util` | Base32/ULID, logger, storage root paths, global CAS dir, ref-field helpers. |
+| LLM plumbing | `@uncaged/workflow-reactor` → `workflow-reactor` | `createLlmFn`, `createThreadReactor`, and related tool-call types for threaded LLM invocation. |
+| CAS | `@uncaged/workflow-cas` → `workflow-cas` | `CasStore` implementation, XXH64 hashing, Merkle helpers over CAS payloads. |
+| Registry / bundles | `@uncaged/workflow-register` → `workflow-register` | Bundle validation & dynamic export extraction, `workflow.yaml` registry I/O, provider/model resolution. |
+| Engine | `@uncaged/workflow-execute` → `workflow-execute` | Thread execution, worker entry path, fork/GC, extract pipeline, `workflowAsAgent`. |
+| CLI | `@uncaged/cli-workflow` → `cli-workflow` | `uncaged-workflow` binary (depends on engine, registry, CAS, protocol, util, runtime). |
+| Agent adapters | `@uncaged/workflow-agent-cursor` → `workflow-agent-cursor` | `AgentFn` via `cursor-agent` CLI + workspace extraction. |
+| | `@uncaged/workflow-agent-hermes` → `workflow-agent-hermes` | `AgentFn` via `hermes chat` CLI. |
+| | `@uncaged/workflow-agent-llm` → `workflow-agent-llm` | `AgentFn` via OpenAI-compatible HTTP (`LlmProvider` from runtime). |
+| Agent shared | `@uncaged/workflow-util-agent` → `workflow-util-agent` | `buildAgentPrompt`, `spawnCli` for CLI-backed agents. |
+| Templates | `@uncaged/workflow-template-develop` → `workflow-template-develop` | Develop workflow definition, roles, descriptor builder. |
+| | `@uncaged/workflow-template-solve-issue` → `workflow-template-solve-issue` | Solve-issue workflow definition, roles, descriptor builder. |
+| Dashboard | `@uncaged/workflow-dashboard` → `workflow-dashboard` | Private Vite + React app (`src/main.tsx`); only `react` / `react-dom` dependencies — no workspace packages. |
 
-### External dependencies
+## Dependency graph (workspace packages)
 
-| Package | Role |
-|---------|------|
-| `@uncaged/json-cas` | Content-addressed store API, XXH64 hashing, JSON Schema registration and validation. |
-| `@uncaged/json-cas-fs` | Filesystem backend for `json-cas`. |
-| `jsonata` | JSONata expression evaluator (used by `workflow-moderator`). |
-| `commander` | CLI argument parsing (used by `cli-workflow`). |
-| `dotenv` | Loads `.env` files for API keys. |
-| `yaml` | YAML parse/stringify. |
-
-## Dependency graph
+Bottom-up layering for the execution stack:
 
 ```mermaid
 flowchart BT
-  subgraph External
-    jcas["@uncaged/json-cas"]
-    jcasfs["@uncaged/json-cas-fs"]
-  end
   subgraph L0["Layer 0 — contract"]
     protocol["@uncaged/workflow-protocol"]
   end
-  subgraph L1["Layer 1 — shared"]
+  subgraph L1["Layer 1 — on protocol"]
+    runtime["@uncaged/workflow-runtime"]
     util["@uncaged/workflow-util"]
-    moderator["@uncaged/workflow-moderator"]
+    reactor["@uncaged/workflow-reactor"]
   end
-  subgraph L2["Layer 2 — agent framework"]
-    kit["@uncaged/workflow-agent-kit"]
+  subgraph L2["Layer 2 — protocol + util"]
+    cas["@uncaged/workflow-cas"]
+    register["@uncaged/workflow-register"]
   end
-  subgraph L3["Layer 3 — agent implementations"]
-    hermes["@uncaged/workflow-agent-hermes"]
+  subgraph L3["Layer 3 — engine"]
+    execute["@uncaged/workflow-execute"]
   end
   subgraph L4["Layer 4 — CLI"]
     cli["@uncaged/cli-workflow"]
   end
-  protocol --> jcasfs
+  runtime --> protocol
   util --> protocol
-  moderator --> protocol
-  kit --> protocol
-  kit --> util
-  kit --> jcas
-  kit --> jcasfs
-  hermes --> kit
-  hermes --> jcas
+  reactor --> protocol
+  cas --> protocol
+  cas --> util
+  register --> protocol
+  register --> util
+  execute --> protocol
+  execute --> runtime
+  execute --> util
+  execute --> cas
+  execute --> reactor
+  execute --> register
   cli --> protocol
   cli --> util
-  cli --> kit
-  cli --> moderator
-  cli --> jcas
-  cli --> jcasfs
+  cli --> cas
+  cli --> execute
+  cli --> register
+  cli --> runtime
 ```
 
-## Workflow definition
+**Adjacent consumers** (not in the main CLI stack):
 
-Workflows are **YAML files** (not ESM bundles). `uwf workflow put <file.yaml>` parses the YAML, registers output schemas as JSON Schema CAS nodes, and stores the `WorkflowPayload` as a CAS node.
+- `@uncaged/workflow-util-agent` → `@uncaged/workflow-runtime`
+- `@uncaged/workflow-agent-llm` → `@uncaged/workflow-runtime`
+- `@uncaged/workflow-agent-cursor` → `@uncaged/workflow-runtime`, `@uncaged/workflow-util-agent`, `zod`
+- `@uncaged/workflow-agent-hermes` → `@uncaged/workflow-runtime`, `@uncaged/workflow-util-agent`
+- `@uncaged/workflow-template-develop` → `@uncaged/workflow-register`, `@uncaged/workflow-runtime`, `zod`
+- `@uncaged/workflow-template-solve-issue` → `@uncaged/workflow-register`, `@uncaged/workflow-runtime`, `zod` (dev-only workspace deps: `@uncaged/workflow-cas`, `@uncaged/workflow-execute` for tests/tooling per `package.json`)
 
-Example (`examples/solve-issue.yaml`):
+## Package roles (detail)
 
-```yaml
-name: "solve-issue"
-description: "End-to-end issue resolution"
-roles:
-  planner:
-    description: "Creates implementation plan"
-    goal: "You are a planning agent. Analyze the issue and create a step-by-step plan."
-    capabilities:
-      - issue-analysis
-      - planning
-    procedure: "Analyze the issue and create a detailed, actionable implementation plan."
-    output: "Output the plan summary and list of concrete steps."
-    meta:
-      type: object
-      properties:
-        plan: { type: string }
-        steps: { type: array, items: { type: string } }
-      required: [plan, steps]
-  developer:
-    description: "Implements code changes"
-    goal: "You are a developer agent. Implement the plan."
-    capabilities:
-      - file-edit
-      - shell
-    procedure: "Implement the plan. Write code, tests, and ensure existing tests pass."
-    output: "List all files changed and provide a summary of the implementation."
-    meta:
-      type: object
-      properties:
-        filesChanged: { type: array, items: { type: string } }
-        summary: { type: string }
-      required: [filesChanged, summary]
-  reviewer:
-    description: "Reviews code changes"
-    goal: "You are a code reviewer. Review the implementation."
-    capabilities:
-      - code-review
-    procedure: "Review the implementation against the plan."
-    output: "Approve or reject with detailed comments."
-    meta:
-      type: object
-      properties:
-        approved: { type: boolean }
-        comments: { type: string }
-      required: [approved, comments]
-conditions:
-  notApproved:
-    description: "Reviewer rejected the implementation"
-    expression: "steps[-1].output.approved = false"
-graph:
-  $START:
-    - role: "planner"
-      condition: null
-  planner:
-    - role: "developer"
-      condition: null
-  developer:
-    - role: "reviewer"
-      condition: null
-  reviewer:
-    - role: "developer"
-      condition: "notApproved"
-    - role: "$END"
-      condition: null
-```
-
-Key properties:
-
-- **`roles`** — inline role definitions; each `meta` is a JSON Schema (stored as its own CAS node on registration)
-- **`conditions`** — named JSONata expressions evaluated against the `ModeratorContext`
-- **`graph`** — `Record<Role | "$START", Transition[]>` — first matching transition wins; `condition: null` = fallback
-- **No agent binding** — agent selection is a deployment concern, configured in `config.yaml`
-- **No Zod** — all schemas are JSON Schema, validated through `@uncaged/json-cas`
+- **`workflow-protocol`** — Pure types (`WorkflowFn`, contexts, `CasStore` interface, descriptor shapes), `START` / `END`, `ok` / `err`. Depends only on peer `zod` for schema-related types in signatures.
+- **`workflow-runtime`** — Workflow author surface: `createWorkflow` from `src/create-workflow.js`, re-exports protocol types/constants used when authoring bundles.
+- **`workflow-util`** — Cross-cutting utilities: Crockford Base32, ULID, `createLogger`, `getDefaultWorkflowStorageRoot`, `getGlobalCasDir`, ref normalization; re-exports `ok`/`err` from protocol.
+- **`workflow-cas`** — Filesystem CAS (`createCasStore`), `hashString` / `hashWorkflowBundleBytes`, Merkle node serialization and helpers (`merkle.js`).
+- **`workflow-register`** — Bundle pipeline (`validateWorkflowBundle`, `extractBundleExports`, descriptor builders), registry YAML read/write, `resolveModel` / `splitProviderModelRef`.
+- **`workflow-execute`** — `executeThread`, supervisor/worker wiring (`engine/`), fork/GC/pause gate, `createExtract` + LLM extract helpers (`extract/`), `workflowAsAgent`. Imports `@uncaged/workflow-reactor` for LLM-backed extract/supervisor paths (`extract-fn.ts`, `supervisor.ts`).
+- **`workflow-reactor`** — `createLlmFn`, `createThreadReactor`, and thread tool-invocation types — consumed by `workflow-execute`.
+- **`cli-workflow`** — CLI commands and HTTP/dashboard-related wiring (`hono`, `yaml`); composes register + execute + CAS + util.
+- **`workflow-agent-*`** — Replaceable `AgentFn` implementations (Cursor / Hermes CLIs, or HTTP LLM).
+- **`workflow-util-agent`** — Shared prompt assembly and subprocess spawning for CLI agents.
+- **`workflow-template-*`** — Concrete `WorkflowDefinition` graphs + Zod role schemas + descriptor builders for publishing bundles.
+- **`workflow-dashboard`** — Standalone React UI; no published library entry matching `src/index.ts`.
 
 ## Three-phase engine loop
 
-Each `uwf thread step` runs exactly one cycle: moderator → agent → extract. The CLI orchestrates this in `packages/cli-workflow/src/commands/thread.ts` (`cmdThreadStep`).
+Each role round is implemented in `packages/workflow-runtime/src/create-workflow.ts` (`advanceOneRound`): moderator → agent → extractor, with progressive context types from `@uncaged/workflow-protocol`.
 
 ```
 ┌─→ Phase 1: MODERATOR
-│   Input:  WorkflowPayload + ModeratorContext { start, steps[] }
-│   Engine: JSONata conditions evaluated against the graph
-│   Output: next role name | $END
+│   Context: ModeratorContext { threadId, depth, start, steps }
+│   Action:  moderator(ctx) → role name | END
 │
 │   Phase 2: AGENT
-│   Input:  thread-id + role (via argv)
-│   Engine: agent-kit builds context from CAS chain, prepends
-│           output format instruction to system prompt, spawns agent
-│   Output: raw string (frontmatter markdown)
+│   Context: AgentContext = ModeratorCtx + { currentRole: { name, systemPrompt } }
+│   Action:  agent(ctx) → raw string
 │
-│   Phase 3: EXTRACT
-│   Input:  raw agent output + role's meta schema
-│   Engine: two-layer extract (frontmatter fast path → LLM fallback)
-│   Output: CasRef to structured output node
+│   Phase 3: EXTRACTOR
+│   Context: ExtractContext = AgentCtx + { agentContent }
+│   Action:  runtime.extract(schema, extractPrompt, ctx) → typed meta
 │
-│   Persist: StepNode { start, prev, role, output, detail, agent }
-│   Update:  threads.yaml head pointer
-└─────────────────────────────────────────────────────────────────┘
+│   Merge: RoleStep { role, contentHash, meta, refs, timestamp }
+│   Append to steps
+└─────────────────────────────────────────────────────┘
 ```
 
-### Context types
+### Context types (progressive)
 
 Defined in `packages/workflow-protocol/src/types.ts`:
 
 ```typescript
-type StepContext = {
-  role: string;
-  output: unknown;    // CAS node payload, expanded (not hash)
-  detail: CasRef;
-  agent: string;
-};
-
-type ModeratorContext = {
-  start: StartNodePayload;  // { workflow: CasRef, prompt: string }
-  steps: StepContext[];     // chronological, oldest first
-};
-
-type AgentContext = ModeratorContext & {
-  threadId: ThreadId;
-  role: string;
-  store: Store;
-  workflow: WorkflowPayload;
-  outputFormatInstruction: string;
+type ModeratorContext<M> = ThreadContext<M>;
+type AgentContext<M> = ModeratorContext<M> & {
+  currentRole: { name: string; systemPrompt: string };
 };
+type ExtractContext<M> = AgentContext<M> & { agentContent: string };
 ```
 
 ### Key properties
 
-- **Moderator** — pure JSONata evaluation; no LLM call, no I/O beyond CAS reads. Evaluates `workflow.graph[currentRole]` transitions in order, returns first match.
-- **Agent** — receives `AgentContext` with thread history + role system prompt + output format instruction. Raw output is frontmatter markdown.
-- **Extractor** — two-layer: tries frontmatter fast-path first (zero LLM cost), falls back to LLM extract if frontmatter is absent or invalid.
-- **Stateless** — each `uwf thread step` is an atomic, self-contained operation. No in-memory state between steps.
+- **Moderator is synchronous and pure** — no I/O, no state mutation inside `createWorkflow`’s moderator call path.
+- **Agent receives `AgentContext`** — reads `ctx.currentRole.systemPrompt`; raw output becomes `agentContent` for extract.
+- **Extractor is `WorkflowRuntime.extract`** — supplied by the engine from registry-resolved LLM config (`workflow-execute`); stores agent body in CAS and yields `contentHash` + `refs` on each step (`create-workflow.ts`).
+- **`extractPrompt` is a call parameter** on `RoleDefinition`, not implicit context state.
 
-## Agent CLI protocol
+## Agent information sources
 
-Each agent is an external command invoked by `uwf thread step`:
+An agent has exactly three information sources:
 
-```bash
-<agent-cmd> <thread-id> <role>
+1. **Prior knowledge** — LLM training, agent memory, agent skills
+2. **Thread context** — `AgentContext` (`start`, `steps`, `currentRole`)
+3. **Derived information** — from 1 & 2 (e.g. tool calls, shell commands)
+
+No hidden environment parameters. If an agent needs something (like a workspace path), it obtains it via `ExtractFn` (e.g. Cursor agent).
+
+## Bundle contract
+
+A workflow bundle is a single `.esm.js` file with two named exports (see `WorkflowFn` / `WorkflowDescriptor` in `packages/workflow-protocol/src/types.ts`):
+
+```typescript
+export const descriptor: WorkflowDescriptor;
+export const run: WorkflowFn;
+
+type WorkflowFn = (
+  thread: ThreadContext,
+  runtime: WorkflowRuntime,
+) => AsyncGenerator<RoleOutput, WorkflowCompletion>;
 ```
 
-Contract:
-1. `uwf thread step` determines the next role via the moderator
-2. Agent CLI is spawned with `(thread-id, role)` as positional args
-3. `workflow-agent-kit` (`createAgent`) handles the boilerplate:
-   - Parses argv
-   - Loads `.env` from storage root
-   - Builds `AgentContext` by walking the CAS chain from `threads.yaml` head
-   - Resolves the role's `meta` schema and builds `outputFormatInstruction`
-   - Calls the agent's `run` function
-   - Runs two-layer extract on the raw output
-   - Writes `StepNode` to CAS (output + detail + prev link)
-   - Prints the new `StepNode` CAS hash to stdout
-4. `uwf thread step` reads stdout, updates `threads.yaml` head pointer, re-evaluates moderator for `done`
-5. Exit 0 = success, non-zero = failure
+`RoleOutput` carries `contentHash`, `meta`, and `refs` (agent text lives in CAS, addressed by hash).
 
-Agent resolution priority: `--agent` CLI override → `config.yaml` per-workflow/role override → `config.yaml` `defaultAgent`.
+### Constraints
 
-## Agent output format: frontmatter markdown (RFC #351)
+- Single `.esm.js` file
+- No dynamic `import()` in bundles (loader exempt in engine)
+- Portable bundle static imports are constrained by validation in `@uncaged/workflow-register` (`validateWorkflowBundle`)
+- XXH64 hash (Crockford Base32) = version ID
 
-Agents produce **frontmatter markdown** — YAML frontmatter for structured meta, followed by a markdown body for content:
+### Why AsyncGenerator?
 
-```markdown
----
-status: done
-next: reviewer
-confidence: 0.9
-artifacts:
-  - src/auth.ts
-scope: role
----
-
-## Implementation
-
-Fixed the login redirect by updating the auth middleware...
-```
-
-The `outputFormatInstruction` (built by `buildOutputFormatInstruction` in `workflow-agent-kit`) is prepended to the role's system prompt, so the deliverable format is the first thing the agent sees. It lists the expected frontmatter fields derived from the role's `meta` JSON Schema.
-
-## Two-layer extract
-
-Structured output extraction uses a two-layer strategy (`workflow-agent-kit`):
-
-### Layer 1: frontmatter fast path (`frontmatter.ts`)
-
-1. Parse YAML frontmatter from raw agent output (`parseFrontmatterMarkdown`)
-2. Validate required fields (`validateFrontmatter`)
-3. Build a candidate object from frontmatter fields (`status`, `next`, `confidence`, `artifacts`, `scope`)
-4. `store.put()` the candidate against the role's `meta` schema
-5. Validate with `json-cas` schema validation
-6. If valid → return `outputHash` (zero LLM cost)
-
-### Layer 2: LLM extract fallback (`extract.ts`)
-
-If the fast path returns `null` (no frontmatter, invalid, or doesn't satisfy schema):
-
-1. Resolve extract model alias from config (`modelOverrides.extract` → `models.extract` → `defaultModel`)
-2. Call OpenAI-compatible chat completion with JSON mode
-3. System prompt: "Extract structured data matching this JSON Schema: ..."
-4. User message: the raw agent output
-5. Parse response, `store.put()`, validate
-6. Return `outputHash`
-
-## Prompt injection
-
-`workflow-agent-kit` prepends two pieces of context to the agent's system prompt:
-
-1. **Deliverable format instruction** — generated from the role's `meta` schema, tells the agent exactly what frontmatter fields to produce and the expected format
-2. **Scope constraint** — "Focus exclusively on YOUR role's deliverable. Do not perform actions outside your role's scope."
-
-This ensures agents produce parseable frontmatter output without requiring per-agent format knowledge.
-
-## CAS node types
-
-### Workflow
-
-```yaml
-type: <workflow-schema-hash>
-payload:
-  name: "solve-issue"
-  description: "End-to-end issue resolution"
-  roles:
-    planner:
-      description: "Creates implementation plan"
-      goal: "You are a planning agent..."
-      capabilities: [planning, issue-analysis]
-      procedure: "Analyze the issue and create a plan."
-      output: "Output the plan summary."
-      meta: "5GWKR8TN1V3JA"    # cas_ref → JSON Schema node
-  conditions:
-    notApproved:
-      description: "Reviewer rejected"
-      expression: "steps[-1].output.approved = false"
-  graph:
-    $START:
-      - role: "planner"
-        condition: null
-```
-
-### StartNode
-
-```yaml
-type: <start-node-schema-hash>
-payload:
-  workflow: "4KNM2PXR3B1QW"    # cas_ref → Workflow
-  prompt: "Fix the login bug..."
-```
-
-### StepNode
-
-```yaml
-type: <step-node-schema-hash>
-payload:
-  start: "4TNVW8KR2B3MA"      # cas_ref → StartNode
-  prev: "2MXBG6PN4A8JR"       # cas_ref → previous StepNode (null for first step)
-  role: "developer"
-  output: "9KRVW3TN5F1QA"     # cas_ref → structured output (validated against meta schema)
-  detail: "7BQST3VW9F2MA"     # cas_ref → execution detail (raw turns, session data)
-  agent: "uwf-hermes"         # agent command used (plain string)
-```
-
-### Chain structure
-
-```
-threads.yaml: { "01J7K9...4T": "8FWKR3TN5V1QA" }
-                                    │
-                                    ▼
-                            StepNode (step 3)
-                            ├── start ──→ StartNode
-                            │              ├── workflow → Workflow (CAS)
-                            │              └── prompt: "Fix..."
-                            ├── prev ──→ StepNode (step 2)
-                            │             ├── prev ──→ StepNode (step 1)
-                            │             │             └── prev: null
-                            │             └── ...
-                            ├── role: "reviewer"
-                            ├── output → CAS({ approved: true })
-                            ├── detail → CAS(session turns)
-                            └── agent: "uwf-hermes"
-```
+- Each `yield` lets `workflow-execute` persist state, CAS rows, and enforce pause/abort
+- `return` supplies `WorkflowCompletion`
+- Fork replays historical steps into a new thread context
+- Bundle does not import the engine — only protocol/runtime types at build time
 
 ## Storage layout
 
 ```
 ~/.uncaged/workflow/
-├── cas/                          # json-cas filesystem store (all CAS nodes)
-├── config.yaml                   # Provider, model, agent configuration
-├── threads.yaml                  # Active thread head pointers: threadId → CasRef
-├── history.jsonl                 # Archived thread records
-├── registry.yaml                 # Workflow name → CAS hash mapping
-└── .env                          # API keys (loaded by dotenv)
+├── cas/                           # Global content-addressed blobs (see getGlobalCasDir)
+├── bundles/
+│   ├── C9NMV6V2TQT81.esm.js       # Crockford Base32 of XXH64
+│   ├── C9NMV6V2TQT81.yaml         # Role descriptor sidecar (when present)
+│   └── C9NMV6V2TQT81/             # Per-hash bundle dir (alongside or instead of loose files)
+│       ├── threads.json           # Active threads: threadId → { head, start, updatedAt }
+│       └── history/
+│           └── 2026-05-09.jsonl   # Completed threads (one JSON object per line)
+├── logs/                          # One folder per bundle hash
+│   └── C9NMV6V2TQT81/
+│       ├── 01KQXKW…YG.running     # Present while worker executes this thread (optional)
+│       └── 01KQXKW…YG.info.jsonl   # Debug log
+└── workflow.yaml                  # Registry
 ```
 
-### Mutable state
-
-Only three files carry mutable state:
-
-| File | Contents |
-|------|----------|
-| `threads.yaml` | `Record<ThreadId, CasRef>` — maps active thread IDs to head node hash |
-| `history.jsonl` | Append-only log of completed threads (`thread`, `workflow`, `head`, `completedAt`) |
-| `registry.yaml` | Workflow name → current CAS hash |
-
-Everything else is immutable CAS content.
-
 ### ID encoding: Crockford Base32
 
 - Case-insensitive, filesystem-safe, no ambiguous chars (0/O, 1/I/L)
-- CAS hash: XXH64 → 13-char Crockford Base32
-- Thread ID: ULID → 26-char Crockford Base32 (10 timestamp + 16 random)
+- Bundle hash: XXH64 → 13-char
+- Thread ID: ULID → 26-char (10 timestamp + 16 random)
 
-### Config (`config.yaml`)
+### Registry (`workflow.yaml`)
 
-```yaml
-providers:
-  openrouter:
-    baseUrl: "https://openrouter.ai/api/v1"
-    apiKeyEnv: "OPENROUTER_API_KEY"
+Managed by `@uncaged/workflow-register` (`readWorkflowRegistry`, `writeWorkflowRegistry`, …). Shape includes workflow entries and a top-level `config` section used for extract/supervisor model resolution.
 
-models:
-  sonnet:
-    provider: "openrouter"
-    name: "anthropic/claude-sonnet-4"
-  gpt4o-mini:
-    provider: "openai"
-    name: "gpt-4o-mini"
+### Thread storage (CAS + index)
 
-agents:
-  hermes:
-    command: "uwf-hermes"
-    args: []
-  cursor:
-    command: "uwf-cursor"
-    args: []
+Thread execution state is a chain of immutable CAS nodes (`StartNode`, `StateNode`, content Merkle blobs). Per bundle:
 
-defaultAgent: "hermes"
-agentOverrides:
-  solve-issue:
-    developer: "cursor"
+- **`threads.json`** — only in-flight threads (`head`, `start`, `updatedAt`).
+- **`history/{YYYY-MM-DD}.jsonl`** — completed threads (`threadId`, `head`, `start`, `completedAt`).
+- **CAS (`cas/`)** — payloads and refs for replay, GC, and fork sharing.
 
-defaultModel: "sonnet"
-modelOverrides:
-  extract: "gpt4o-mini"
+**`.info.jsonl`** — Structured debug log via `@uncaged/workflow-util` `createLogger`:
+
+```jsonc
+{ "tag": "4KNMR2PX", "content": "Loading bundle...", "timestamp": ... }
 ```
 
+Tags are 8-char Crockford Base32 (40-bit random), one per call site. `grep "4KNMR2PX"` → code location.
+
+## Execution model
+
+- **No daemon.** `uncaged-workflow run <name>` starts a worker process (`workflow-execute` worker entry via `getWorkerHostScriptPath`)
+- Threads share bundle-scoped workers as implemented in CLI/engine
+- Pause/resume/abort via engine IPC and pause gate (`createThreadPauseGate`)
+
 ## CLI commands
 
-Binary: `uwf`
-
-### Thread commands
-
-| Command | Description |
-|---------|-------------|
-| `uwf thread start <workflow> -p <prompt>` | Create a thread (StartNode → CAS, head → threads.yaml). No execution. |
-| `uwf thread step <thread-id> [--agent <cmd>]` | Execute one moderator→agent→extract cycle. |
-| `uwf thread show <thread-id>` | Show thread head pointer and done status. |
-| `uwf thread list [--all]` | List active threads (`--all` includes archived). |
-| `uwf thread steps <thread-id>` | List all steps in chronological order. |
-| `uwf thread read <thread-id> [--quota <chars>] [--before <hash>]` | Render thread as human-readable markdown. |
-| `uwf thread fork <step-hash>` | Fork a thread from a specific CAS node. |
-| `uwf thread step-details <step-hash>` | Dump full detail node as YAML. |
-| `uwf thread kill <thread-id>` | Terminate and archive a thread. |
-
-### Workflow commands
-
-| Command | Description |
-|---------|-------------|
-| `uwf workflow put <file.yaml>` | Register a workflow from YAML definition. |
-| `uwf workflow show <id>` | Show workflow by name or CAS hash. |
-| `uwf workflow list` | List registered workflows. |
-
-### CAS commands
-
-| Command | Description |
-|---------|-------------|
-| `uwf cas get <hash>` | Read a CAS node. |
-| `uwf cas put <type-hash> <data>` | Store a node, print its hash. |
-| `uwf cas has <hash>` | Check if a hash exists. |
-| `uwf cas refs <hash>` | List direct CAS references. |
-| `uwf cas walk <hash>` | Recursive traversal from a node. |
-| `uwf cas reindex` | Rebuild type index from all nodes. |
-| `uwf cas schema list` | List registered schemas. |
-| `uwf cas schema get <hash>` | Show a schema by type hash. |
-
-### Setup
-
-| Command | Description |
-|---------|-------------|
-| `uwf setup [--provider --base-url --api-key --model --agent]` | Configure provider/model/agent (interactive if no flags). |
-
-## Toolchain
-
-| Tool | Purpose |
-|------|---------|
-| **bun** | Package manager + runtime |
-| **TypeScript** | Type checking (strict mode) |
-| **Biome** | Lint + format |
-| **vitest** | Test runner |
+| Priority | Command | Description |
+|----------|---------|-------------|
+| P1 | `add <name> <file.esm.js>` | Register a bundle |
+| P1 | `list` | List registered workflows |
+| P1 | `show <name>` | Show workflow details |
+| P1 | `remove <name>` | Remove a workflow |
+| P1 | `run <name> [--prompt] [--max-rounds]` | Start a thread |
+| P1 | `threads [name]` | List threads |
+| P1 | `thread <id>` | Show thread state |
+| P1 | `thread rm <id>` | Delete a thread |
+| P1 | `ps` | List running threads |
+| P1 | `kill <thread-id>` | Terminate a running thread |
+| P2 | `history <name>` | Show version history |
+| P2 | `rollback <name> [hash]` | Switch to a previous version |
+| P2 | `pause <thread-id>` | Pause a running thread |
+| P2 | `resume <thread-id>` | Resume a paused thread |
+| P3 | `fork <thread-id> [--from-role <role>]` | Fork from historical state |
 
 ## Design decisions
 
 | Decision | Rationale |
 |----------|-----------|
-| **YAML workflow definitions** | Human-readable, versionable, no build step required. JSON Schema inline in YAML, registered as CAS nodes on `workflow put`. |
-| **Stateless single-step CLI** | Each `uwf thread step` is atomic — no in-memory state, no daemon, no long-running process. OS handles lifecycle. |
-| **CAS-backed thread state** | Immutable linked nodes enable fork, replay, and GC without copying data. Content-addressed deduplication across threads. |
-| **JSONata moderator** | Declarative condition expressions evaluated against thread history. No LLM cost for routing decisions. |
-| **Frontmatter markdown output** | Agents produce structured meta (YAML frontmatter) alongside free-form content (markdown body). Enables zero-cost extraction when frontmatter is well-formed. |
-| **Two-layer extract** | Fast path avoids LLM calls when agents follow the format; LLM fallback handles messy output gracefully. |
-| **Prompt injection for format** | Output format instruction prepended to system prompt ensures agents produce parseable output without per-agent configuration. |
-| **JSON Schema (not Zod)** | Schemas are CAS-native data — storable, hashable, validatable through `json-cas`. No code generation, no runtime library dependency. |
-| **Agent as external command** | Agents are independent CLI binaries (`uwf-hermes`, `uwf-cursor`). Swappable per workflow/role via config. No tight coupling to the engine. |
-| **No daemon** | Process starts, does one step, exits. Simpler failure model, no connection management. |
-| **Crockford Base32** | Filesystem-safe, case-insensitive, readable, compact. |
+| **Role = pure data** | Decouples definition from execution; same role with different agents |
+| **Agent bound at runtime** | `WorkflowDefinition` is reusable; agent choice is deployment concern |
+| **Three-phase context** | Each phase sees only what it needs; types live in `workflow-protocol` |
+| **`WorkflowRuntime.extract` + CAS `contentHash`** | Large agent bodies deduplicated globally; Merkle roots summarize threads |
+| **`workflow-reactor` split** | LLM tool-calling loop isolated from filesystem/registry concerns |
+| **Single-file ESM** | Hash = version, self-contained bundle |
+| **No daemon** | OS handles process lifecycle |
+| **Crockford Base32** | Filesystem-safe, readable, compact |
+| **15-package split** | Clear boundaries: protocol ↔ runtime author API ↔ util/CAS/register ↔ execute ↔ CLI ↔ agents/templates/UI |

docs/plans/2026-05-12-react-agent.md

@@ -1,191 +0,0 @@
-# workflow-agent-react — ReAct Agent Package
-
-**Status**: RFC v3
-**Author**: 小橘 🍊
-
-## Problem
-
-现有的 agent 包都依赖外部 CLI 进程：
-
-| Package | 机制 | 能力 |
-|---------|------|------|
-| `workflow-agent-hermes` | spawn `hermes chat` | 完整工具链（文件、终端、浏览器…） |
-| `workflow-agent-cursor` | spawn `cursor-agent` | IDE 级别代码编辑 |
-| `workflow-agent-llm` | 单轮 chat completion | 纯文本，无工具 |
-
-缺少一个 **内置 ReAct agent**：用 LLM + tool calling 循环执行任务，不依赖外部 CLI，工具集由调用方注入。
-
-## 核心设计变更：AdapterFn 替代 AgentFn
-
-### 现状的问题
-
-当前 `AgentFn` 返回 `string`，engine 再用额外一轮 LLM 调用 extract meta：
-
-```
-Agent(ctx) → string → Extract(string, schema) → meta   // 浪费一轮 LLM
-```
-
-### 新抽象：AdapterFn
-
-```typescript
-type RoleFn<T> = (ctx: ThreadContext) => Promise<T>;
-
-type AdapterFn = <T>(prompt: string, schema: z.ZodType<T>) => RoleFn<T>;
-```
-
-- **`prompt`** — role 的 system prompt，描述角色职责和输出要求
-- **`schema`** — role 的 meta schema，定义输出格式
-- **`ThreadContext`** — threadId, depth, bundleHash, start, steps
-
-prompt 和 schema 是一对：prompt 说"你要输出什么"，schema 定义"输出的格式"。它们属于 role definition，由 `createWorkflow` 在每个 role 执行时传给 adapter。
-
-### AgentContext 不再需要
-
-`AgentContext` 在 `ThreadContext` 上扩展了 `currentRole: { name, systemPrompt }`。prompt 现在直接传给 adapter，`AgentContext` 可以删除。
-
-### createWorkflow 签名变更
-
-```typescript
-// Before
-type AgentBinding = {
-  agent: AgentFn;
-  overrides: Partial<Record<string, AgentFn>> | null;
-};
-
-// After
-type AdapterBinding = {
-  adapter: AdapterFn;
-  overrides: Partial<Record<string, AdapterFn>> | null;
-};
-```
-
-engine 对每个 role 的执行逻辑：
-
-```typescript
-// Before
-const result = await agent({ ...threadCtx, currentRole: { name, systemPrompt } });
-const meta = await extract(result, role.metaSchema, provider);  // 额外一轮 LLM
-
-// After
-const roleFn = adapter(role.systemPrompt, role.metaSchema);
-const meta = await roleFn(threadCtx);  // 直接拿到类型安全的 T
-```
-
-## `createReactAdapter` — 复用 workflow-reactor
-
-AdapterFn 的终止条件是"拿到符合 schema 的 T"——和 `workflow-reactor` 的 `ThreadReactorFn` 完全一致。因此 react adapter 是对 reactor 的**薄包装**，不需要自己实现 ReAct 循环。
-
-```typescript
-import { createLlmFn, createThreadReactor } from "@uncaged/workflow-reactor";
-import type { ThreadContext, LlmProvider } from "@uncaged/workflow-protocol";
-import type { ToolDefinition } from "@uncaged/workflow-reactor";
-
-type ReactToolHandler = (name: string, args: string) => Promise<string>;
-
-type ReactAdapterConfig = {
-  provider: LlmProvider;
-  tools: readonly ToolDefinition[];
-  toolHandler: ReactToolHandler;
-  maxRounds: number;
-};
-
-function createReactAdapter(config: ReactAdapterConfig): AdapterFn {
-  return <T>(prompt: string, schema: z.ZodType<T>) => {
-    const reactor = createThreadReactor<ThreadContext>({
-      llm: createLlmFn(config.provider),
-      staticTools: config.tools,
-      structuredToolFromSchema: (s) => buildStructuredTool(s),
-      systemPromptForStructuredTool: () => prompt,
-      toolHandler: (call, ctx) =>
-        config.toolHandler(call.function.name, call.function.arguments),
-      maxRounds: config.maxRounds,
-    });
-
-    return async (ctx: ThreadContext): Promise<T> => {
-      const input = buildThreadInput(ctx);
-      const result = await reactor({ thread: ctx, input, schema });
-      if (!result.ok) throw new Error(result.error);
-      return result.value;
-    };
-  };
-}
-```
-
-整个包就是：**一个工厂函数 + 类型定义 + thread 输入构造**。
-
-## `agentToAdapter` — 向后兼容
-
-把现有 `AgentFn`（hermes/cursor）包装成 `AdapterFn`：
-
-```typescript
-function agentToAdapter(agent: AgentFn, extractProvider: LlmProvider): AdapterFn {
-  return <T>(prompt: string, schema: z.ZodType<T>): RoleFn<T> => {
-    return async (ctx: ThreadContext): Promise<T> => {
-      const agentCtx = { ...ctx, currentRole: { name: "agent", systemPrompt: prompt } };
-      const result = await agent(agentCtx);
-      const output = typeof result === "string" ? result : result.output;
-      return extract(output, schema, extractProvider);
-    };
-  };
-}
-```
-
-hermes/cursor agent 内部不改，bundle-entry 层多包一层即可。
-
-## 包结构
-
-```
-packages/workflow-agent-react/
-  src/
-    types.ts                 # ReactAdapterConfig, ReactToolHandler
-    create-react-adapter.ts  # AdapterFn 工厂（包装 reactor）
-    thread-input.ts          # ThreadContext → user message string
-    index.ts
-  __tests__/
-    create-react-adapter.test.ts
-  package.json
-```
-
-依赖：
-- `@uncaged/workflow-protocol` — `ThreadContext`, `LlmProvider`
-- `@uncaged/workflow-reactor` — `createLlmFn`, `createThreadReactor`, types
-
-## 影响范围
-
-### Breaking Changes
-
-| 改动 | 影响 |
-|------|------|
-| `AgentBinding` → `AdapterBinding` | `createWorkflow` 调用方（所有 bundle-entry） |
-| `AgentContext` 删除 | `buildAgentPrompt`（util-agent）改为接收 `ThreadContext` |
-| extract 从 engine 下沉到 adapter | `workflow-execute` 简化 |
-
-### 需修改的包
-
-1. `workflow-protocol` — 删除 `AgentContext`/`AgentFn`/`AgentFnResult`/`AgentBinding`，新增 `AdapterFn`/`RoleFn`/`AdapterBinding`
-2. `workflow-runtime` — 更新 re-export
-3. `workflow-execute` — engine 调用 `adapter(prompt, schema)` 替代 `agent(ctx) + extract`
-4. `workflow-util-agent` — `buildAgentPrompt` → `buildThreadInput`，接收 `ThreadContext`
-5. 所有 bundle-entry — `agent:` → `adapter:`
-
-### 不受影响
-
-- `workflow-cas` / `workflow-register` / `workflow-reactor` / `workflow-dashboard`
-- `workflow-agent-hermes` / `workflow-agent-cursor`（内部不改，外部用 `agentToAdapter` 包装）
-
-## Phases
-
-1. **Phase 1**: protocol 类型 + `createWorkflow` 签名变更 + `agentToAdapter`
-2. **Phase 2**: `workflow-agent-react` 包（包装 reactor）
-3. **Phase 3**: 工具集实现（read/write/patch/shell） + smoke test 闭环
-
-## 工具集（后续讨论）
-
-| 工具 | 说明 | 优先级 |
-|------|------|--------|
-| `read_file` | 读文件 | P0 |
-| `write_file` | 写文件 | P0 |
-| `patch_file` | find-and-replace 编辑 | P0 |
-| `shell_exec` | 执行 shell 命令 | P0 |
-| `search_files` | grep / find | P1 |
-| `list_files` | ls | P1 |

docs/superpowers/specs/2026-05-18-office-agent-document-template.md

@@ -1,387 +0,0 @@
-# 设计文档：office-agent 文档生成/编辑 Workflow 体系
-
-**日期：** 2026-05-18
-
----
-
-## 概述
-
-在 monorepo 中新增三个包，实现通过 `office-agent` CLI 生成或编辑 Word 文档的完整 workflow 体系。
-
-| 包 | npm name | 职责 |
-|---|---|---|
-| `workflow-template-document` | `@uncaged/workflow-template-document` | 纯结构：角色定义、meta schema、调度表、descriptor |
-| `workflow-agent-office` | `@uncaged/workflow-agent-office` | writer 角色执行器：调用 `office-agent` CLI |
-| `workflow-agent-docx-diff` | `@uncaged/workflow-agent-docx-diff` | differ 角色执行器：调用 `docx-diff` CLI |
-
-Template 只定义结构，不含执行逻辑。执行器与 template 解耦。
-
----
-
-## 一、`workflow-template-document`
-
-### Thread 启动输入
-
-```typescript
-// src/types.ts
-type DocumentStartInput = {
-  prompt: string;           // 用户指令
-  inputDocx: string | null; // null = 生成模式；本机绝对路径 = 编辑模式
-};
-```
-
-start.content 为 JSON `{ prompt, inputDocx }` 或纯文本（fallback：generate 模式，整段作为 prompt）。
-
-### 角色与 Meta
-
-`WriterMeta` 使用 discriminated union，在 schema 层区分两种模式：
-
-```typescript
-const writerMetaSchema = z.discriminatedUnion("mode", [
-  z.object({
-    mode: z.literal("generate"),
-    outputDocx: z.string(),   // 生成产物绝对路径
-    sourceDocx: z.null(),
-  }),
-  z.object({
-    mode: z.literal("edit"),
-    outputDocx: z.string(),   // 修改后产物：<outputDir>/modified.docx
-    sourceDocx: z.string(),   // 原始副本：<outputDir>/original.docx
-  }),
-]);
-type WriterMeta = z.infer<typeof writerMetaSchema>;
-
-// differ：仅编辑模式执行
-const differMetaSchema = z.object({
-  sourceDocx: z.string(),
-  modifiedDocx: z.string(),
-  diffDocx: z.string(),
-});
-type DifferMeta = z.infer<typeof differMetaSchema>;
-```
-
-两个角色的 `systemPrompt` 均为 `""`。
-
-### 调度表
-
-```
-START → writer ──(mode = "edit")──→ differ → END
-               ↘(mode = "generate")→ END
-```
-
-### 公开导出
-
-template 导出两个对象供消费方使用：
-
-- `documentWorkflowDefinition: WorkflowDefinition<DocumentMeta>` — 传入 `createWorkflow` 的 `def` 参数
-- `buildDocumentDescriptor(): WorkflowDescriptor` — bundle 导出用
-
-```typescript
-// bundle 侧用法
-export const descriptor = buildDocumentDescriptor();
-export const run = createWorkflow(documentWorkflowDefinition, { adapter, overrides });
-```
-
-### 包文件结构
-
-```
-packages/workflow-template-document/
-  src/
-    types.ts           # DocumentStartInput
-    roles/
-      writer.ts        # writerMetaSchema, WriterMeta, writerRole
-      differ.ts        # differMetaSchema, DifferMeta, differRole
-      index.ts
-    roles.ts           # DocumentMeta, documentRoles
-    moderator.ts       # writerIsEditMode condition + documentTable
-    definition.ts      # documentWorkflowDefinition
-    descriptor.ts      # buildDocumentDescriptor()
-    index.ts
-  __tests__/
-    moderator.test.ts
-  package.json
-  tsconfig.json
-```
-
-### 依赖
-
-```json
-{
-  "@uncaged/workflow-protocol": "workspace:^",
-  "@uncaged/workflow-runtime": "workspace:^",
-  "@uncaged/workflow-register": "workspace:^",
-  "zod": "^4.0.0"
-}
-```
-
----
-
-## 二、`workflow-agent-office`
-
-### office-agent CLI 接口
-
-```bash
-# 生成模式：在 CWD 生成 output.docx
-office-agent create "<prompt>" -o output.docx
-
-# 编辑模式：在 CWD 对 modified.docx 进行修改（覆写）
-office-agent edit modified.docx "<instruction>"
-```
-
-- 两个命令均为阻塞调用（CLI 内部消费 SSE，退出即完成）
-- 输出文件落到调用方设定的 CWD
-- 退出码 0 = 成功，非零 = 失败
-
-### 文件命名约定
-
-| 模式 | 文件 | 路径 |
-|---|---|---|
-| generate | 输出 | `<outputDir>/output.docx` |
-| edit | 原始副本（workflow-owned 快照） | `<outputDir>/original.docx` |
-| edit | 修改后产物 | `<outputDir>/modified.docx` |
-
-edit 模式先将 `inputDocx` 复制为 `original.docx`（不可变快照），再复制为 `modified.docx`，对 `modified.docx` 调用 CLI。agent 覆写 `modified.docx`，`original.docx` 保持不变。differ 对比这两个 workflow-owned 文件，不依赖用户原始路径。
-
-### 执行流程
-
-**生成模式（`inputDocx = null`）：**
-1. `mkdir -p <outputDir>`（`<config.outputDir>/<ctx.threadId>`）
-2. `const command = config.command ?? "office-agent"`
-3. `spawnCli(command, ["create", prompt, "-o", "output.docx"], { cwd: outputDir, timeoutMs })`
-4. 验证 `outputDir/output.docx` 存在
-5. 返回 `JSON.stringify({ mode: "generate", outputDocx, sourceDocx: null })`
-
-**编辑模式（`inputDocx ≠ null`）：**
-1. `mkdir -p <outputDir>`
-2. `copyFile(inputDocx, <outputDir>/original.docx)`
-3. `copyFile(inputDocx, <outputDir>/modified.docx)`
-4. `const command = config.command ?? "office-agent"`
-5. `spawnCli(command, ["edit", "modified.docx", prompt], { cwd: outputDir, timeoutMs })`
-6. 验证 `outputDir/modified.docx` 存在
-7. 返回 `JSON.stringify({ mode: "edit", outputDocx: modifiedPath, sourceDocx: originalPath })`
-
-### AdapterFn 实现（直接实现，不经过 runtime.extract）
-
-CLI 产出确定性 JSON，直接 `schema.parse(JSON.parse(raw))` 跳过 LLM extraction：
-
-```typescript
-export function createOfficeAgent(config: OfficeAgentConfig): AdapterFn {
-  return <T>(_systemPrompt: string, schema: z.ZodType<T>) =>
-    async (ctx: ThreadContext, _runtime: WorkflowRuntime): Promise<RoleResult<T>> => {
-      const { prompt, inputDocx } = parseStartInput(ctx.start.content);
-      const raw = await runOfficeAgent(config, ctx.threadId, prompt, inputDocx);
-      const meta = schema.parse(JSON.parse(raw)) as T;
-      return { meta, childThread: null };
-    };
-}
-```
-
-`_systemPrompt` 为 writer 角色的 systemPrompt（空字符串），实际指令从 `ctx.start.content` 解析。
-
-### 配置
-
-```typescript
-type OfficeAgentConfig = {
-  outputDir: string;        // 输出根目录，runner 在此下按 threadId 建子目录
-  command: string | null;   // null → runner 内 resolve 为 "office-agent"
-  timeout: number | null;   // null → 不设超时；单位 ms
-};
-```
-
-### 错误处理
-
-```typescript
-if (!result.ok) {
-  const e = result.error;
-  if (e.kind === "non_zero_exit")
-    throw new Error(`office-agent failed (exit ${e.exitCode}): ${e.stderr}`);
-  if (e.kind === "timeout")
-    throw new Error("office-agent: timed out");
-  // "spawn_failed"
-  throw new Error(`office-agent: spawn failed: ${e.message}`);
-}
-if (!existsSync(expectedPath))
-  throw new Error(`office-agent: output file not found: ${expectedPath}`);
-```
-
-### packageDescriptor
-
-```typescript
-// src/package-descriptor.ts
-export const packageDescriptor: PackageDescriptor = {
-  name: "@uncaged/workflow-agent-office",
-  version: "0.1.0",
-  capabilities: ["office-agent-cli", "docx-generate", "docx-edit"],
-  configSchema: {
-    type: "object",
-    required: ["outputDir"],
-    properties: {
-      outputDir: { type: "string", description: "Root directory for workflow outputs." },
-      command:   { anyOf: [{ type: "string" }, { type: "null" }], description: "Path to office-agent CLI; null uses PATH." },
-      timeout:   { anyOf: [{ type: "number" }, { type: "null" }], description: "Timeout in ms; null means no limit." },
-    },
-    additionalProperties: false,
-  },
-};
-```
-
-### 包文件结构
-
-```
-packages/workflow-agent-office/
-  src/
-    types.ts                # OfficeAgentConfig, OfficeAgentOpt
-    runner.ts               # runOfficeAgent()（spawnCli 封装 + 文件验证）
-    agent.ts                # createOfficeAgent(): AdapterFn
-    package-descriptor.ts   # packageDescriptor
-    index.ts
-  __tests__/
-    runner.test.ts
-    agent.test.ts
-  package.json
-  tsconfig.json
-```
-
-### 依赖
-
-```json
-{
-  "@uncaged/workflow-protocol": "workspace:^",
-  "@uncaged/workflow-util": "workspace:^",
-  "@uncaged/workflow-util-agent": "workspace:^"
-}
-```
-
----
-
-## 三、`workflow-agent-docx-diff`
-
-`differ` 角色专用执行器。从 `ctx.steps` 读取 `WriterMeta`，调用本地 `docx-diff` CLI。
-
-### docx-diff 退出码约定
-
-| 退出码 | 含义 | runner 处理 |
-|---|---|---|
-| 0 | 无差异 | 正常，验证 diffDocx 存在 |
-| 1 | 有差异 | 正常（显式处理为成功），验证 diffDocx 存在 |
-| 2+ | 错误 | throw |
-
-runner 收到 `SpawnCliError { kind: "non_zero_exit", exitCode: 1 }` 时视为成功，验证文件后继续；`exitCode >= 2` 才 throw。
-
-### 执行流程
-
-```
-1. 从 ctx.steps 找到 writer 步骤，读取 WriterMeta
-2. 验证 mode === "edit"（否则 throw）
-3. diffDocx = join(dirname(writer.outputDocx), "diff.docx")
-4. const command = config.command ?? "docx-diff"
-5. spawnCli(command,
-     [writer.sourceDocx, writer.outputDocx, "--output", "docx", "--out-file", diffDocx],
-     { cwd: null, timeoutMs: null })
-   exit 0 或 1 → 验证 diffDocx 存在
-   exit 2+ → throw
-6. 返回 JSON.stringify({ sourceDocx, modifiedDocx: writer.outputDocx, diffDocx })
-```
-
-### AdapterFn 实现（直接实现，不经过 runtime.extract）
-
-```typescript
-export function createDocxDiffAgent(config: DocxDiffAgentConfig = { command: null }): AdapterFn {
-  return <T>(_prompt: string, schema: z.ZodType<T>) =>
-    async (ctx: ThreadContext, _runtime: WorkflowRuntime): Promise<RoleResult<T>> => {
-      const writerStep = ctx.steps.find(s => s.role === "writer");
-      if (!writerStep) throw new Error("differ: no writer step found");
-      const writerMeta = writerStep.meta as WriterMeta;
-      if (writerMeta.mode !== "edit")
-        throw new Error("differ: writer did not run in edit mode");
-      const raw = await runDocxDiff(config, writerMeta);
-      const meta = schema.parse(JSON.parse(raw)) as T;
-      return { meta, childThread: null };
-    };
-}
-```
-
-### 配置
-
-```typescript
-type DocxDiffAgentConfig = {
-  command: string | null;   // null → runner 内 resolve 为 "docx-diff"
-};
-```
-
-### packageDescriptor
-
-```typescript
-export const packageDescriptor: PackageDescriptor = {
-  name: "@uncaged/workflow-agent-docx-diff",
-  version: "0.1.0",
-  capabilities: ["docx-diff-cli", "docx-diff-report"],
-  configSchema: {
-    type: "object",
-    properties: {
-      command: { anyOf: [{ type: "string" }, { type: "null" }], description: "Path to docx-diff CLI; null uses PATH." },
-    },
-    additionalProperties: false,
-  },
-};
-```
-
-### 包文件结构
-
-```
-packages/workflow-agent-docx-diff/
-  src/
-    types.ts                # DocxDiffAgentConfig
-    runner.ts               # runDocxDiff()（exit 1 处理 + 文件验证）
-    agent.ts                # createDocxDiffAgent(): AdapterFn
-    package-descriptor.ts   # packageDescriptor
-    index.ts
-  __tests__/
-    runner.test.ts
-    agent.test.ts
-  package.json
-  tsconfig.json
-```
-
-### 依赖
-
-```json
-{
-  "@uncaged/workflow-protocol": "workspace:^",
-  "@uncaged/workflow-util-agent": "workspace:^",
-  "@uncaged/workflow-template-document": "workspace:^"
-}
-```
-
----
-
-## 四、外部 bundle（外部 workspace 消费）
-
-```typescript
-import { createOfficeAgent } from "@uncaged/workflow-agent-office";
-import { createDocxDiffAgent } from "@uncaged/workflow-agent-docx-diff";
-import {
-  buildDocumentDescriptor,
-  documentWorkflowDefinition,
-} from "@uncaged/workflow-template-document";
-import { createWorkflow } from "@uncaged/workflow-runtime";
-import { getDefaultWorkflowStorageRoot } from "@uncaged/workflow-util";
-import { join } from "node:path";
-
-const outputDir = join(getDefaultWorkflowStorageRoot(), "outputs");
-
-export const descriptor = buildDocumentDescriptor();
-export const run = createWorkflow(documentWorkflowDefinition, {
-  adapter: createOfficeAgent({ outputDir, command: null, timeout: null }),
-  overrides: { differ: createDocxDiffAgent() },
-});
-```
-
----
-
-## 不在范围内
-
-- 重试逻辑（失败直接 throw）
-- office-agent server 的启停管理（假设 server 已在运行）
-- docx-diff HTML/terminal 格式输出（仅 docx）
-- 跨机器执行（`inputDocx` 须为本机有效绝对路径）

docs/wf-stateless-design.md

@@ -1,539 +0,0 @@
-# `uwf` — Stateless Workflow CLI
-
-> 将 workflow 引擎降维为无状态单步 CLI。Workflow 是纯数据（CAS 节点），执行是单步原子操作，agent 是可插拔外部命令。
-
----
-
-## 1. CLI Design
-
-### 1.1 命令总览
-
-```
-# thread 组
-uwf thread start <workflow> -p <prompt>     # 创建 thread，不执行
-uwf thread step  <thread-id> [--agent]      # 单步执行
-uwf thread show  <thread-id>                # thread-id → head 查询
-uwf thread list  [--all]                    # 列出活跃 threads（--all 含已归档）
-uwf thread kill  <thread-id>                # 终结 thread，归档
-
-# workflow 组
-uwf workflow put   <file.yaml>              # 注册 workflow（YAML → CAS）
-uwf workflow show  <workflow-id>            # 查看 workflow 定义
-uwf workflow list                           # 列出已注册 workflows
-```
-
-两组对称，各 3-4 个子命令。CAS 操作交给 `json-cas` CLI，不在 `uwf` 中重复。
-
-### 1.2 `uwf thread start`
-
-```bash
-uwf thread start <workflow> -p "Fix the login bug described in issue #42"
-```
-
-- `<workflow>` — workflow 名或 CAS hash
-- `-p` — 用户 prompt（必填）
-
-**输出（JSON to stdout）：**
-
-```jsonc
-{
-  "workflow": "4KNM2PXR3B1QW",   // workflow CAS hash (XXH64, 13-char Crockford Base32)
-  "thread": "01J7K9M2XNPQR5VWBCDF8G3H4T"      // ULID
-}
-```
-
-**做的事：**
-1. 解析 workflow（名字查 registry → CAS hash）
-2. 生成 thread ULID
-3. 写 StartNode 到 CAS
-4. 在 threads.yaml 中记录链头 → StartNode hash
-5. 输出 JSON
-
-### 1.3 `uwf thread step`
-
-```bash
-uwf thread step 01J7K9M2XNPQR5VWBCDF8G3H4T
-uwf thread step 01J7K9M2XNPQR5VWBCDF8G3H4T --agent "bunx uwf-cursor"
-```
-
-**输出（JSON to stdout）：**
-
-```jsonc
-{
-  "workflow": "4KNM2PXR3B1QW",
-  "thread": "01J7K9M2XNPQR5VWBCDF8G3H4T",
-  "head": "8FWKR3TN5V1QA",       // 新链头 StepNode 的 CAS hash
-  "done": false                    // true = moderator 返回 END，thread 已归档
-}
-```
-
-`done: true` 时 head 仍然有值（最后一个 StepNode），但 thread 已从 threads.yaml 移除。
-对已结束或不存在的 thread 调用 step 会报错（非 active thread）。
-
-详细信息通过 `uwf thread show <thread-id>` 或 `json-cas get <head>` 查看。
-
-**做的事：**
-1. 读链头 → 当前 StepNode（或 StartNode）
-2. 收集 thread 历史（遍历链）
-3. 调 moderator：评估 JSONata conditions → 得到下一个 role（或 END）
-4. 若 END → 归档 thread，输出最后链头，退出
-5. 确定 agent command（`--agent` override > config.yaml per-workflow/role > config.yaml defaultAgent）
-6. 调用：`<agent-cmd> <thread-id> <role>`，捕获 stdout 得到新 StepNode hash
-7. 更新链头指针
-8. 再次调 moderator（基于新 StepNode）判断 done
-9. 输出 JSON
-
-### 1.4 `uwf thread show`
-
-```bash
-uwf thread show 01J7K9M2XNPQR5VWBCDF8G3H4T
-```
-
-**输出（JSON to stdout）：**
-
-```jsonc
-{
-  "workflow": "4KNM2PXR3B1QW",
-  "thread": "01J7K9M2XNPQR5VWBCDF8G3H4T",
-  "head": "8FWKR3TN5V1QA",
-  "done": false
-}
-```
-
-纯 thread-id → head 查询。详细内容用 `json-cas get <head>` 或 `json-cas walk <head>` 查看。
-
-### 1.5 Agent CLI 协议
-
-每个 agent 是一个命令，接受 thread-id 和 role 两个参数：
-
-```bash
-uwf-hermes <thread-id> <role>
-```
-
-**约定：**
-- `uwf step` 负责 moderator 决策，将 role 传给 agent CLI
-- agent-kit 根据 thread + role 从 CAS 读 goal / capabilities / procedure / output / meta
-- agent-kit 组装完整 prompt（role goal/capabilities/procedure/output + thread context + user prompt from StartNode）
-- agent 执行实际逻辑，agent-kit 负责 extract
-- agent 将 StepNode 写入 CAS（含 output、detail、agent、prev），但**不挪链头指针**
-- stdout 输出新 StepNode 的 CAS hash（纯文本，一行）
-- 所有配置从环境变量读（LLM model、API key、extractor config）
-- exit 0 = 成功，非 0 = 失败
-
-**stdout 输出：**
-
-```
-8FWKR3TN5V1QA
-```
-
-`uwf step` 拿到这个 hash 后更新链头指针、判断 done。
-
----
-
-## 2. CAS 结构定义
-
-### 2.1 类型层级
-
-沿用 json-cas 的三层：bootstrap meta-schema → JSON Schema nodes → data nodes。
-
-下面所有 CAS 节点都遵循 `{ type: cas_ref, payload: T, timestamp: number }` 的标准格式。
-`cas_ref` 类型的字符串字段在 json-cas 中已内置支持，不需要额外的 `$ref` 包装。
-
-### 2.2 数据节点
-
-#### `Workflow`
-
-Roles 和 moderator 内联在 Workflow 中，只有 meta 独立为 CAS 节点（方便 json-cas 校验）。
-
-```yaml
-type: <workflow-schema-hash>
-payload:
-  name: "solve-issue"
-  description: "End-to-end issue resolution"
-  roles:
-    planner:
-      description: "Creates implementation plan"
-      goal: "You are a planning agent..."
-      capabilities: [planning, issue-analysis]
-      procedure: "Analyze the issue and create a plan."
-      output: "Output the plan summary."
-      meta: "5GWKR8TN1V3JA"    # cas_ref → JSON Schema 节点（json-cas 内置）
-    developer:
-      description: "Implements code changes"
-      goal: "You are a developer agent..."
-      capabilities: [file-edit, shell]
-      procedure: "Implement the plan."
-      output: "List all files changed."
-      meta: "8CNWT4KR6D1HV"    # cas_ref → JSON Schema 节点
-    reviewer:
-      description: "Reviews code changes"
-      goal: "You are a code reviewer..."
-      capabilities: [code-review]
-      procedure: "Review the implementation."
-      output: "Approve or reject with comments."
-      meta: "1VPBG9SM5E7WK"    # cas_ref → JSON Schema 节点
-  conditions:
-    needsClarification:
-      description: "Planner requests clarification from user"
-      expression: "$exists(steps[-1].output.needsClarification)"
-    notApproved:
-      description: "Reviewer rejected the implementation"
-      expression: "steps[-1].output.approved = false"
-  graph:
-    $START:
-      - role: "planner"
-        condition: null                  # 无条件（fallback）
-    planner:
-      - role: "developer"
-        condition: "needsClarification"
-      - role: "$END"
-        condition: null
-    developer:
-      - role: "reviewer"
-        condition: null
-    reviewer:
-      - role: "developer"
-        condition: "notApproved"
-      - role: "$END"
-        condition: null
-```
-
-- `roles` — 内联定义，每个 role 的 `meta` 是独立的 cas_ref（指向 json-cas 内置 JSON Schema 节点）
-- `conditions` — `Record<Name, JSONata>`，命名条件，方便画图描述
-- `graph` — `Record<Role | "$START", Transition[]>`，每个 Transition = `{ role, condition }`
-- `condition` 引用 conditions 中的 key，`null` = fallback
-- 按数组顺序求值，第一个匹配的 transition 胜出
-- 不含 agent binding — agent 配置在 `~/.uncaged/workflow/config.yaml` 中管理
-
-JSONata 表达式的求值上下文：
-
-```jsonc
-{
-  "start": {                          // StartNode 信息
-    "workflow": "4KNM2PXR3B1QW",
-    "prompt": "Fix the login bug..."
-  },
-  "steps": [                          // 所有已完成 steps，从旧到新
-    { "role": "planner", "output": { "phases": [...] }, "detail": "7BQST3VW9F2MA", "agent": "uwf-hermes" },
-    { "role": "developer", "output": { "filesChanged": ["src/auth.ts"], "summary": "Fixed redirect" }, "detail": "9KRVW3TN5F1QA", "agent": "uwf-cursor" },
-    { "role": "reviewer", "output": { "approved": false }, "detail": "2MXBG6PN4A8JR", "agent": "uwf-hermes" }
-  ]
-}
-```
-
-注：`output` 在上下文中会被自动展开为实际的 CAS 节点内容（而非 hash），方便 JSONata 表达式直接访问字段。
-
-#### `StartNode`（Thread 起点）
-
-```yaml
-type: <start-node-schema-hash>
-payload:
-  workflow: "4KNM2PXR3B1QW"        # cas_ref → Workflow
-  prompt: "Fix the login bug..."
-```
-
-- 没有 thread-id — thread-id 是索引层面的事，不进 CAS 内容
-- 没有 agent binding — 运行时从 config.yaml 解析
-
-#### `StepNode`（Thread 每一步）
-
-```yaml
-type: <step-node-schema-hash>
-payload:
-  start: "4TNVW8KR2B3MA"          # cas_ref → StartNode（每个 step 都引用）
-  prev: "2MXBG6PN4A8JR"           # cas_ref → 前一个 StepNode，第一步为 null
-  role: "developer"
-  output: "9KRVW3TN5F1QA"         # cas_ref → 结构化输出节点（符合 role 的 meta schema）
-  detail: "7BQST3VW9F2MA"         # cas_ref → 执行详情（content node / 子 workflow terminal StepNode / ...）
-  agent: "uwf-cursor"              # 实际使用的 agent 命令（纯字符串）
-```
-
-- `start` — 每个 StepNode 都直接引用 StartNode，方便随机访问
-- `prev` — 前一个 StepNode 的 cas_ref，第一步为 `null`（不指向 StartNode）
-- `output` — cas_ref，指向符合 role meta schema 的 CAS 节点，可用 json-cas 校验
-- `detail` — cas_ref，指向执行详情。可以是原始 agent 输出（content node），也可以是子 workflow thread 的 terminal StepNode（workflowAsAgent 场景）
-- `agent` — 纯字符串，不是 CAS 节点
-
-### 2.3 链式结构
-
-```
-threads.yaml: { "01J7K9M2XNPQR5VWBCDF8G3H4T": "8FWKR3TN5V1QA" }
-                                      │
-                                      ▼
-                              StepNode (step 3)
-                              ├── start ──→ StartNode
-                              │              ├── workflow → CAS(Workflow)
-                              │              └── prompt: "Fix..."
-                              ├── prev ──→ StepNode (step 2)
-                              │             ├── start ──→ (same StartNode)
-                              │             ├── prev ──→ StepNode (step 1)
-                              │             │             ├── start ──→ (same StartNode)
-                              │             │             ├── prev: null
-                              │             │             ├── role: "planner"
-                              │             │             └── ...
-                              │             ├── role: "developer"
-                              │             └── ...
-                              ├── role: "reviewer"
-                              ├── output → CAS({ approved: true })
-                              ├── detail → CAS(raw output | sub-workflow terminal node)
-                              └── agent: "uwf-hermes"
-```
-
-### 2.4 可变状态
-
-系统两个顶层 YAML 文件和一个 env 文件：
-
-```yaml
-# ~/.uncaged/workflow/config.yaml — 全局配置
-providers:
-  openai:
-    baseUrl: "https://api.openai.com/v1"
-    apiKeyEnv: "OPENAI_API_KEY"
-  anthropic:
-    baseUrl: "https://api.anthropic.com/v1"
-    apiKeyEnv: "ANTHROPIC_API_KEY"
-  openrouter:
-    baseUrl: "https://openrouter.ai/api/v1"
-    apiKeyEnv: "OPENROUTER_API_KEY"
-
-models:
-  sonnet:
-    provider: "openrouter"
-    name: "anthropic/claude-sonnet-4"
-  gpt4o-mini:
-    provider: "openai"
-    name: "gpt-4o-mini"
-
-agents:
-  hermes:
-    command: "uwf-hermes"
-    args: []
-  cursor:
-    command: "uwf-cursor"
-    args: []
-
-defaultAgent: "hermes"
-agentOverrides:
-  solve-issue:
-    developer: "cursor"
-
-defaultModel: "sonnet"
-modelOverrides:
-  extract: "gpt4o-mini"
-```
-
-```yaml
-# ~/.uncaged/workflow/threads.yaml — active thread 链头指针
-01J7K9M2XNPQR5VWBCDF8G3H4T: "8FWKR3TN5V1QA"
-01J8AB3QRMSTV6WKXZ2C4DF7GN: "3CNWT9KR6D2HV"
-```
-
-Thread 结束时从 threads.yaml 移除。可选：追加到 `history.jsonl` 做归档。
-
-```bash
-# ~/.uncaged/workflow/.env — 敏感信息（API keys）
-OPENAI_API_KEY=sk-...
-ANTHROPIC_API_KEY=sk-ant-...
-OPENROUTER_API_KEY=sk-or-...
-```
-
-- `config.yaml` — 非敏感配置（agent 命令、model 名、provider 名）
-- `.env` — 敏感信息（API keys），agent-kit 启动时自动加载
-- `threads.yaml` — 运行时状态
-
----
-
-## 3. 包结构
-
-全新包，不复用现有 packages，避免命名冲突。CAS 直接依赖 `@uncaged/json-cas`。
-
-```
-packages/
-├── cli-workflow/              # @uncaged/cli-workflow — uwf CLI（thread/workflow 命令）
-├── workflow-moderator/        # @uncaged/workflow-moderator — JSONata moderator 引擎
-├── workflow-agent-kit/        # @uncaged/workflow-agent-kit — Agent CLI 框架（含 extractor）
-├── workflow-agent-hermes/     # @uncaged/workflow-agent-hermes — uwf-hermes CLI
-├── workflow-agent-cursor/ # @uncaged/workflow-agent-cursor — uwf-cursor CLI
-└── workflow-protocol/         # @uncaged/workflow-protocol — 共享类型定义
-```
-
-**外部依赖：**
-- `@uncaged/json-cas` — CAS 存储、hash、schema 校验
-- `@uncaged/json-cas-fs` — 文件系统 CAS 后端
-
-**现有包全部保留不动**，新旧并存，逐步迁移。
-
----
-
-## 4. 关键数据类型
-
-JSONata 求值上下文本质上是 thread 链表的线性化表达。StepNode payload 和上下文中的 step 共享大量字段，提取为公共类型。
-
-### 4.1 公共类型
-
-```typescript
-/** CAS hash — XXH64, 13-char Crockford Base32 */
-type CasRef = string;
-
-/** Thread ID — ULID, 26-char Crockford Base32 */
-type ThreadId = string;
-
-/** 一个 step 的核心数据，被 StepNode payload 和 JSONata 上下文共享 */
-type StepRecord = {
-  role: string;
-  output: CasRef;                    // cas_ref → 结构化输出节点（符合 role meta schema）
-  detail: CasRef;                    // cas_ref → 执行详情（content node / 子 workflow terminal StepNode）
-  agent: string;                     // 实际使用的 agent 命令（纯字符串）
-};
-```
-
-### 4.2 Workflow 定义
-
-```typescript
-type RoleDefinition = {
-  description: string;
-  goal: string;
-  capabilities: string[];
-  procedure: string;
-  output: string;
-  meta: CasRef;                      // cas_ref → json-cas 内置 JSON Schema 节点
-};
-
-type Transition = {
-  role: string;                      // 目标 role 名 或 "$END"
-  condition: string | null;          // 引用 conditions 中的 key，null = fallback
-};
-
-type ConditionDefinition = {
-  description: string;
-  expression: string;                           // JSONata expression
-};
-
-type WorkflowPayload = {
-  name: string;
-  description: string;
-  roles: Record<string, RoleDefinition>;
-  conditions: Record<string, ConditionDefinition>;
-  graph: Record<string, Transition[]>;          // Record<Role | "$START", Transition[]>
-};
-```
-
-### 4.3 Thread 节点
-
-```typescript
-type StartNodePayload = {
-  workflow: CasRef;                  // cas_ref → Workflow
-  prompt: string;
-};
-
-type StepNodePayload = StepRecord & {
-  start: CasRef;                     // cas_ref → StartNode（每个 step 都引用）
-  prev: CasRef | null;               // cas_ref → 前一个 StepNode，第一步为 null
-};
-```
-
-### 4.4 JSONata 求值上下文
-
-Thread 链表的线性化。`steps[n]` 的字段和 `StepRecord` 一致，但 `output` 被展开为实际内容。
-
-```typescript
-/** JSONata 上下文中的 step — output 被展开 */
-type StepContext = Omit<StepRecord, "output"> & {
-  output: unknown;                   // 展开后的 CAS 节点内容，非 hash
-};
-
-type ModeratorContext = {
-  start: StartNodePayload;
-  steps: StepContext[];              // 从旧到新
-};
-```
-
-### 4.5 CLI 输出
-
-```typescript
-/** uwf thread start */
-type StartOutput = {
-  workflow: CasRef;
-  thread: ThreadId;
-};
-
-/** uwf thread step / uwf thread show */
-type StepOutput = {
-  workflow: CasRef;
-  thread: ThreadId;
-  head: CasRef;
-  done: boolean;
-};
-
-/** uwf thread list */
-type ThreadListItem = {
-  thread: ThreadId;
-  workflow: CasRef;
-  head: CasRef;
-};
-```
-
-### 4.6 配置
-
-```typescript
-/** Alias types for config references */
-type AgentAlias = string;
-type ModelAlias = string;
-type ProviderAlias = string;
-type WorkflowName = string;
-type RoleName = string;
-type Scenario = string;              // e.g. "extract"
-
-type ProviderConfig = {
-  baseUrl: string;
-  apiKeyEnv: string;                 // env var name to read API key from
-};
-
-type ModelConfig = {
-  provider: ProviderAlias;
-  name: string;                      // e.g. "anthropic/claude-sonnet-4", "gpt-4o-mini"
-};
-
-type AgentConfig = {
-  command: string;
-  args: string[];
-};
-
-/** ~/.uncaged/workflow/config.yaml */
-type WorkflowConfig = {
-  providers: Record<ProviderAlias, ProviderConfig>;
-  models: Record<ModelAlias, ModelConfig>;
-  agents: Record<AgentAlias, AgentConfig>;
-  defaultAgent: AgentAlias;
-  agentOverrides: Record<WorkflowName, Record<RoleName, AgentAlias>> | null;
-  defaultModel: ModelAlias;
-  modelOverrides: Record<Scenario, ModelAlias> | null;
-};
-
-/** ~/.uncaged/workflow/threads.yaml */
-type ThreadsIndex = Record<ThreadId, CasRef>;
-//                         ^ thread-id  ^ head StepNode/StartNode hash
-```
-
-### 4.7 类型关系图
-
-```
-WorkflowConfig (config.yaml)
-ThreadsIndex (threads.yaml)          ← 唯二可变状态
-    │
-    │ thread-id → head hash
-    ▼
-StepNodePayload ──extends──→ StepRecord ←──maps to──→ StepContext
-    │                           │                          │
-    ├── start → StartNodePayload│                          │ (output 展开)
-    ├── prev → StepNodePayload  │                          │
-    │                           ├── role                   ├── role
-    │                           ├── output (CasRef)        ├── output (展开)
-    │                           ├── detail (CasRef)        ├── detail (CasRef)
-    │                           └── agent (string)         └── agent (string)
-    │
-    └── start.workflow → WorkflowPayload
-                             ├── roles: Record<name, RoleDefinition>
-                             ├── conditions: Record<name, JSONata>
-                             └── graph: Record<role, Transition[]>
-```

examples/analyze-topic.yaml

@@ -1,43 +0,0 @@
-name: "analyze-topic"
-description: "Single-role topic analysis using four-phase role description"
-roles:
-  analyst:
-    description: "Analyzes a given topic and produces a structured summary"
-    goal: |
-      You are a research analyst with expertise in breaking down complex topics
-      into clear, structured summaries. You think critically and cite key points.
-    capabilities:
-      - research
-      - critical-thinking
-      - structured-writing
-    procedure: |
-      Analyze the topic by:
-      1. Identifying the main thesis or question
-      2. Listing 3-5 key points with brief explanations
-      3. Noting any counterarguments or caveats
-      Keep your analysis concise (under 500 words).
-    output: |
-      Provide your analysis as markdown under the frontmatter.
-      The frontmatter must include your structured findings.
-    frontmatter:
-      type: object
-      properties:
-        thesis:
-          type: string
-        keyPoints:
-          type: array
-          items:
-            type: string
-        caveats:
-          type: string
-      required: [thesis, keyPoints]
-conditions: {}
-graph:
-  $START:
-    - role: "analyst"
-      condition: null
-      prompt: "Analyze the topic in the task and produce a structured summary with key points."
-  analyst:
-    - role: "$END"
-      condition: null
-      prompt: "Analysis complete. Finish the workflow."

examples/solve-issue.yaml

@@ -1,80 +0,0 @@
-name: "solve-issue"
-description: "End-to-end issue resolution"
-roles:
-  planner:
-    description: "Creates implementation plan"
-    goal: "You are a planning agent. You analyze issues and create step-by-step plans."
-    capabilities:
-      - issue-analysis
-      - planning
-    procedure: "Analyze the issue and create a detailed, actionable implementation plan."
-    output: "Output the plan summary and list of concrete steps."
-    frontmatter:
-      type: object
-      properties:
-        plan:
-          type: string
-        steps:
-          type: array
-          items:
-            type: string
-      required: [plan, steps]
-  developer:
-    description: "Implements code changes"
-    goal: "You are a developer agent. You implement code changes according to plans."
-    capabilities:
-      - file-edit
-      - shell
-      - testing
-    procedure: "Implement the plan. Write code, tests, and ensure existing tests pass."
-    output: "List all files changed and provide a summary of the implementation."
-    frontmatter:
-      type: object
-      properties:
-        filesChanged:
-          type: array
-          items:
-            type: string
-        summary:
-          type: string
-      required: [filesChanged, summary]
-  reviewer:
-    description: "Reviews code changes"
-    goal: "You are a code reviewer. You review implementations for correctness and quality."
-    capabilities:
-      - code-review
-      - static-analysis
-    procedure: "Review the implementation against the plan. Check for bugs, edge cases, and style."
-    output: "Approve or reject with detailed comments explaining your decision."
-    frontmatter:
-      type: object
-      properties:
-        approved:
-          type: boolean
-        comments:
-          type: string
-      required: [approved, comments]
-conditions:
-  notApproved:
-    description: "Reviewer rejected the implementation"
-    expression: "$last('reviewer').approved = false"
-graph:
-  $START:
-    - role: "planner"
-      condition: null
-      prompt: "Analyze the issue described in the task and produce a detailed implementation plan."
-  planner:
-    - role: "developer"
-      condition: null
-      prompt: "Implement the plan from the planner. Write code, tests, and ensure existing tests pass."
-  developer:
-    - role: "reviewer"
-      condition: null
-      prompt: "Review the developer's implementation against the plan for correctness and quality."
-  reviewer:
-    - role: "developer"
-      condition: "notApproved"
-      prompt: "The reviewer rejected your implementation. Read their feedback and fix the issues."
-    - role: "$END"
-      condition: null
-      prompt: "The review passed. Complete the workflow."

legacy-packages/cli-workflow/CHANGELOG.md

@@ -1,138 +0,0 @@
-# @uncaged/cli-workflow
-
-## 0.5.0-alpha.4
-
-### Patch Changes
-
-- Updated dependencies
-- Updated dependencies [f74b482]
-- Updated dependencies [f74b482]
-  - @uncaged/workflow-util@0.5.0-alpha.4
-  - @uncaged/workflow-protocol@0.5.0-alpha.4
-  - @uncaged/workflow-cas@0.5.0-alpha.4
-  - @uncaged/workflow-execute@0.5.0-alpha.4
-  - @uncaged/workflow-gateway@0.5.0-alpha.4
-  - @uncaged/workflow-register@0.5.0-alpha.4
-  - @uncaged/workflow-runtime@0.5.0-alpha.4
-
-## 0.5.0-alpha.3
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.3
-  - @uncaged/workflow-cas@0.5.0-alpha.3
-  - @uncaged/workflow-execute@0.5.0-alpha.3
-  - @uncaged/workflow-gateway@0.5.0-alpha.3
-  - @uncaged/workflow-register@0.5.0-alpha.3
-  - @uncaged/workflow-runtime@0.5.0-alpha.3
-  - @uncaged/workflow-util@0.5.0-alpha.3
-
-## 0.5.0-alpha.2
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.2
-  - @uncaged/workflow-cas@0.5.0-alpha.2
-  - @uncaged/workflow-execute@0.5.0-alpha.2
-  - @uncaged/workflow-gateway@0.5.0-alpha.2
-  - @uncaged/workflow-register@0.5.0-alpha.2
-  - @uncaged/workflow-runtime@0.5.0-alpha.2
-  - @uncaged/workflow-util@0.5.0-alpha.2
-
-## 0.5.0-alpha.1
-
-### Patch Changes
-
-- @uncaged/workflow-cas@0.5.0-alpha.1
-- @uncaged/workflow-execute@0.5.0-alpha.1
-- @uncaged/workflow-gateway@0.5.0-alpha.1
-- @uncaged/workflow-protocol@0.5.0-alpha.1
-- @uncaged/workflow-register@0.5.0-alpha.1
-- @uncaged/workflow-runtime@0.5.0-alpha.1
-- @uncaged/workflow-util@0.5.0-alpha.1
-
-## 0.5.0-alpha.0
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.0
-  - @uncaged/workflow-cas@0.5.0-alpha.0
-  - @uncaged/workflow-execute@0.5.0-alpha.0
-  - @uncaged/workflow-register@0.5.0-alpha.0
-  - @uncaged/workflow-runtime@0.5.0-alpha.0
-  - @uncaged/workflow-util@0.5.0-alpha.0
-  - @uncaged/workflow-gateway@0.5.0-alpha.0
-
-## 0.4.5
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.5
-  - @uncaged/workflow-cas@0.4.5
-  - @uncaged/workflow-execute@0.4.5
-  - @uncaged/workflow-gateway@0.4.5
-  - @uncaged/workflow-register@0.4.5
-  - @uncaged/workflow-runtime@0.4.5
-  - @uncaged/workflow-util@0.4.5
-
-## 0.4.4
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.4
-  - @uncaged/workflow-cas@0.4.4
-  - @uncaged/workflow-execute@0.4.4
-  - @uncaged/workflow-gateway@0.4.4
-  - @uncaged/workflow-register@0.4.4
-  - @uncaged/workflow-runtime@0.4.4
-  - @uncaged/workflow-util@0.4.4
-
-## 0.4.3
-
-### Patch Changes
-
-- Include src/ in published packages so bun runtime can resolve the 'bun' exports condition.
-- Updated dependencies
-  - @uncaged/workflow-cas@0.4.3
-  - @uncaged/workflow-execute@0.4.3
-  - @uncaged/workflow-gateway@0.4.3
-  - @uncaged/workflow-protocol@0.4.3
-  - @uncaged/workflow-register@0.4.3
-  - @uncaged/workflow-runtime@0.4.3
-  - @uncaged/workflow-util@0.4.3
-
-## 0.4.2
-
-### Patch Changes
-
-- Fix workspace dependency resolution: use workspace:^ so published packages resolve to compatible versions instead of exact (non-existent) versions.
-- Updated dependencies
-  - @uncaged/workflow-cas@0.4.2
-  - @uncaged/workflow-execute@0.4.2
-  - @uncaged/workflow-gateway@0.4.2
-  - @uncaged/workflow-protocol@0.4.2
-  - @uncaged/workflow-register@0.4.2
-  - @uncaged/workflow-runtime@0.4.2
-  - @uncaged/workflow-util@0.4.2
-
-## 0.4.0
-
-### Minor Changes
-
-- Fix package exports for published packages and adopt changesets for version management.
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-cas@0.4.0
-  - @uncaged/workflow-execute@0.4.0
-  - @uncaged/workflow-gateway@0.4.0
-  - @uncaged/workflow-protocol@0.4.0
-  - @uncaged/workflow-register@0.4.0
-  - @uncaged/workflow-runtime@0.4.0
-  - @uncaged/workflow-util@0.4.0

legacy-packages/cli-workflow/__tests__/setup-cli.test.ts

@@ -1,131 +0,0 @@
-import { afterEach, beforeEach, describe, expect, test } from "bun:test";
-import { mkdir, mkdtemp, readFile, rm, writeFile } from "node:fs/promises";
-import { tmpdir } from "node:os";
-import { join } from "node:path";
-import { readWorkflowRegistry } from "@uncaged/workflow-register";
-
-import { runCli } from "../src/cli-dispatch.js";
-import { cmdSetup } from "../src/commands/setup/index.js";
-
-describe("setup command (CLI mode)", () => {
-  let prevEnv: string | undefined;
-  let storageRoot: string;
-
-  beforeEach(async () => {
-    prevEnv = process.env.UNCAGED_WORKFLOW_STORAGE_ROOT;
-    storageRoot = await mkdtemp(join(tmpdir(), "uncaged-setup-"));
-    process.env.UNCAGED_WORKFLOW_STORAGE_ROOT = storageRoot;
-    await mkdir(storageRoot, { recursive: true });
-  });
-
-  afterEach(async () => {
-    if (prevEnv === undefined) {
-      delete process.env.UNCAGED_WORKFLOW_STORAGE_ROOT;
-    } else {
-      process.env.UNCAGED_WORKFLOW_STORAGE_ROOT = prevEnv;
-    }
-    await rm(storageRoot, { recursive: true, force: true });
-  });
-
-  test("writes workflow.yaml with provider, models.default, and depth defaults", async () => {
-    const r = await cmdSetup(storageRoot, {
-      provider: "dashscope",
-      baseUrl: "https://dashscope.aliyuncs.com/compatible-mode/v1",
-      apiKey: "sk-test123",
-      defaultModel: "dashscope/qwen-plus",
-      initWorkspaceName: null,
-    });
-    expect(r.ok).toBe(true);
-    if (!r.ok) {
-      return;
-    }
-
-    const reg = await readWorkflowRegistry(storageRoot);
-    expect(reg.ok).toBe(true);
-    if (!reg.ok) {
-      return;
-    }
-    expect(reg.value.config).not.toBeNull();
-    if (reg.value.config === null) {
-      return;
-    }
-    expect(reg.value.config.providers.dashscope).toEqual({
-      baseUrl: "https://dashscope.aliyuncs.com/compatible-mode/v1",
-      apiKey: "sk-test123",
-    });
-    expect(reg.value.config.models.default).toBe("dashscope/qwen-plus");
-    expect(reg.value.config.maxDepth).toBe(3);
-    expect(reg.value.config.supervisorInterval).toBe(3);
-
-    const raw = await readFile(join(storageRoot, "workflow.yaml"), "utf8");
-    expect(raw).toContain("dashscope");
-    expect(raw).toContain("qwen-plus");
-  });
-
-  test("idempotent: second run updates apiKey and preserves workflows", async () => {
-    const initialYaml = `config:
-  maxDepth: 7
-  supervisorInterval: 2
-  providers:
-    dashscope:
-      baseUrl: https://dashscope.aliyuncs.com/compatible-mode/v1
-      apiKey: sk-old
-  models:
-    default: dashscope/qwen-plus
-workflows:
-  keep-me:
-    hash: "0000000000000"
-    timestamp: 1
-    history: []
-`;
-    await writeFile(join(storageRoot, "workflow.yaml"), initialYaml, "utf8");
-
-    const r2 = await cmdSetup(storageRoot, {
-      provider: "dashscope",
-      baseUrl: "https://dashscope.aliyuncs.com/compatible-mode/v1",
-      apiKey: "sk-newkey",
-      defaultModel: "dashscope/qwen-plus",
-      initWorkspaceName: null,
-    });
-    expect(r2.ok).toBe(true);
-    if (!r2.ok) {
-      return;
-    }
-
-    const reg = await readWorkflowRegistry(storageRoot);
-    expect(reg.ok).toBe(true);
-    if (!reg.ok || reg.value.config === null) {
-      return;
-    }
-    expect(reg.value.config.providers.dashscope.apiKey).toBe("sk-newkey");
-    expect(reg.value.config.maxDepth).toBe(7);
-    expect(reg.value.config.supervisorInterval).toBe(2);
-    expect(reg.value.workflows["keep-me"]).toBeDefined();
-    if (reg.value.workflows["keep-me"] === undefined) {
-      return;
-    }
-    expect(reg.value.workflows["keep-me"].hash).toBe("0000000000000");
-  });
-
-  test("runCli setup dispatches with flags and exits 0", async () => {
-    const code = await runCli(storageRoot, [
-      "setup",
-      "--provider",
-      "openai",
-      "--base-url",
-      "https://api.openai.com/v1",
-      "--api-key",
-      "sk-test",
-      "--default-model",
-      "openai/gpt-4o",
-    ]);
-    expect(code).toBe(0);
-    const reg = await readWorkflowRegistry(storageRoot);
-    expect(reg.ok).toBe(true);
-    if (!reg.ok || reg.value.config === null) {
-      return;
-    }
-    expect(reg.value.config.providers.openai.apiKey).toBe("sk-test");
-    expect(reg.value.config.models.default).toBe("openai/gpt-4o");
-  });
-});

legacy-packages/cli-workflow/package.json

@@ -1,30 +0,0 @@
-{
-  "name": "@uncaged/cli-workflow",
-  "version": "0.5.0-alpha.4",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "bin": {
-    "uncaged-workflow": "src/cli.ts"
-  },
-  "dependencies": {
-    "@uncaged/workflow-gateway": "workspace:^",
-    "@uncaged/workflow-protocol": "workspace:^",
-    "@uncaged/workflow-util": "workspace:^",
-    "@uncaged/workflow-cas": "workspace:^",
-    "@uncaged/workflow-execute": "workspace:^",
-    "@uncaged/workflow-register": "workspace:^",
-    "@uncaged/workflow-runtime": "workspace:^",
-    "hono": "^4.12.18",
-    "yaml": "^2.8.4"
-  },
-  "scripts": {
-    "test": "bun test"
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/cli-workflow/src/cli.ts

@@ -1,9 +0,0 @@
-#!/usr/bin/env bun
-
-import { runCli } from "./cli-dispatch.js";
-import { resolveWorkflowStorageRoot } from "./storage-env.js";
-
-const argv = process.argv.slice(2);
-const storageRoot = resolveWorkflowStorageRoot();
-const code = await runCli(storageRoot, argv);
-process.exit(code);

legacy-packages/cli-workflow/src/commands/connect/connect.ts

@@ -1,111 +0,0 @@
-import { randomUUID } from "node:crypto";
-import { hostname as osHostname } from "node:os";
-import { ok, type Result } from "@uncaged/workflow-protocol";
-import { createLogger } from "@uncaged/workflow-util";
-
-import { printCliLine } from "../../cli-output.js";
-import { createApp } from "./app.js";
-import { registerWithGateway, startHeartbeat, unregisterFromGateway } from "./gateway.js";
-import type { ConnectOptions } from "./types.js";
-import { startGatewayWsClient } from "./ws-client.js";
-
-const DEFAULT_GATEWAY_URL = "https://workflow-gateway.shazhou.workers.dev";
-const HEARTBEAT_INTERVAL_MS = 60_000;
-
-function requireNextArg(argv: string[], i: number, flag: string): Result<string, string> {
-  const next = argv[i + 1];
-  if (next === undefined) {
-    return { ok: false, error: `${flag} requires a value` };
-  }
-  return ok(next);
-}
-
-function parseConnectArgv(argv: string[]): Result<ConnectOptions, string> {
-  let name = osHostname().split(".")[0].toLowerCase();
-  let gatewayUrl = DEFAULT_GATEWAY_URL;
-  const gatewaySecret = process.env.WORKFLOW_DASHBOARD_SECRET ?? "";
-  const stringFlags: Record<string, (v: string) => void> = {
-    "--name": (v) => {
-      name = v;
-    },
-    "--gateway": (v) => {
-      gatewayUrl = v;
-    },
-  };
-
-  for (let i = 0; i < argv.length; i++) {
-    const arg = argv[i];
-    if (arg in stringFlags) {
-      const r = requireNextArg(argv, i, arg);
-      if (!r.ok) return r;
-      stringFlags[arg](r.value);
-      i++;
-    }
-  }
-
-  return ok({ name, gatewayUrl, gatewaySecret });
-}
-
-export async function dispatchConnect(storageRoot: string, argv: string[]): Promise<number> {
-  const parsed = parseConnectArgv(argv);
-  if (!parsed.ok) {
-    printCliLine(`error: ${parsed.error}`);
-    return 1;
-  }
-
-  const options = parsed.value;
-
-  if (options.gatewaySecret === "") {
-    printCliLine("error: WORKFLOW_DASHBOARD_SECRET is required");
-    return 1;
-  }
-
-  const clientToken = randomUUID();
-  const app = createApp(storageRoot, clientToken);
-
-  const log = createLogger({ sink: { kind: "stderr" } });
-  const stopWsClient = startGatewayWsClient({
-    gatewayUrl: options.gatewayUrl,
-    name: options.name,
-    secret: options.gatewaySecret,
-    appFetch: app.fetch,
-    log,
-  });
-
-  printCliLine("connected to gateway via WebSocket");
-
-  // Register with gateway for discovery
-  const registered = await registerWithGateway(
-    options.gatewayUrl,
-    options.name,
-    `ws://${options.name}`,
-    options.gatewaySecret,
-    clientToken,
-  );
-  if (registered) {
-    printCliLine(`registered with gateway as "${options.name}"`);
-  }
-
-  const heartbeatTimer = startHeartbeat(
-    options.gatewayUrl,
-    options.name,
-    `ws://${options.name}`,
-    options.gatewaySecret,
-    clientToken,
-    HEARTBEAT_INTERVAL_MS,
-  );
-
-  const cleanup = async () => {
-    clearInterval(heartbeatTimer);
-    stopWsClient();
-    printCliLine("unregistering from gateway...");
-    await unregisterFromGateway(options.gatewayUrl, options.name, options.gatewaySecret);
-    process.exit(0);
-  };
-
-  process.on("SIGINT", cleanup);
-  process.on("SIGTERM", cleanup);
-
-  await new Promise(() => {});
-  return 0;
-}

legacy-packages/cli-workflow/src/commands/connect/index.ts

@@ -1,2 +0,0 @@
-export { dispatchConnect } from "./connect.js";
-export type { ConnectOptions } from "./types.js";

legacy-packages/cli-workflow/src/commands/connect/types.ts

@@ -1,5 +0,0 @@
-export type ConnectOptions = {
-  name: string;
-  gatewayUrl: string;
-  gatewaySecret: string;
-};

legacy-packages/cli-workflow/src/commands/connect/ws-client.ts

@@ -1,164 +0,0 @@
-import { parseWsRequestJson, type WsResponse } from "@uncaged/workflow-gateway/ws-protocol";
-import type { LogFn } from "@uncaged/workflow-util";
-
-export type GatewayWsClientParams = {
-  gatewayUrl: string;
-  name: string;
-  secret: string;
-  appFetch: (request: Request) => Response | Promise<Response>;
-  log: LogFn;
-};
-
-const INITIAL_BACKOFF_MS = 1000;
-const MAX_BACKOFF_MS = 30_000;
-
-export function buildGatewayWsConnectUrl(gatewayUrl: string, name: string, secret: string): string {
-  const u = new URL(gatewayUrl);
-  if (u.protocol === "https:") {
-    u.protocol = "wss:";
-  } else if (u.protocol === "http:") {
-    u.protocol = "ws:";
-  }
-  u.pathname = "/ws/connect";
-  u.search = "";
-  u.searchParams.set("name", name);
-  u.searchParams.set("secret", secret);
-  return u.href;
-}
-
-function headersToRecord(h: Headers): Record<string, string> {
-  const out: Record<string, string> = {};
-  for (const [k, v] of h) {
-    out[k] = v;
-  }
-  return out;
-}
-
-async function handleGatewayMessage(
-  ws: WebSocket,
-  raw: string,
-  params: GatewayWsClientParams,
-): Promise<void> {
-  const req = parseWsRequestJson(raw);
-  if (req === null) {
-    params.log("ZM8K2PQ1", "gateway WebSocket dropped non-request message");
-    return;
-  }
-  const localUrl = `http://localhost${req.path}`;
-  const headers = new Headers(req.headers);
-  let resp: Response;
-  try {
-    resp = await params.appFetch(
-      new Request(localUrl, {
-        method: req.method,
-        headers,
-        body: req.body === null ? undefined : req.body,
-      }),
-    );
-  } catch (e) {
-    params.log("R4N7BQ3C", `app.fetch failed: ${String(e)}`);
-    const errBody: WsResponse = {
-      id: req.id,
-      status: 502,
-      headers: { "content-type": "application/json" },
-      body: JSON.stringify({ error: "local fetch failed", detail: String(e) }),
-    };
-    ws.send(JSON.stringify(errBody));
-    return;
-  }
-  const bodyText = await resp.text();
-  const headerRecord = headersToRecord(resp.headers);
-  const out: WsResponse = {
-    id: req.id,
-    status: resp.status,
-    headers: headerRecord,
-    body: bodyText,
-  };
-  ws.send(JSON.stringify(out));
-}
-
-/** Maintains a reverse WebSocket to the workflow gateway; reconnects with exponential backoff. */
-export function startGatewayWsClient(params: GatewayWsClientParams): () => void {
-  const wsUrl = buildGatewayWsConnectUrl(params.gatewayUrl, params.name, params.secret);
-  let socket: WebSocket | null = null;
-  let reconnectTimer: ReturnType<typeof setTimeout> | null = null;
-  let stopped = false;
-  let attempt = 0;
-
-  const clearReconnectTimer = (): void => {
-    if (reconnectTimer !== null) {
-      clearTimeout(reconnectTimer);
-      reconnectTimer = null;
-    }
-  };
-
-  const scheduleReconnect = (): void => {
-    if (stopped) {
-      return;
-    }
-    clearReconnectTimer();
-    const delayMs = Math.min(INITIAL_BACKOFF_MS * 2 ** attempt, MAX_BACKOFF_MS);
-    attempt++;
-    params.log("6CJX2R8P", `gateway WebSocket reconnect in ${delayMs}ms (attempt ${attempt})`);
-    reconnectTimer = setTimeout(connect, delayMs);
-  };
-
-  const connect = (): void => {
-    if (stopped) {
-      return;
-    }
-    clearReconnectTimer();
-    params.log("2XK7HM9Q", "gateway WebSocket connecting...");
-    try {
-      socket = new WebSocket(wsUrl);
-    } catch (e) {
-      params.log("7NQW4HBT", `gateway WebSocket create failed: ${String(e)}`);
-      scheduleReconnect();
-      return;
-    }
-
-    const ws = socket;
-
-    ws.addEventListener("open", () => {
-      attempt = 0;
-      params.log("4PWN3V82", "gateway WebSocket connected");
-    });
-
-    ws.addEventListener("close", (ev) => {
-      socket = null;
-      params.log(
-        "8QTR6ZKC",
-        `gateway WebSocket closed code=${String(ev.code)} reason=${ev.reason} wasClean=${String(ev.wasClean)}`,
-      );
-      if (!stopped) {
-        scheduleReconnect();
-      }
-    });
-
-    ws.addEventListener("error", () => {
-      params.log("9BWS1M7F", "gateway WebSocket error");
-    });
-
-    ws.addEventListener("message", (ev) => {
-      const data = ev.data;
-      if (typeof data !== "string") {
-        params.log("T9W2K35H", "gateway WebSocket non-text frame ignored");
-        return;
-      }
-      void handleGatewayMessage(ws, data, params).catch((e: unknown) => {
-        params.log("V7KX2M9P", `gateway WebSocket handler error: ${String(e)}`);
-      });
-    });
-  };
-
-  connect();
-
-  return (): void => {
-    stopped = true;
-    clearReconnectTimer();
-    if (socket !== null && socket.readyState === WebSocket.OPEN) {
-      socket.close(1000, "shutdown");
-    }
-    socket = null;
-  };
-}

legacy-packages/cli-workflow/src/commands/setup/dispatch.ts

@@ -1,451 +0,0 @@
-import { existsSync } from "node:fs";
-import { resolve as resolvePath } from "node:path";
-import { stdin as input, stdout as output } from "node:process";
-import { createInterface } from "node:readline/promises";
-
-import { err, ok, type Result } from "@uncaged/workflow-protocol";
-
-import { createLogger } from "@uncaged/workflow-util";
-
-import { printCliError, printCliLine, printCliWarn } from "../../cli-output.js";
-
-const setupDispatchLog = createLogger({ sink: { kind: "stderr" } });
-
-import { loadPresetProviders } from "./preset-providers.js";
-import { cmdSetup, printSetupSummary } from "./setup.js";
-import type { SetupCliArgs } from "./types.js";
-
-type OpenAiModelEntry = {
-  id: string;
-};
-
-type OpenAiModelsResponse = {
-  data: OpenAiModelEntry[];
-};
-
-function usageSetup(): string {
-  return [
-    "uncaged-workflow setup — configure workflow.yaml providers and default model",
-    "",
-    "Non-interactive (agent mode):",
-    "  uncaged-workflow setup \\",
-    "    --provider <name> \\",
-    "    --base-url <url> \\",
-    "    --api-key <key> \\",
-    "    --default-model <provider/model> \\",
-    "    [--init-workspace <name>]",
-    "",
-    "Interactive: run with no flags (prompts for each value).",
-    "",
-    "Storage: uses the same root as other commands (see UNCAGED_WORKFLOW_STORAGE_ROOT).",
-  ].join("\n");
-}
-
-function requireNext(argv: string[], i: number, flag: string): Result<string, string> {
-  const next = argv[i + 1];
-  if (next === undefined || next.startsWith("--")) {
-    return err(`${flag} requires a value`);
-  }
-  return ok(next);
-}
-
-type ParsedSetup = SetupCliArgs | "interactive" | "help";
-
-type SetupFlagField = "provider" | "baseUrl" | "apiKey" | "defaultModel" | "initWorkspaceName";
-
-const SETUP_FLAG_TO_FIELD: Record<string, SetupFlagField> = {
-  "--provider": "provider",
-  "--base-url": "baseUrl",
-  "--api-key": "apiKey",
-  "--default-model": "defaultModel",
-  "--init-workspace": "initWorkspaceName",
-};
-
-function emptyFlagState(): Record<SetupFlagField, string | null> {
-  return {
-    provider: null,
-    baseUrl: null,
-    apiKey: null,
-    defaultModel: null,
-    initWorkspaceName: null,
-  };
-}
-
-function finalizeParsedSetup(
-  state: Record<SetupFlagField, string | null>,
-): Result<ParsedSetup, string> {
-  const hasAnyFlag =
-    state.provider !== null ||
-    state.baseUrl !== null ||
-    state.apiKey !== null ||
-    state.defaultModel !== null ||
-    state.initWorkspaceName !== null;
-
-  if (!hasAnyFlag) {
-    return ok("interactive");
-  }
-
-  if (state.provider === null) {
-    return err(
-      "non-interactive setup requires --provider (or omit all flags for interactive mode)",
-    );
-  }
-
-  const missing: string[] = [];
-  if (state.baseUrl === null) {
-    missing.push("--base-url");
-  }
-  if (state.apiKey === null) {
-    missing.push("--api-key");
-  }
-  if (state.defaultModel === null) {
-    missing.push("--default-model");
-  }
-  if (missing.length > 0) {
-    return err(`missing required flag(s): ${missing.join(", ")}`);
-  }
-
-  const b = state.baseUrl;
-  const k = state.apiKey;
-  const m = state.defaultModel;
-  if (b === null || k === null || m === null) {
-    return err("internal: missing required flags after validation");
-  }
-
-  return ok({
-    provider: state.provider,
-    baseUrl: b,
-    apiKey: k,
-    defaultModel: m,
-    initWorkspaceName: state.initWorkspaceName,
-  });
-}
-
-function parseSetupArgv(argv: string[]): Result<ParsedSetup, string> {
-  const state = emptyFlagState();
-
-  for (let i = 0; i < argv.length; i++) {
-    const tok = argv[i];
-    if (tok === undefined) {
-      break;
-    }
-    if (tok === "--help" || tok === "-h") {
-      return ok("help");
-    }
-    const field = SETUP_FLAG_TO_FIELD[tok];
-    if (field === undefined) {
-      return err(`unknown argument: ${tok}`);
-    }
-    const v = requireNext(argv, i, tok);
-    if (!v.ok) {
-      return v;
-    }
-    state[field] = v.value;
-    i++;
-  }
-
-  return finalizeParsedSetup(state);
-}
-
-async function promptLine(
-  rl: { question: (q: string) => Promise<string> },
-  label: string,
-): Promise<string> {
-  const raw = await rl.question(label);
-  return raw.trim();
-}
-
-type SecretInputState = {
-  buf: string;
-  rawWasSet: boolean;
-  onData: (chunk: string) => void;
-  fulfill: (value: string) => void;
-};
-
-function isLineTerminator(c: string): boolean {
-  return c === "\n" || c === "\r" || c === "\u0004";
-}
-
-function handleLineTerminator(state: SecretInputState): void {
-  if (process.stdin.isTTY) {
-    process.stdin.setRawMode(state.rawWasSet);
-  }
-  process.stdin.pause();
-  process.stdin.removeListener("data", state.onData);
-  process.stdout.write("\n");
-  state.fulfill(state.buf.trim());
-}
-
-function handleBackspace(state: SecretInputState): void {
-  if (state.buf.length > 0) {
-    state.buf = state.buf.slice(0, -1);
-    process.stdout.write("\b \b");
-  }
-}
-
-function handleInterrupt(rawWasSet: boolean): void {
-  if (process.stdin.isTTY) {
-    process.stdin.setRawMode(rawWasSet);
-  }
-  process.exit(130);
-}
-
-function isBackspace(c: string): boolean {
-  return c === "\u007F" || c === "\b";
-}
-
-/** Process a single character in secret input. Returns "done" to stop reading. */
-function processSecretChar(c: string, state: SecretInputState): "done" | "skip" | "append" {
-  if (isLineTerminator(c)) {
-    handleLineTerminator(state);
-    return "done";
-  }
-  if (isBackspace(c)) {
-    handleBackspace(state);
-    return "skip";
-  }
-  if (c === "\u0003") {
-    handleInterrupt(state.rawWasSet);
-  }
-  state.buf += c;
-  process.stdout.write("*");
-  return "append";
-}
-
-/** Read a line with terminal echo disabled (for secrets). */
-async function promptSecret(label: string): Promise<string> {
-  process.stdout.write(label);
-  return new Promise((fulfill) => {
-    const rawWasSet = process.stdin.isRaw;
-    if (process.stdin.isTTY) {
-      process.stdin.setRawMode(true);
-    }
-    process.stdin.resume();
-    process.stdin.setEncoding("utf8");
-
-    const state: SecretInputState = { buf: "", rawWasSet, fulfill, onData: () => {} };
-
-    const onData = (chunk: string) => {
-      for (const c of chunk.toString()) {
-        if (processSecretChar(c, state) === "done") return;
-      }
-    };
-
-    state.onData = onData;
-    process.stdin.on("data", onData);
-  });
-}
-
-/** Fetch available models from an OpenAI-compatible /models endpoint. */
-async function fetchAvailableModels(baseUrl: string, apiKey: string): Promise<string[]> {
-  const url = `${baseUrl.replace(/\/+$/, "")}/models`;
-  try {
-    const res = await fetch(url, {
-      headers: { Authorization: `Bearer ${apiKey}` },
-      signal: AbortSignal.timeout(10_000),
-    });
-    if (!res.ok) {
-      setupDispatchLog("R5KH7WM3", `GET ${url} returned ${res.status}`);
-      return [];
-    }
-    const body = (await res.json()) as OpenAiModelsResponse;
-    if (!Array.isArray(body.data)) {
-      return [];
-    }
-    // Filter out non-chat models. Some patterns are DashScope-specific (sambert, cosyvoice,
-    // wordart, wanx, wan2, paraformer) but harmless for other providers.
-    const NON_CHAT_RE =
-      /speech|embed|image|video|audio|ocr|rerank|tts|asr|paraformer|sambert|cosyvoice|wordart|wanx|wan2|flux|stable-diffusion|z-image|s2s|livetranslate|realtime|gui-/i;
-    return body.data
-      .map((m) => m.id)
-      .filter((id) => !NON_CHAT_RE.test(id))
-      .sort();
-  } catch (e) {
-    setupDispatchLog(
-      "V8NQ4JT6",
-      `fetch models failed: ${e instanceof Error ? e.message : String(e)}`,
-    );
-    return [];
-  }
-}
-
-type PresetProvider = ReturnType<typeof loadPresetProviders>[number];
-
-function printProviderMenu(presets: readonly PresetProvider[]): void {
-  const numWidth = String(presets.length + 1).length;
-  printCliLine("Select a provider:\n");
-  for (let i = 0; i < presets.length; i++) {
-    const p = presets.at(i);
-    if (!p) continue;
-    const num = String(i + 1).padStart(numWidth);
-    printCliLine(`  ${num}) ${p.label.padEnd(28)} ${p.baseUrl}`);
-  }
-  const customNum = String(presets.length + 1).padStart(numWidth);
-  printCliLine(`  ${customNum}) Custom (enter name and URL manually)`);
-  printCliLine("");
-}
-
-async function selectProvider(
-  rl: { question: (q: string) => Promise<string> },
-  presets: readonly PresetProvider[],
-): Promise<Result<{ provider: string; baseUrl: string }, string>> {
-  const choice = await promptLine(rl, `Choose [1-${presets.length + 1}]: `);
-  const choiceNum = Number.parseInt(choice, 10);
-  if (Number.isNaN(choiceNum) || choiceNum < 1 || choiceNum > presets.length + 1) {
-    return err(`invalid choice: ${choice}`);
-  }
-
-  if (choiceNum <= presets.length) {
-    const selected = presets.at(choiceNum - 1);
-    if (!selected) return err(`invalid choice: ${choice}`);
-    printCliLine(`\n  → ${selected.label} (${selected.baseUrl})\n`);
-    return ok({ provider: selected.name, baseUrl: selected.baseUrl });
-  }
-
-  const provider = await promptLine(rl, "Provider name (e.g. my-proxy): ");
-  if (provider === "") return err("provider name must not be empty");
-  const baseUrl = await promptLine(rl, "OpenAI-compatible API base URL: ");
-  if (baseUrl === "") return err("base URL must not be empty");
-  return ok({ provider, baseUrl });
-}
-
-function printModelList(models: string[]): void {
-  const cols = process.stdout.columns || 80;
-  const nw = String(models.length).length;
-  const prefixLen = nw + 4;
-  const maxModelLen = Math.max(...models.map((m) => m.length));
-  const cellWidth = prefixLen + maxModelLen + 2;
-  const numCols = Math.max(1, Math.floor(cols / cellWidth));
-  for (let i = 0; i < models.length; i += numCols) {
-    const cells: string[] = [];
-    for (let j = i; j < Math.min(i + numCols, models.length); j++) {
-      const num = String(j + 1).padStart(nw);
-      const model = models.at(j) ?? "";
-      cells.push(`  ${num}) ${model.padEnd(maxModelLen + 2)}`);
-    }
-    printCliLine(cells.join(""));
-  }
-}
-
-async function selectModel(
-  rl: { question: (q: string) => Promise<string> },
-  models: string[],
-): Promise<Result<string, string>> {
-  if (models.length > 0) {
-    printCliLine(`\nAvailable models (${models.length}):\n`);
-    printModelList(models);
-    printCliLine(`\nChoose a number, or type a model name directly.`);
-    const modelInput = await promptLine(rl, `Default model [1-${models.length}]: `);
-    if (modelInput === "") return err("default model must not be empty");
-    const modelNum = Number.parseInt(modelInput, 10);
-    if (!Number.isNaN(modelNum) && modelNum >= 1 && modelNum <= models.length) {
-      return ok(models.at(modelNum - 1) ?? modelInput);
-    }
-    return ok(modelInput);
-  }
-
-  printCliWarn("Could not fetch models (API may not support /models endpoint).");
-  const modelInput = await promptLine(rl, `Default model (e.g. qwen-plus, gpt-4o): `);
-  if (modelInput === "") return err("default model must not be empty");
-  return ok(modelInput);
-}
-
-async function selectWorkspace(rl: {
-  question: (q: string) => Promise<string>;
-}): Promise<string | null> {
-  while (true) {
-    const wsPath = await promptLine(
-      rl,
-      "\nWorkflow workspace path (default: ./workflows, type 'skip' to skip): ",
-    );
-    if (wsPath.toLowerCase() === "skip") return null;
-    const candidate = wsPath === "" ? "./workflows" : wsPath;
-    const resolved = resolvePath(process.cwd(), candidate);
-    if (existsSync(resolved)) {
-      printCliWarn(`directory already exists: ${resolved}`);
-      printCliLine("Please enter a different path, or type 'skip' to skip.");
-      continue;
-    }
-    return candidate;
-  }
-}
-
-function stripProviderPrefix(model: string): string {
-  if (model.includes("/")) {
-    return model.split("/").pop() ?? model;
-  }
-  return model;
-}
-
-async function collectInteractiveSetup(): Promise<Result<SetupCliArgs, string>> {
-  const rl = createInterface({ input, output });
-  try {
-    printCliLine("Configure the LLM provider that workflow agents will use.\n");
-
-    const presets = loadPresetProviders();
-    printProviderMenu(presets);
-
-    const providerResult = await selectProvider(rl, presets);
-    if (!providerResult.ok) {
-      rl.close();
-      return providerResult;
-    }
-    const { provider, baseUrl } = providerResult.value;
-
-    rl.close();
-    const apiKey = await promptSecret("API key for this provider: ");
-    if (apiKey === "") return err("API key must not be empty");
-    const rl2 = createInterface({ input, output });
-
-    printCliLine("\nFetching available models...");
-    const models = await fetchAvailableModels(baseUrl, apiKey);
-    const modelResult = await selectModel(rl2, models);
-    if (!modelResult.ok) {
-      rl2.close();
-      return modelResult;
-    }
-
-    const bare = stripProviderPrefix(modelResult.value);
-    const defaultModel = `${provider}/${bare}`;
-    printCliLine(`  → ${defaultModel}`);
-
-    const initWorkspaceName = await selectWorkspace(rl2);
-    rl2.close();
-
-    return ok({ provider, baseUrl, apiKey, defaultModel, initWorkspaceName });
-  } catch (e) {
-    return err(e instanceof Error ? e.message : String(e));
-  }
-}
-
-export async function dispatchSetup(storageRoot: string, argv: string[]): Promise<number> {
-  const parsed = parseSetupArgv(argv);
-  if (!parsed.ok) {
-    printCliError(`${parsed.error}\n\n${usageSetup()}`);
-    return 1;
-  }
-  if (parsed.value === "help") {
-    printCliLine(usageSetup());
-    return 0;
-  }
-
-  let args: SetupCliArgs;
-  if (parsed.value === "interactive") {
-    const collected = await collectInteractiveSetup();
-    if (!collected.ok) {
-      printCliError(collected.error);
-      return 1;
-    }
-    args = collected.value;
-  } else {
-    args = parsed.value;
-  }
-
-  const result = await cmdSetup(storageRoot, args);
-  if (!result.ok) {
-    printCliError(result.error);
-    return 1;
-  }
-  printSetupSummary(result.value);
-  return 0;
-}

legacy-packages/cli-workflow/src/commands/setup/index.ts

@@ -1,4 +0,0 @@
-export { dispatchSetup } from "./dispatch.js";
-export { loadPresetProviders } from "./preset-providers.js";
-export { cmdSetup, printSetupSummary } from "./setup.js";
-export type { CmdSetupSuccess, PresetProvider, SetupCliArgs } from "./types.js";

legacy-packages/cli-workflow/src/commands/setup/preset-providers.ts

@@ -1,47 +0,0 @@
-import { readFileSync } from "node:fs";
-import { join } from "node:path";
-
-import { parse as parseYaml } from "yaml";
-
-import type { PresetProvider } from "./types.js";
-
-type RawPresetEntry = {
-  name: unknown;
-  label: unknown;
-  baseUrl: unknown;
-};
-
-function isRawEntry(v: unknown): v is RawPresetEntry {
-  if (typeof v !== "object" || v === null) return false;
-  const o = v as Record<string, unknown>;
-  return typeof o.name === "string" && typeof o.label === "string" && typeof o.baseUrl === "string";
-}
-
-let cached: ReadonlyArray<PresetProvider> | null = null;
-
-export function loadPresetProviders(): ReadonlyArray<PresetProvider> {
-  if (cached !== null) return cached;
-
-  const yamlPath = join(import.meta.dirname, "providers.yaml");
-  const raw = readFileSync(yamlPath, "utf8");
-  const parsed: unknown = parseYaml(raw);
-
-  if (!Array.isArray(parsed)) {
-    throw new Error(`providers.yaml: expected array, got ${typeof parsed}`);
-  }
-
-  const result: PresetProvider[] = [];
-  for (const entry of parsed) {
-    if (!isRawEntry(entry)) {
-      throw new Error(`providers.yaml: invalid entry: ${JSON.stringify(entry)}`);
-    }
-    result.push({
-      name: entry.name as string,
-      label: entry.label as string,
-      baseUrl: entry.baseUrl as string,
-    });
-  }
-
-  cached = result;
-  return result;
-}

legacy-packages/cli-workflow/src/commands/setup/providers.yaml

@@ -1,73 +0,0 @@
-# Preset LLM providers for `uncaged-workflow setup`.
-# Each entry needs a provider name (used in workflow.yaml) and an OpenAI-compatible base URL.
-# Add new providers here — no code changes required.
-
-# ── International ──────────────────────────────────────────
-
-- name: openai
-  label: OpenAI
-  baseUrl: https://api.openai.com/v1
-
-- name: xai
-  label: xAI
-  baseUrl: https://api.x.ai/v1
-
-- name: openrouter
-  label: OpenRouter
-  baseUrl: https://openrouter.ai/api/v1
-
-- name: venice
-  label: Venice
-  baseUrl: https://api.venice.ai/api/v1
-
-# ── China ──────────────────────────────────────────────────
-
-- name: dashscope
-  label: DashScope (Alibaba)
-  baseUrl: https://dashscope.aliyuncs.com/compatible-mode/v1
-
-- name: deepseek
-  label: DeepSeek
-  baseUrl: https://api.deepseek.com/v1
-
-- name: siliconflow
-  label: SiliconFlow
-  baseUrl: https://api.siliconflow.cn/v1
-
-- name: volcengine
-  label: Volcengine (ByteDance)
-  baseUrl: https://ark.cn-beijing.volces.com/api/v3
-
-- name: kimi
-  label: Kimi (Moonshot)
-  baseUrl: https://api.moonshot.cn/v1
-
-- name: glm
-  label: GLM (Zhipu AI)
-  baseUrl: https://open.bigmodel.cn/api/paas/v4
-
-- name: glm-intl
-  label: GLM (Zhipu AI Intl)
-  baseUrl: https://api.z.ai/api/paas/v4
-
-- name: stepfun
-  label: StepFun
-  baseUrl: https://api.stepfun.com/v1
-
-- name: minimax
-  label: MiniMax
-  baseUrl: https://api.minimax.io/v1
-
-- name: tencent
-  label: Tencent TokenHub
-  baseUrl: https://tokenhub.tencentmaas.com/v1
-
-- name: xiaomi
-  label: Xiaomi MiMo
-  baseUrl: https://api.xiaomimimo.com/v1
-
-# ── Local ──────────────────────────────────────────────────
-
-- name: ollama
-  label: Ollama (local)
-  baseUrl: http://localhost:11434/v1

legacy-packages/cli-workflow/src/commands/setup/setup.ts

@@ -1,103 +0,0 @@
-import { err, ok, type Result, type WorkflowConfig } from "@uncaged/workflow-protocol";
-import {
-  readWorkflowRegistry,
-  splitProviderModelRef,
-  workflowRegistryPath,
-  writeWorkflowRegistry,
-} from "@uncaged/workflow-register";
-import { createLogger } from "@uncaged/workflow-util";
-
-import { printCliLine } from "../../cli-output.js";
-import { cmdInitWorkspace } from "../init/index.js";
-import type { CmdSetupSuccess, SetupCliArgs } from "./types.js";
-
-const setupLog = createLogger({ sink: { kind: "stderr" } });
-
-function mergeWorkflowConfig(
-  prev: WorkflowConfig | null,
-  input: SetupCliArgs,
-): Result<WorkflowConfig, string> {
-  const modelSplit = splitProviderModelRef(input.defaultModel);
-  if (!modelSplit.ok) {
-    return err(modelSplit.error);
-  }
-  if (modelSplit.value.providerName !== input.provider) {
-    return err(
-      `default model provider "${modelSplit.value.providerName}" must match --provider "${input.provider}"`,
-    );
-  }
-
-  const maxDepth = prev === null ? 3 : prev.maxDepth;
-  const supervisorInterval = prev === null ? 3 : prev.supervisorInterval;
-  const providers = {
-    ...(prev === null ? {} : prev.providers),
-    [input.provider]: { baseUrl: input.baseUrl, apiKey: input.apiKey },
-  };
-  const models = { ...(prev === null ? {} : prev.models), default: input.defaultModel };
-
-  return ok({
-    maxDepth,
-    supervisorInterval,
-    providers,
-    models,
-  });
-}
-
-export async function cmdSetup(
-  storageRoot: string,
-  input: SetupCliArgs,
-): Promise<Result<CmdSetupSuccess, string>> {
-  const readResult = await readWorkflowRegistry(storageRoot);
-  if (!readResult.ok) {
-    setupLog("W8JH4Q2K", `read workflow registry failed: ${readResult.error.message}`);
-    return err(readResult.error.message);
-  }
-
-  const current = readResult.value;
-  const merged = mergeWorkflowConfig(current.config, input);
-  if (!merged.ok) {
-    return merged;
-  }
-  const nextConfig = merged.value;
-  const nextRegistry = {
-    config: nextConfig,
-    workflows: current.workflows,
-  };
-
-  const written = await writeWorkflowRegistry(storageRoot, nextRegistry);
-  if (!written.ok) {
-    setupLog("M2NB5VX9", `write workflow registry failed: ${written.error.message}`);
-    return err(written.error.message);
-  }
-
-  const registryPath = workflowRegistryPath(storageRoot);
-
-  let initWorkspaceRootPath: string | null = null;
-  if (input.initWorkspaceName !== null) {
-    const initResult = await cmdInitWorkspace(process.cwd(), input.initWorkspaceName);
-    if (!initResult.ok) {
-      setupLog("T7QC4HWP", `init workspace failed: ${initResult.error}`);
-      return err(initResult.error);
-    }
-    initWorkspaceRootPath = initResult.value.rootPath;
-  }
-
-  return ok({
-    registryPath,
-    provider: input.provider,
-    defaultModel: input.defaultModel,
-    maxDepth: nextConfig.maxDepth,
-    supervisorInterval: nextConfig.supervisorInterval,
-    initWorkspaceRootPath,
-  });
-}
-
-export function printSetupSummary(result: CmdSetupSuccess): void {
-  printCliLine(`wrote registry: ${result.registryPath}`);
-  printCliLine(`provider "${result.provider}" (baseUrl + apiKey updated)`);
-  printCliLine(`config.models.default = "${result.defaultModel}"`);
-  printCliLine(`maxDepth=${result.maxDepth}, supervisorInterval=${result.supervisorInterval}`);
-  if (result.initWorkspaceRootPath !== null) {
-    printCliLine(`initialized workflow workspace at ${result.initWorkspaceRootPath}`);
-  }
-}

legacy-packages/cli-workflow/src/commands/setup/types.ts

@@ -1,23 +0,0 @@
-/** Parsed non-interactive `setup` CLI arguments (all fields required for agent mode). */
-export type SetupCliArgs = {
-  provider: string;
-  baseUrl: string;
-  apiKey: string;
-  defaultModel: string;
-  initWorkspaceName: string | null;
-};
-
-export type PresetProvider = {
-  name: string;
-  label: string;
-  baseUrl: string;
-};
-
-export type CmdSetupSuccess = {
-  registryPath: string;
-  provider: string;
-  defaultModel: string;
-  maxDepth: number;
-  supervisorInterval: number;
-  initWorkspaceRootPath: string | null;
-};

legacy-packages/cli-workflow/tsconfig.json

@@ -1,29 +0,0 @@
-{
-  "compilerOptions": {
-    "target": "ES2022",
-    "lib": ["ES2022"],
-    "module": "NodeNext",
-    "moduleResolution": "NodeNext",
-    "strict": true,
-    "exactOptionalPropertyTypes": true,
-    "esModuleInterop": true,
-    "skipLibCheck": true,
-    "forceConsistentCasingInFileNames": true,
-    "declaration": true,
-    "declarationMap": true,
-    "sourceMap": true,
-    "composite": true,
-    "outDir": "dist",
-    "rootDir": "src",
-    "types": ["bun-types"]
-  },
-  "references": [
-    { "path": "../workflow-runtime" },
-    { "path": "../workflow-protocol" },
-    { "path": "../workflow-util" },
-    { "path": "../workflow-cas" },
-    { "path": "../workflow-execute" },
-    { "path": "../workflow-register" }
-  ],
-  "include": ["src/**/*.ts"]
-}

legacy-packages/workflow-agent-cursor/CHANGELOG.md

@@ -1,119 +0,0 @@
-# @uncaged/workflow-agent-cursor
-
-## 0.5.0-alpha.4
-
-### Patch Changes
-
-- Updated dependencies
-- Updated dependencies [f74b482]
-- Updated dependencies [f74b482]
-  - @uncaged/workflow-util@0.5.0-alpha.4
-  - @uncaged/workflow-protocol@0.5.0-alpha.4
-  - @uncaged/workflow-cas@0.5.0-alpha.4
-  - @uncaged/workflow-runtime@0.5.0-alpha.4
-  - @uncaged/workflow-util-agent@0.5.0-alpha.4
-
-## 0.5.0-alpha.3
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.3
-  - @uncaged/workflow-cas@0.5.0-alpha.3
-  - @uncaged/workflow-runtime@0.5.0-alpha.3
-  - @uncaged/workflow-util@0.5.0-alpha.3
-  - @uncaged/workflow-util-agent@0.5.0-alpha.3
-
-## 0.5.0-alpha.2
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.2
-  - @uncaged/workflow-cas@0.5.0-alpha.2
-  - @uncaged/workflow-runtime@0.5.0-alpha.2
-  - @uncaged/workflow-util@0.5.0-alpha.2
-  - @uncaged/workflow-util-agent@0.5.0-alpha.2
-
-## 0.5.0-alpha.1
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-util-agent@0.5.0-alpha.1
-  - @uncaged/workflow-cas@0.5.0-alpha.1
-  - @uncaged/workflow-protocol@0.5.0-alpha.1
-  - @uncaged/workflow-runtime@0.5.0-alpha.1
-  - @uncaged/workflow-util@0.5.0-alpha.1
-
-## 0.5.0-alpha.0
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.0
-  - @uncaged/workflow-cas@0.5.0-alpha.0
-  - @uncaged/workflow-runtime@0.5.0-alpha.0
-  - @uncaged/workflow-util@0.5.0-alpha.0
-  - @uncaged/workflow-util-agent@0.5.0-alpha.0
-
-## 0.4.5
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.5
-  - @uncaged/workflow-reactor@0.4.5
-  - @uncaged/workflow-runtime@0.4.5
-  - @uncaged/workflow-util@0.4.5
-  - @uncaged/workflow-util-agent@0.4.5
-
-## 0.4.4
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.4
-  - @uncaged/workflow-reactor@0.4.4
-  - @uncaged/workflow-runtime@0.4.4
-  - @uncaged/workflow-util@0.4.4
-  - @uncaged/workflow-util-agent@0.4.4
-
-## 0.4.3
-
-### Patch Changes
-
-- Include src/ in published packages so bun runtime can resolve the 'bun' exports condition.
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.3
-  - @uncaged/workflow-reactor@0.4.3
-  - @uncaged/workflow-runtime@0.4.3
-  - @uncaged/workflow-util-agent@0.4.3
-  - @uncaged/workflow-util@0.4.3
-
-## 0.4.2
-
-### Patch Changes
-
-- Fix workspace dependency resolution: use workspace:^ so published packages resolve to compatible versions instead of exact (non-existent) versions.
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.2
-  - @uncaged/workflow-reactor@0.4.2
-  - @uncaged/workflow-runtime@0.4.2
-  - @uncaged/workflow-util-agent@0.4.2
-  - @uncaged/workflow-util@0.4.2
-
-## 0.4.0
-
-### Minor Changes
-
-- Fix package exports for published packages and adopt changesets for version management.
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.0
-  - @uncaged/workflow-reactor@0.4.0
-  - @uncaged/workflow-runtime@0.4.0
-  - @uncaged/workflow-util-agent@0.4.0
-  - @uncaged/workflow-util@0.4.0

legacy-packages/workflow-agent-cursor/__tests__/cursor-agent.test.ts

@@ -1,65 +0,0 @@
-import { describe, expect, test } from "bun:test";
-import { createCursorAgent, validateCursorAgentConfig } from "../src/index.js";
-
-const baseConfig = {
-  command: "/usr/local/bin/cursor-agent",
-  model: null as string | null,
-  timeout: 0,
-  workspace: null as string | null,
-};
-
-describe("validateCursorAgentConfig", () => {
-  test("accepts valid config", () => {
-    const r = validateCursorAgentConfig({
-      ...baseConfig,
-    });
-    expect(r.ok).toBe(true);
-  });
-
-  test("rejects non-absolute command", () => {
-    const r = validateCursorAgentConfig({
-      ...baseConfig,
-      command: "cursor-agent",
-    });
-    expect(r.ok).toBe(false);
-    if (!r.ok) {
-      expect(r.error).toContain("absolute path");
-    }
-  });
-
-  test("rejects negative timeout", () => {
-    const r = validateCursorAgentConfig({
-      ...baseConfig,
-      timeout: -1,
-    });
-    expect(r.ok).toBe(false);
-  });
-
-  test("rejects non-absolute workspace when set", () => {
-    const r = validateCursorAgentConfig({
-      ...baseConfig,
-      workspace: "relative/path",
-    });
-    expect(r.ok).toBe(false);
-    if (!r.ok) {
-      expect(r.error).toContain("workspace");
-    }
-  });
-});
-
-describe("createCursorAgent", () => {
-  test("returns an AdapterFn", () => {
-    const agent = createCursorAgent({
-      ...baseConfig,
-    });
-    expect(typeof agent).toBe("function");
-  });
-
-  test("defers validation to call time (invalid config does not throw at construction)", () => {
-    const agent = createCursorAgent({
-      ...baseConfig,
-      timeout: -1,
-    });
-    expect(typeof agent).toBe("function");
-  });
-});

legacy-packages/workflow-agent-cursor/package.json

@@ -1,32 +0,0 @@
-{
-  "name": "@uncaged/workflow-agent-cursor",
-  "version": "0.5.0-alpha.4",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "types": "src/index.ts",
-  "scripts": {
-    "test": "bun test"
-  },
-  "dependencies": {
-    "@uncaged/workflow-cas": "workspace:^",
-    "@uncaged/workflow-protocol": "workspace:^",
-    "@uncaged/workflow-runtime": "workspace:^",
-    "@uncaged/workflow-util": "workspace:^",
-    "@uncaged/workflow-util-agent": "workspace:^",
-    "zod": "^4.0.0"
-  },
-  "exports": {
-    ".": {
-      "bun": "./src/index.ts",
-      "types": "./dist/index.d.ts",
-      "import": "./dist/index.js"
-    }
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/workflow-agent-cursor/src/extract-workspace.ts

@@ -1,47 +0,0 @@
-import { putContentNodeWithRefs } from "@uncaged/workflow-cas";
-import type { ThreadContext, WorkflowRuntime } from "@uncaged/workflow-runtime";
-import type { LogFn } from "@uncaged/workflow-util";
-import * as z from "zod/v4";
-
-const workspaceSchema = z.object({
-  workspace: z.string().describe("Absolute filesystem path of the project workspace"),
-});
-
-function buildExtractionInput(ctx: ThreadContext): string {
-  const lines: string[] = [];
-  lines.push("## Task");
-  lines.push(ctx.start.content);
-
-  for (const step of ctx.steps) {
-    lines.push("");
-    lines.push(`## Step: ${step.role}`);
-    lines.push(`Meta: ${JSON.stringify(step.meta)}`);
-  }
-
-  lines.push("");
-  lines.push(
-    "Extract the absolute filesystem path of the project workspace where code changes should be made.",
-  );
-
-  return lines.join("\n");
-}
-
-export async function extractWorkspacePath(
-  ctx: ThreadContext,
-  runtime: WorkflowRuntime,
-  logger: LogFn,
-): Promise<string | null> {
-  const input = buildExtractionInput(ctx);
-  const contentHash = await putContentNodeWithRefs(runtime.cas, input, []);
-
-  const result = await runtime.extract(workspaceSchema, contentHash);
-  const workspace = result.meta.workspace.trim();
-
-  if (!workspace.startsWith("/")) {
-    logger("H4PM7RXV", `workspace extraction returned non-absolute path: ${workspace}`);
-    return null;
-  }
-
-  logger("V3KM8QWP", `extracted workspace: ${workspace}`);
-  return workspace;
-}

legacy-packages/workflow-agent-cursor/src/types.ts

@@ -1,11 +0,0 @@
-export type CursorAgentConfig = {
-  /** Absolute path to the cursor-agent CLI binary. */
-  command: string;
-  model: string | null;
-  timeout: number;
-  /**
-   * When non-null, use this workspace directory for `cursor-agent` instead of resolving it
-   * from the thread via runtime extraction.
-   */
-  workspace: string | null;
-};

legacy-packages/workflow-agent-cursor/tsconfig.json

@@ -1,14 +0,0 @@
-{
-  "extends": "../../tsconfig.json",
-  "compilerOptions": {
-    "rootDir": "src",
-    "outDir": "dist",
-    "composite": true
-  },
-  "include": ["src/**/*.ts"],
-  "references": [
-    { "path": "../workflow-cas" },
-    { "path": "../workflow-runtime" },
-    { "path": "../workflow-util-agent" }
-  ]
-}

legacy-packages/workflow-agent-docx-diff/__tests__/agent.test.ts

@@ -1,22 +0,0 @@
-import { describe, expect, test } from "bun:test";
-import { createDocxDiffAgent } from "../src/agent.js";
-import { packageDescriptor } from "../src/package-descriptor.js";
-
-describe("createDocxDiffAgent", () => {
-  test("returns an AdapterFn (function)", () => {
-    const agent = createDocxDiffAgent({ command: null });
-    expect(typeof agent).toBe("function");
-  });
-
-  test("AdapterFn returns a RoleFn (function)", () => {
-    const agent = createDocxDiffAgent({ command: null });
-    const roleFn = agent("", expect.anything() as never);
-    expect(typeof roleFn).toBe("function");
-  });
-});
-
-describe("packageDescriptor", () => {
-  test("has correct name", () => {
-    expect(packageDescriptor.name).toBe("@uncaged/workflow-agent-docx-diff");
-  });
-});

legacy-packages/workflow-agent-docx-diff/__tests__/runner.test.ts

@@ -1,118 +0,0 @@
-import { describe, expect, mock, test } from "bun:test";
-import { mkdirSync, writeFileSync } from "node:fs";
-import { tmpdir } from "node:os";
-import { join } from "node:path";
-import { err, ok } from "@uncaged/workflow-util";
-import type { SpawnCliConfig } from "@uncaged/workflow-util-agent";
-import { runDocxDiff } from "../src/runner.js";
-
-type MockSpawnResult = Awaited<ReturnType<typeof import("@uncaged/workflow-util-agent").spawnCli>>;
-
-function makeSpawn(result: MockSpawnResult) {
-  return mock(async (_cmd: string, _args: string[], _opts: SpawnCliConfig) => result);
-}
-
-function tempDir(): string {
-  const dir = join(tmpdir(), `diff-test-${Date.now()}`);
-  mkdirSync(dir, { recursive: true });
-  return dir;
-}
-
-describe("runDocxDiff", () => {
-  test("exit 0: success, returns DifferMeta JSON", async () => {
-    const dir = tempDir();
-    const sourceDocx = join(dir, "original.docx");
-    const modifiedDocx = join(dir, "modified.docx");
-    const diffDocx = join(dir, "diff.docx");
-    writeFileSync(sourceDocx, "");
-    writeFileSync(modifiedDocx, "");
-
-    const spawnFn = makeSpawn(ok("") as MockSpawnResult);
-    // simulate docx-diff creating the diff file
-    writeFileSync(diffDocx, "");
-
-    const raw = await runDocxDiff(
-      { command: "docx-diff" },
-      sourceDocx,
-      modifiedDocx,
-      diffDocx,
-      spawnFn,
-    );
-    const meta = JSON.parse(raw);
-    expect(meta.sourceDocx).toBe(sourceDocx);
-    expect(meta.modifiedDocx).toBe(modifiedDocx);
-    expect(meta.diffDocx).toBe(diffDocx);
-
-    expect(spawnFn.mock.calls[0][1]).toEqual([
-      sourceDocx,
-      modifiedDocx,
-      "--output",
-      "docx",
-      "--out-file",
-      diffDocx,
-    ]);
-  });
-
-  test("exit 1 (changes found): treated as success", async () => {
-    const dir = tempDir();
-    const sourceDocx = join(dir, "s.docx");
-    const modifiedDocx = join(dir, "m.docx");
-    const diffDocx = join(dir, "diff.docx");
-    writeFileSync(sourceDocx, "");
-    writeFileSync(modifiedDocx, "");
-    writeFileSync(diffDocx, "");
-
-    const spawnFn = makeSpawn(
-      err({ kind: "non_zero_exit", exitCode: 1, stdout: "", stderr: "" }) as MockSpawnResult,
-    );
-
-    await expect(
-      runDocxDiff({ command: "docx-diff" }, sourceDocx, modifiedDocx, diffDocx, spawnFn),
-    ).resolves.toBeDefined();
-  });
-
-  test("exit 2: throws error", async () => {
-    const dir = tempDir();
-    const spawnFn = makeSpawn(
-      err({
-        kind: "non_zero_exit",
-        exitCode: 2,
-        stdout: "",
-        stderr: "fatal error",
-      }) as MockSpawnResult,
-    );
-
-    await expect(
-      runDocxDiff({ command: null }, "s.docx", "m.docx", "diff.docx", spawnFn),
-    ).rejects.toThrow("docx-diff failed");
-  });
-
-  test("timeout: throws error", async () => {
-    const spawnFn = makeSpawn(err({ kind: "timeout" }) as MockSpawnResult);
-
-    await expect(
-      runDocxDiff({ command: null }, "s.docx", "m.docx", "diff.docx", spawnFn),
-    ).rejects.toThrow("timed out");
-  });
-
-  test("throws when diff file not created", async () => {
-    const dir = tempDir();
-    const spawnFn = makeSpawn(ok("") as MockSpawnResult);
-    // do NOT create diffDocx
-
-    await expect(
-      runDocxDiff({ command: null }, "s.docx", "m.docx", join(dir, "missing.docx"), spawnFn),
-    ).rejects.toThrow("diff file not found");
-  });
-
-  test("uses PATH docx-diff when command is null", async () => {
-    const dir = tempDir();
-    const diffDocx = join(dir, "diff.docx");
-    writeFileSync(diffDocx, "");
-    const spawnFn = makeSpawn(ok("") as MockSpawnResult);
-
-    await runDocxDiff({ command: null }, "s.docx", "m.docx", diffDocx, spawnFn);
-
-    expect(spawnFn.mock.calls[0][0]).toBe("docx-diff");
-  });
-});

legacy-packages/workflow-agent-docx-diff/package.json

@@ -1,33 +0,0 @@
-{
-  "name": "@uncaged/workflow-agent-docx-diff",
-  "version": "0.1.0",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "types": "src/index.ts",
-  "exports": {
-    ".": {
-      "bun": "./src/index.ts",
-      "types": "./dist/index.d.ts",
-      "import": "./dist/index.js"
-    }
-  },
-  "scripts": {
-    "test": "bun test"
-  },
-  "dependencies": {
-    "@uncaged/workflow-runtime": "workspace:^",
-    "@uncaged/workflow-util-agent": "workspace:^",
-    "@uncaged/workflow-template-document": "workspace:^",
-    "zod": "^4.0.0"
-  },
-  "devDependencies": {
-    "@uncaged/workflow-util": "workspace:^"
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/workflow-agent-docx-diff/src/agent.ts

@@ -1,28 +0,0 @@
-import { dirname, join } from "node:path";
-import type {
-  AdapterFn,
-  RoleResult,
-  ThreadContext,
-  WorkflowRuntime,
-} from "@uncaged/workflow-runtime";
-import type { WriterMeta } from "@uncaged/workflow-template-document";
-import type * as z from "zod/v4";
-import { runDocxDiff } from "./runner.js";
-import type { DocxDiffAgentConfig } from "./types.js";
-
-export function createDocxDiffAgent(config: DocxDiffAgentConfig): AdapterFn {
-  return <T>(_prompt: string, schema: z.ZodType<T>) =>
-    async (ctx: ThreadContext, _runtime: WorkflowRuntime): Promise<RoleResult<T>> => {
-      const writerStep = ctx.steps.find((s) => s.role === "writer");
-      if (writerStep === undefined) throw new Error("differ: no writer step found");
-
-      const writerMeta = writerStep.meta as WriterMeta;
-      if (writerMeta.mode !== "edit") throw new Error("differ: writer did not run in edit mode");
-
-      const diffDocx = join(dirname(writerMeta.outputDocx), "diff.docx");
-      const raw = await runDocxDiff(config, writerMeta.sourceDocx, writerMeta.outputDocx, diffDocx);
-
-      const meta = schema.parse(JSON.parse(raw)) as T;
-      return { meta, childThread: null };
-    };
-}

legacy-packages/workflow-agent-docx-diff/src/index.ts

@@ -1,3 +0,0 @@
-export { createDocxDiffAgent } from "./agent.js";
-export { packageDescriptor } from "./package-descriptor.js";
-export type { DocxDiffAgentConfig } from "./types.js";

legacy-packages/workflow-agent-docx-diff/src/package-descriptor.ts

@@ -1,17 +0,0 @@
-import type { PackageDescriptor } from "@uncaged/workflow-runtime";
-
-export const packageDescriptor: PackageDescriptor = {
-  name: "@uncaged/workflow-agent-docx-diff",
-  version: "0.1.0",
-  capabilities: ["docx-diff-cli", "docx-diff-report"],
-  configSchema: {
-    type: "object",
-    properties: {
-      command: {
-        anyOf: [{ type: "string" }, { type: "null" }],
-        description: "Path to docx-diff CLI binary; null uses PATH.",
-      },
-    },
-    additionalProperties: false,
-  },
-};

legacy-packages/workflow-agent-docx-diff/src/runner.ts

@@ -1,46 +0,0 @@
-import { stat } from "node:fs/promises";
-import type { SpawnCliError } from "@uncaged/workflow-util-agent";
-import { spawnCli } from "@uncaged/workflow-util-agent";
-import type { DocxDiffAgentConfig } from "./types.js";
-
-type SpawnCliFn = typeof spawnCli;
-
-function throwSpawnError(e: SpawnCliError): never {
-  if (e.kind === "non_zero_exit")
-    throw new Error(`docx-diff failed (exit ${e.exitCode}): ${e.stderr}`);
-  if (e.kind === "timeout") throw new Error("docx-diff: timed out");
-  throw new Error(`docx-diff: spawn failed: ${e.message}`);
-}
-
-export async function runDocxDiff(
-  config: DocxDiffAgentConfig,
-  sourceDocx: string,
-  modifiedDocx: string,
-  diffDocx: string,
-  spawnCliFn: SpawnCliFn = spawnCli,
-): Promise<string> {
-  const command = config.command ?? "docx-diff";
-  const result = await spawnCliFn(
-    command,
-    [sourceDocx, modifiedDocx, "--output", "docx", "--out-file", diffDocx],
-    { cwd: null, timeoutMs: null },
-  );
-
-  if (!result.ok) {
-    const e = result.error;
-    // exit 1 = changes found (normal for docx-diff)
-    if (e.kind === "non_zero_exit" && e.exitCode === 1) {
-      // fall through to file check
-    } else {
-      throwSpawnError(e);
-    }
-  }
-
-  try {
-    await stat(diffDocx);
-  } catch {
-    throw new Error(`docx-diff: diff file not found: ${diffDocx}`);
-  }
-
-  return JSON.stringify({ sourceDocx, modifiedDocx, diffDocx });
-}

legacy-packages/workflow-agent-docx-diff/src/types.ts

@@ -1,3 +0,0 @@
-export type DocxDiffAgentConfig = {
-  command: string | null;
-};

legacy-packages/workflow-agent-docx-diff/tsconfig.json

@@ -1,15 +0,0 @@
-{
-  "extends": "../../tsconfig.json",
-  "compilerOptions": {
-    "rootDir": "src",
-    "outDir": "dist",
-    "composite": true
-  },
-  "include": ["src/**/*.ts"],
-  "references": [
-    { "path": "../workflow-protocol" },
-    { "path": "../workflow-runtime" },
-    { "path": "../workflow-util-agent" },
-    { "path": "../workflow-template-document" }
-  ]
-}

legacy-packages/workflow-agent-hermes/CHANGELOG.md

@@ -1,81 +0,0 @@
-# @uncaged/workflow-agent-hermes
-
-## 0.5.0-alpha.4
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.4
-- @uncaged/workflow-util-agent@0.5.0-alpha.4
-
-## 0.5.0-alpha.3
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.3
-- @uncaged/workflow-util-agent@0.5.0-alpha.3
-
-## 0.5.0-alpha.2
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.2
-- @uncaged/workflow-util-agent@0.5.0-alpha.2
-
-## 0.5.0-alpha.1
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-util-agent@0.5.0-alpha.1
-  - @uncaged/workflow-runtime@0.5.0-alpha.1
-
-## 0.5.0-alpha.0
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.0
-- @uncaged/workflow-util-agent@0.5.0-alpha.0
-
-## 0.4.5
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.4.5
-- @uncaged/workflow-util-agent@0.4.5
-
-## 0.4.4
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.4.4
-- @uncaged/workflow-util-agent@0.4.4
-
-## 0.4.3
-
-### Patch Changes
-
-- Include src/ in published packages so bun runtime can resolve the 'bun' exports condition.
-- Updated dependencies
-  - @uncaged/workflow-runtime@0.4.3
-  - @uncaged/workflow-util-agent@0.4.3
-
-## 0.4.2
-
-### Patch Changes
-
-- Fix workspace dependency resolution: use workspace:^ so published packages resolve to compatible versions instead of exact (non-existent) versions.
-- Updated dependencies
-  - @uncaged/workflow-runtime@0.4.2
-  - @uncaged/workflow-util-agent@0.4.2
-
-## 0.4.0
-
-### Minor Changes
-
-- Fix package exports for published packages and adopt changesets for version management.
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-runtime@0.4.0
-  - @uncaged/workflow-util-agent@0.4.0

legacy-packages/workflow-agent-hermes/package.json

@@ -1,28 +0,0 @@
-{
-  "name": "@uncaged/workflow-agent-hermes",
-  "version": "0.5.0-alpha.4",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "types": "src/index.ts",
-  "scripts": {
-    "test": "bun test"
-  },
-  "dependencies": {
-    "@uncaged/workflow-runtime": "workspace:^",
-    "@uncaged/workflow-util-agent": "workspace:^"
-  },
-  "exports": {
-    ".": {
-      "bun": "./src/index.ts",
-      "types": "./dist/index.d.ts",
-      "import": "./dist/index.js"
-    }
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/workflow-agent-hermes/src/index.ts

@@ -1,72 +0,0 @@
-import type { AdapterFn, AgentFn } from "@uncaged/workflow-runtime";
-import {
-  buildThreadInput,
-  createAgentAdapter,
-  type SpawnCliError,
-  spawnCli,
-} from "@uncaged/workflow-util-agent";
-
-import type { HermesAgentConfig } from "./types.js";
-import { validateHermesAgentConfig } from "./validate-config.js";
-
-const HERMES_DEFAULT_MAX_TURNS = 90;
-
-type HermesAgentOpt = { prompt: string };
-
-export type { HermesAgentConfig } from "./types.js";
-export { validateHermesAgentConfig } from "./validate-config.js";
-
-function throwHermesSpawnError(error: SpawnCliError): never {
-  if (error.kind === "non_zero_exit") {
-    throw new Error(
-      `hermes: exitCode=${error.exitCode} stdout=${error.stdout} stderr=${error.stderr}`,
-    );
-  }
-  if (error.kind === "timeout") {
-    throw new Error("hermes: timeout");
-  }
-  if (error.kind === "spawn_failed") {
-    throw new Error(`hermes: ${error.message}`);
-  }
-  throw new Error("hermes: unknown spawn error");
-}
-
-function createHermesAgentFn(config: HermesAgentConfig): AgentFn<HermesAgentOpt> {
-  const timeoutMs = config.timeout;
-
-  return async (ctx, { prompt }) => {
-    const threadInput = await buildThreadInput(ctx);
-    const fullPrompt = `${prompt}\n\n${threadInput}`;
-    const args = [
-      "chat",
-      "-q",
-      fullPrompt,
-      "--yolo",
-      "--max-turns",
-      String(HERMES_DEFAULT_MAX_TURNS),
-      "--quiet",
-    ];
-    if (config.model !== null) {
-      args.push("--model", config.model);
-    }
-    const run = await spawnCli(config.command, args, {
-      cwd: null,
-      timeoutMs,
-    });
-    if (!run.ok) {
-      throwHermesSpawnError(run.error);
-    }
-    return run.value;
-  };
-}
-
-/** Runs `hermes chat` non-interactively with the Nerve-style argv contract (`-q`, `--yolo`, `--quiet`). */
-export function createHermesAgent(config: HermesAgentConfig): AdapterFn {
-  return createAgentAdapter(createHermesAgentFn(config), async (_ctx, prompt, _runtime) => {
-    const validated = validateHermesAgentConfig(config);
-    if (!validated.ok) {
-      throw new Error(validated.error);
-    }
-    return { prompt };
-  });
-}

legacy-packages/workflow-agent-hermes/src/types.ts

@@ -1,6 +0,0 @@
-export type HermesAgentConfig = {
-  /** Absolute path to the hermes CLI binary. */
-  command: string;
-  model: string | null;
-  timeout: number | null;
-};

legacy-packages/workflow-agent-llm/CHANGELOG.md

@@ -1,81 +0,0 @@
-# @uncaged/workflow-agent-llm
-
-## 0.5.0-alpha.4
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.4
-- @uncaged/workflow-util-agent@0.5.0-alpha.4
-
-## 0.5.0-alpha.3
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.3
-- @uncaged/workflow-util-agent@0.5.0-alpha.3
-
-## 0.5.0-alpha.2
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.2
-- @uncaged/workflow-util-agent@0.5.0-alpha.2
-
-## 0.5.0-alpha.1
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-util-agent@0.5.0-alpha.1
-  - @uncaged/workflow-runtime@0.5.0-alpha.1
-
-## 0.5.0-alpha.0
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.5.0-alpha.0
-- @uncaged/workflow-util-agent@0.5.0-alpha.0
-
-## 0.4.5
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.4.5
-- @uncaged/workflow-util-agent@0.4.5
-
-## 0.4.4
-
-### Patch Changes
-
-- @uncaged/workflow-runtime@0.4.4
-- @uncaged/workflow-util-agent@0.4.4
-
-## 0.4.3
-
-### Patch Changes
-
-- Include src/ in published packages so bun runtime can resolve the 'bun' exports condition.
-- Updated dependencies
-  - @uncaged/workflow-runtime@0.4.3
-  - @uncaged/workflow-util-agent@0.4.3
-
-## 0.4.2
-
-### Patch Changes
-
-- Fix workspace dependency resolution: use workspace:^ so published packages resolve to compatible versions instead of exact (non-existent) versions.
-- Updated dependencies
-  - @uncaged/workflow-runtime@0.4.2
-  - @uncaged/workflow-util-agent@0.4.2
-
-## 0.4.0
-
-### Minor Changes
-
-- Fix package exports for published packages and adopt changesets for version management.
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-runtime@0.4.0
-  - @uncaged/workflow-util-agent@0.4.0

legacy-packages/workflow-agent-llm/package.json

@@ -1,31 +0,0 @@
-{
-  "name": "@uncaged/workflow-agent-llm",
-  "version": "0.5.0-alpha.4",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "types": "src/index.ts",
-  "scripts": {
-    "test": "bun test"
-  },
-  "dependencies": {
-    "@uncaged/workflow-runtime": "workspace:^",
-    "@uncaged/workflow-util-agent": "workspace:^"
-  },
-  "devDependencies": {
-    "zod": "^4.0.0"
-  },
-  "exports": {
-    ".": {
-      "bun": "./src/index.ts",
-      "types": "./dist/index.d.ts",
-      "import": "./dist/index.js"
-    }
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/workflow-agent-office/__tests__/agent.test.ts

@@ -1,27 +0,0 @@
-import { describe, expect, test } from "bun:test";
-import { createOfficeAgent } from "../src/agent.js";
-import { packageDescriptor } from "../src/package-descriptor.js";
-
-describe("createOfficeAgent", () => {
-  test("returns an AdapterFn (function)", () => {
-    const agent = createOfficeAgent({ outputDir: "/tmp", command: null, timeout: null });
-    expect(typeof agent).toBe("function");
-  });
-
-  test("AdapterFn returns a RoleFn (function)", () => {
-    const agent = createOfficeAgent({ outputDir: "/tmp", command: null, timeout: null });
-    const roleFn = agent("", expect.anything() as never);
-    expect(typeof roleFn).toBe("function");
-  });
-});
-
-describe("packageDescriptor", () => {
-  test("has correct name", () => {
-    expect(packageDescriptor.name).toBe("@uncaged/workflow-agent-office");
-  });
-
-  test("has outputDir in configSchema required", () => {
-    const schema = packageDescriptor.configSchema as { required: string[] };
-    expect(schema.required).toContain("outputDir");
-  });
-});

legacy-packages/workflow-agent-office/__tests__/runner.test.ts

@@ -1,135 +0,0 @@
-import { describe, expect, mock, test } from "bun:test";
-import { mkdirSync, writeFileSync } from "node:fs";
-import { tmpdir } from "node:os";
-import { join } from "node:path";
-import { err, ok } from "@uncaged/workflow-util";
-import type { SpawnCliConfig } from "@uncaged/workflow-util-agent";
-import { editDocument, generateDocument } from "../src/runner.js";
-
-type MockSpawnResult = Awaited<ReturnType<typeof import("@uncaged/workflow-util-agent").spawnCli>>;
-
-function makeSpawn(result: MockSpawnResult) {
-  return mock(async (_cmd: string, _args: string[], _opts: SpawnCliConfig) => result);
-}
-
-function tempDir(): string {
-  const dir = join(tmpdir(), `office-test-${Date.now()}`);
-  mkdirSync(dir, { recursive: true });
-  return dir;
-}
-
-describe("generateDocument", () => {
-  test("calls office-agent create with correct args and returns outputDocx path", async () => {
-    const base = tempDir();
-    const spawnFn = makeSpawn(ok("agent reply") as MockSpawnResult);
-    // Simulate CLI creating the file
-    const outFile = join(base, "thread1", "output.docx");
-    mkdirSync(join(base, "thread1"), { recursive: true });
-    writeFileSync(outFile, "");
-
-    const result = await generateDocument(
-      { outputDir: base, command: "office-agent", timeout: null },
-      "thread1",
-      "Write a report",
-      spawnFn,
-    );
-
-    expect(result.outputDocx).toBe(outFile);
-    expect(result.sourceDocx).toBeNull();
-    expect(spawnFn.mock.calls[0][0]).toBe("office-agent");
-    expect(spawnFn.mock.calls[0][1]).toEqual(["create", "Write a report", "-o", "output.docx"]);
-    expect(spawnFn.mock.calls[0][2].cwd).toBe(join(base, "thread1"));
-  });
-
-  test("uses PATH office-agent when command is null", async () => {
-    const base = tempDir();
-    const spawnFn = makeSpawn(ok("") as MockSpawnResult);
-    mkdirSync(join(base, "t2"), { recursive: true });
-    writeFileSync(join(base, "t2", "output.docx"), "");
-
-    await generateDocument(
-      { outputDir: base, command: null, timeout: null },
-      "t2",
-      "Generate",
-      spawnFn,
-    );
-
-    expect(spawnFn.mock.calls[0][0]).toBe("office-agent");
-  });
-
-  test("throws on non_zero_exit", async () => {
-    const base = tempDir();
-    const spawnFn = makeSpawn(
-      err({ kind: "non_zero_exit", exitCode: 1, stdout: "", stderr: "error" }) as MockSpawnResult,
-    );
-
-    await expect(
-      generateDocument({ outputDir: base, command: null, timeout: null }, "t3", "fail", spawnFn),
-    ).rejects.toThrow("office-agent failed (exit 1)");
-  });
-
-  test("throws on timeout", async () => {
-    const base = tempDir();
-    const spawnFn = makeSpawn(err({ kind: "timeout" }) as MockSpawnResult);
-
-    await expect(
-      generateDocument({ outputDir: base, command: null, timeout: null }, "t4", "slow", spawnFn),
-    ).rejects.toThrow("office-agent: timed out");
-  });
-
-  test("throws when output file not created", async () => {
-    const base = tempDir();
-    const spawnFn = makeSpawn(ok("") as MockSpawnResult);
-    // Do NOT create output.docx
-
-    await expect(
-      generateDocument({ outputDir: base, command: null, timeout: null }, "t5", "no file", spawnFn),
-    ).rejects.toThrow("output file not found");
-  });
-});
-
-describe("editDocument", () => {
-  test("copies input to original.docx and modified.docx, calls edit, returns paths", async () => {
-    const base = tempDir();
-    // Create a fake inputDocx
-    const inputFile = join(base, "source.docx");
-    writeFileSync(inputFile, "original content");
-
-    const spawnFn = makeSpawn(ok("") as MockSpawnResult);
-    // Simulate CLI overwriting modified.docx
-    const outDir = join(base, "te1");
-    mkdirSync(outDir, { recursive: true });
-    writeFileSync(join(outDir, "modified.docx"), "modified content");
-
-    const result = await editDocument(
-      { outputDir: base, command: "office-agent", timeout: null },
-      "te1",
-      "Edit the doc",
-      inputFile,
-      spawnFn,
-    );
-
-    expect(result.outputDocx).toBe(join(outDir, "modified.docx"));
-    expect(result.sourceDocx).toBe(join(outDir, "original.docx"));
-    expect(spawnFn.mock.calls[0][1]).toEqual(["edit", "modified.docx", "Edit the doc"]);
-  });
-
-  test("throws on spawn_failed", async () => {
-    const base = tempDir();
-    const inputFile = join(base, "src.docx");
-    writeFileSync(inputFile, "");
-    const spawnFn = makeSpawn(
-      err({ kind: "spawn_failed", message: "not found" }) as MockSpawnResult,
-    );
-
-    await expect(
-      editDocument(
-        { outputDir: base, command: null, timeout: null },
-        "te2",
-        "edit",
-        inputFile,
-        spawnFn,
-      ),
-    ).rejects.toThrow("spawn failed");
-  });
-});

legacy-packages/workflow-agent-office/package.json

@@ -1,29 +0,0 @@
-{
-  "name": "@uncaged/workflow-agent-office",
-  "version": "0.1.0",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "types": "src/index.ts",
-  "exports": {
-    ".": {
-      "bun": "./src/index.ts",
-      "types": "./dist/index.d.ts",
-      "import": "./dist/index.js"
-    }
-  },
-  "scripts": {
-    "test": "bun test"
-  },
-  "dependencies": {
-    "@uncaged/workflow-runtime": "workspace:^",
-    "@uncaged/workflow-util": "workspace:^",
-    "@uncaged/workflow-util-agent": "workspace:^"
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/workflow-agent-office/src/agent.ts

@@ -1,56 +0,0 @@
-import type {
-  AdapterFn,
-  RoleResult,
-  ThreadContext,
-  WorkflowRuntime,
-} from "@uncaged/workflow-runtime";
-import { createLogger } from "@uncaged/workflow-util";
-import type * as z from "zod/v4";
-import { editDocument, generateDocument } from "./runner.js";
-import type { OfficeAgentConfig } from "./types.js";
-
-const log = createLogger({ sink: { kind: "stderr" } });
-
-type ParsedInput = { prompt: string; inputDocx: string | null };
-
-function parseStartInput(content: string): ParsedInput {
-  try {
-    const parsed = JSON.parse(content) as Record<string, unknown>;
-    if (typeof parsed.prompt === "string") {
-      return {
-        prompt: parsed.prompt,
-        inputDocx: typeof parsed.inputDocx === "string" ? parsed.inputDocx : null,
-      };
-    }
-  } catch {
-    // not JSON — treat whole content as prompt, generate mode
-  }
-  return { prompt: content, inputDocx: null };
-}
-
-export function createOfficeAgent(config: OfficeAgentConfig): AdapterFn {
-  return <T>(_systemPrompt: string, schema: z.ZodType<T>) =>
-    async (ctx: ThreadContext, _runtime: WorkflowRuntime): Promise<RoleResult<T>> => {
-      const { prompt, inputDocx } = parseStartInput(ctx.start.content);
-      log(
-        "8FQKP3NV",
-        `office-agent: mode=${inputDocx === null ? "generate" : "edit"} thread=${ctx.threadId}`,
-      );
-
-      let raw: string;
-      if (inputDocx === null) {
-        const result = await generateDocument(config, ctx.threadId, prompt);
-        raw = JSON.stringify({ mode: "generate", outputDocx: result.outputDocx, sourceDocx: null });
-      } else {
-        const result = await editDocument(config, ctx.threadId, prompt, inputDocx);
-        raw = JSON.stringify({
-          mode: "edit",
-          outputDocx: result.outputDocx,
-          sourceDocx: result.sourceDocx,
-        });
-      }
-
-      const meta = schema.parse(JSON.parse(raw)) as T;
-      return { meta, childThread: null };
-    };
-}

legacy-packages/workflow-agent-office/src/index.ts

@@ -1,3 +0,0 @@
-export { createOfficeAgent } from "./agent.js";
-export { packageDescriptor } from "./package-descriptor.js";
-export type { OfficeAgentConfig } from "./types.js";

legacy-packages/workflow-agent-office/src/package-descriptor.ts

@@ -1,26 +0,0 @@
-import type { PackageDescriptor } from "@uncaged/workflow-runtime";
-
-export const packageDescriptor: PackageDescriptor = {
-  name: "@uncaged/workflow-agent-office",
-  version: "0.1.0",
-  capabilities: ["office-agent-cli", "docx-generate", "docx-edit"],
-  configSchema: {
-    type: "object",
-    required: ["outputDir"],
-    properties: {
-      outputDir: {
-        type: "string",
-        description: "Root directory for workflow outputs; subdirs are created per threadId.",
-      },
-      command: {
-        anyOf: [{ type: "string" }, { type: "null" }],
-        description: "Path to office-agent CLI binary; null uses PATH.",
-      },
-      timeout: {
-        anyOf: [{ type: "number" }, { type: "null" }],
-        description: "Timeout in milliseconds; null means no limit.",
-      },
-    },
-    additionalProperties: false,
-  },
-};

legacy-packages/workflow-agent-office/src/runner.ts

@@ -1,64 +0,0 @@
-import { copyFile, mkdir, stat } from "node:fs/promises";
-import { join } from "node:path";
-import type { SpawnCliError } from "@uncaged/workflow-util-agent";
-import { spawnCli } from "@uncaged/workflow-util-agent";
-import type { OfficeAgentConfig } from "./types.js";
-
-type SpawnCliFn = typeof spawnCli;
-
-function throwSpawnError(e: SpawnCliError): never {
-  if (e.kind === "non_zero_exit")
-    throw new Error(`office-agent failed (exit ${e.exitCode}): ${e.stderr}`);
-  if (e.kind === "timeout") throw new Error("office-agent: timed out");
-  throw new Error(`office-agent: spawn failed: ${e.message}`);
-}
-
-async function assertFileExists(path: string): Promise<void> {
-  try {
-    await stat(path);
-  } catch {
-    throw new Error(`office-agent: output file not found: ${path}`);
-  }
-}
-
-export async function generateDocument(
-  config: OfficeAgentConfig,
-  threadId: string,
-  prompt: string,
-  spawnCliFn: SpawnCliFn = spawnCli,
-): Promise<{ outputDocx: string; sourceDocx: null }> {
-  const outputDir = join(config.outputDir, threadId);
-  await mkdir(outputDir, { recursive: true });
-  const command = config.command ?? "office-agent";
-  const result = await spawnCliFn(command, ["create", prompt, "-o", "output.docx"], {
-    cwd: outputDir,
-    timeoutMs: config.timeout,
-  });
-  if (!result.ok) throwSpawnError(result.error);
-  const outputDocx = join(outputDir, "output.docx");
-  await assertFileExists(outputDocx);
-  return { outputDocx, sourceDocx: null };
-}
-
-export async function editDocument(
-  config: OfficeAgentConfig,
-  threadId: string,
-  prompt: string,
-  inputDocx: string,
-  spawnCliFn: SpawnCliFn = spawnCli,
-): Promise<{ outputDocx: string; sourceDocx: string }> {
-  const outputDir = join(config.outputDir, threadId);
-  await mkdir(outputDir, { recursive: true });
-  const originalDocx = join(outputDir, "original.docx");
-  const modifiedDocx = join(outputDir, "modified.docx");
-  await copyFile(inputDocx, originalDocx);
-  await copyFile(inputDocx, modifiedDocx);
-  const command = config.command ?? "office-agent";
-  const result = await spawnCliFn(command, ["edit", "modified.docx", prompt], {
-    cwd: outputDir,
-    timeoutMs: config.timeout,
-  });
-  if (!result.ok) throwSpawnError(result.error);
-  await assertFileExists(modifiedDocx);
-  return { outputDocx: modifiedDocx, sourceDocx: originalDocx };
-}

legacy-packages/workflow-agent-office/src/types.ts

@@ -1,5 +0,0 @@
-export type OfficeAgentConfig = {
-  outputDir: string;
-  command: string | null;
-  timeout: number | null;
-};

legacy-packages/workflow-agent-office/tsconfig.json

@@ -1,15 +0,0 @@
-{
-  "extends": "../../tsconfig.json",
-  "compilerOptions": {
-    "rootDir": "src",
-    "outDir": "dist",
-    "composite": true
-  },
-  "include": ["src/**/*.ts"],
-  "references": [
-    { "path": "../workflow-protocol" },
-    { "path": "../workflow-runtime" },
-    { "path": "../workflow-util" },
-    { "path": "../workflow-util-agent" }
-  ]
-}

legacy-packages/workflow-agent-react/CHANGELOG.md

@@ -1,98 +0,0 @@
-# @uncaged/workflow-agent-react
-
-## 0.5.0-alpha.4
-
-### Patch Changes
-
-- Updated dependencies [f74b482]
-- Updated dependencies [f74b482]
-  - @uncaged/workflow-protocol@0.5.0-alpha.4
-  - @uncaged/workflow-reactor@0.5.0-alpha.4
-  - @uncaged/workflow-util-agent@0.5.0-alpha.4
-
-## 0.5.0-alpha.3
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.3
-  - @uncaged/workflow-reactor@0.5.0-alpha.3
-  - @uncaged/workflow-util-agent@0.5.0-alpha.3
-
-## 0.5.0-alpha.2
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.2
-  - @uncaged/workflow-reactor@0.5.0-alpha.2
-  - @uncaged/workflow-util-agent@0.5.0-alpha.2
-
-## 0.5.0-alpha.1
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-util-agent@0.5.0-alpha.1
-  - @uncaged/workflow-protocol@0.5.0-alpha.1
-  - @uncaged/workflow-reactor@0.5.0-alpha.1
-
-## 0.5.0-alpha.0
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.0
-  - @uncaged/workflow-reactor@0.5.0-alpha.0
-  - @uncaged/workflow-util-agent@0.5.0-alpha.0
-
-## 0.4.5
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.5
-  - @uncaged/workflow-reactor@0.4.5
-  - @uncaged/workflow-util-agent@0.4.5
-
-## 0.4.4
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.4
-  - @uncaged/workflow-reactor@0.4.4
-  - @uncaged/workflow-util-agent@0.4.4
-
-## 0.4.3
-
-### Patch Changes
-
-- Include src/ in published packages so bun runtime can resolve the 'bun' exports condition.
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.3
-  - @uncaged/workflow-reactor@0.4.3
-  - @uncaged/workflow-util-agent@0.4.3
-
-## 0.4.2
-
-### Patch Changes
-
-- Fix workspace dependency resolution: use workspace:^ so published packages resolve to compatible versions instead of exact (non-existent) versions.
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.2
-  - @uncaged/workflow-reactor@0.4.2
-  - @uncaged/workflow-util-agent@0.4.2
-
-## 0.4.0
-
-### Minor Changes
-
-- Fix package exports for published packages and adopt changesets for version management.
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.0
-  - @uncaged/workflow-reactor@0.4.0
-  - @uncaged/workflow-util-agent@0.4.0

legacy-packages/workflow-agent-react/__tests__/create-react-adapter.test.ts

@@ -1,211 +0,0 @@
-import { describe, expect, test } from "bun:test";
-import { ok, START, type ThreadContext, type WorkflowRuntime } from "@uncaged/workflow-protocol";
-import type { LlmFn, ToolDefinition } from "@uncaged/workflow-reactor";
-import * as z from "zod/v4";
-
-import { createReactAdapter } from "../src/create-react-adapter.js";
-import type { ReactAdapterConfig } from "../src/types.js";
-
-// ── Helpers ─────────────────────────────────────────────────────────
-
-function makeThread(prompt: string): ThreadContext {
-  return {
-    threadId: "01TEST000000000000000000TR",
-    depth: 0,
-    bundleHash: "TESTHASH00001",
-    start: {
-      role: START,
-      content: prompt,
-      meta: {},
-      timestamp: Date.now(),
-      parentState: null,
-    },
-    steps: [],
-  };
-}
-
-const STUB_RUNTIME: WorkflowRuntime = {
-  cas: {
-    put: async (_content: string) => "STUBHASH",
-    get: async (_hash: string) => null,
-    delete: async (_hash: string) => {},
-    list: async () => [],
-  },
-  extract: async (_schema, _contentHash) => ({
-    meta: {},
-    contentPayload: "",
-    refs: [],
-  }),
-};
-
-const TEST_SCHEMA = z
-  .object({
-    summary: z.string(),
-    score: z.number(),
-  })
-  .meta({ title: "resolve", description: "Submit the final result." });
-
-function makeChatResponse(content: string | null, toolCalls: unknown[] | null): string {
-  const message: Record<string, unknown> = { role: "assistant" };
-  if (content !== null) {
-    message.content = content;
-  }
-  if (toolCalls !== null) {
-    message.tool_calls = toolCalls;
-  }
-  return JSON.stringify({ choices: [{ message }] });
-}
-
-function makeToolCallResponse(name: string, args: Record<string, unknown>, id: string): string {
-  return makeChatResponse(null, [
-    {
-      id,
-      type: "function",
-      function: { name, arguments: JSON.stringify(args) },
-    },
-  ]);
-}
-
-// ── Tests ───────────────────────────────────────────────────────────
-
-describe("createReactAdapter", () => {
-  test("direct resolve: LLM immediately calls resolve tool with valid args", async () => {
-    const llm: LlmFn = async (_input) => {
-      return ok(makeToolCallResponse("resolve", { summary: "done", score: 42 }, "call_1"));
-    };
-
-    const config: ReactAdapterConfig = {
-      llm,
-      tools: [],
-      toolHandler: async () => "unused",
-      maxRounds: 5,
-    };
-
-    const adapter = createReactAdapter(config);
-    const roleFn = adapter("You are a test agent.", TEST_SCHEMA);
-    const result = await roleFn(makeThread("test task"), STUB_RUNTIME);
-
-    expect(result.meta).toEqual({ summary: "done", score: 42 });
-    expect(result.childThread).toBeNull();
-  });
-
-  test("tool call then resolve: LLM calls user tool first, then resolves", async () => {
-    let callCount = 0;
-    const llm: LlmFn = async (_input) => {
-      callCount += 1;
-      if (callCount === 1) {
-        return ok(makeToolCallResponse("search", { query: "test" }, "call_1"));
-      }
-      return ok(makeToolCallResponse("resolve", { summary: "found it", score: 99 }, "call_2"));
-    };
-
-    const searchTool: ToolDefinition = {
-      type: "function",
-      function: {
-        name: "search",
-        description: "Search for information",
-        parameters: {
-          type: "object",
-          properties: { query: { type: "string" } },
-          required: ["query"],
-        },
-      },
-    };
-
-    const toolResults: string[] = [];
-    const config: ReactAdapterConfig = {
-      llm,
-      tools: [searchTool],
-      toolHandler: async (name, args) => {
-        toolResults.push(`${name}:${args}`);
-        return "search result: found the answer";
-      },
-      maxRounds: 5,
-    };
-
-    const adapter = createReactAdapter(config);
-    const roleFn = adapter("You are a test agent.", TEST_SCHEMA);
-    const result = await roleFn(makeThread("test task"), STUB_RUNTIME);
-
-    expect(result.meta).toEqual({ summary: "found it", score: 99 });
-    expect(toolResults).toHaveLength(1);
-    expect(toolResults[0]).toContain("search:");
-  });
-
-  test("plain JSON response accepted", async () => {
-    const llm: LlmFn = async (_input) => {
-      return ok(makeChatResponse(JSON.stringify({ summary: "plain", score: 7 }), null));
-    };
-
-    const config: ReactAdapterConfig = {
-      llm,
-      tools: [],
-      toolHandler: async () => "unused",
-      maxRounds: 5,
-    };
-
-    const adapter = createReactAdapter(config);
-    const roleFn = adapter("You are a test agent.", TEST_SCHEMA);
-    const result = await roleFn(makeThread("test task"), STUB_RUNTIME);
-
-    expect(result.meta).toEqual({ summary: "plain", score: 7 });
-  });
-
-  test("schema validation failure + retry: invalid args then valid args", async () => {
-    let callCount = 0;
-    const llm: LlmFn = async (_input) => {
-      callCount += 1;
-      if (callCount === 1) {
-        // Invalid: score should be number, not string
-        return ok(
-          makeToolCallResponse("resolve", { summary: "bad", score: "not-a-number" }, "call_1"),
-        );
-      }
-      return ok(makeToolCallResponse("resolve", { summary: "fixed", score: 10 }, "call_2"));
-    };
-
-    const config: ReactAdapterConfig = {
-      llm,
-      tools: [],
-      toolHandler: async () => "unused",
-      maxRounds: 5,
-    };
-
-    const adapter = createReactAdapter(config);
-    const roleFn = adapter("You are a test agent.", TEST_SCHEMA);
-    const result = await roleFn(makeThread("test task"), STUB_RUNTIME);
-
-    expect(result.meta).toEqual({ summary: "fixed", score: 10 });
-    expect(callCount).toBe(2);
-  });
-
-  test("max rounds exceeded: throws error", async () => {
-    const searchTool: ToolDefinition = {
-      type: "function",
-      function: {
-        name: "search",
-        description: "Search",
-        parameters: { type: "object", properties: {}, required: [] },
-      },
-    };
-
-    const llm: LlmFn = async (_input) => {
-      // Always call search, never resolve
-      return ok(makeToolCallResponse("search", {}, "call_n"));
-    };
-
-    const config: ReactAdapterConfig = {
-      llm,
-      tools: [searchTool],
-      toolHandler: async () => "still searching...",
-      maxRounds: 3,
-    };
-
-    const adapter = createReactAdapter(config);
-    const roleFn = adapter("You are a test agent.", TEST_SCHEMA);
-
-    await expect(roleFn(makeThread("test task"), STUB_RUNTIME)).rejects.toThrow(
-      "max_react_rounds_exceeded",
-    );
-  });
-});

legacy-packages/workflow-agent-react/__tests__/tools.test.ts

@@ -1,121 +0,0 @@
-import { afterAll, describe, expect, test } from "bun:test";
-import { randomBytes } from "node:crypto";
-import { mkdirSync, readFileSync, unlinkSync } from "node:fs";
-import { tmpdir } from "node:os";
-import { join } from "node:path";
-import { patchFileTool, readFileTool, shellExecTool, writeFileTool } from "../src/tools/index.js";
-
-const TMP_DIR = join(tmpdir(), `tools-test-${randomBytes(4).toString("hex")}`);
-mkdirSync(TMP_DIR, { recursive: true });
-
-const tmpFile = (name: string) => join(TMP_DIR, name);
-
-const cleanupFiles: string[] = [];
-
-afterAll(() => {
-  for (const f of cleanupFiles) {
-    try {
-      unlinkSync(f);
-    } catch {
-      /* ignore */
-    }
-  }
-  try {
-    unlinkSync(TMP_DIR);
-  } catch {
-    /* ignore */
-  }
-});
-
-describe("read_file", () => {
-  test("reads file with line numbers", async () => {
-    const p = tmpFile("read-test.txt");
-    cleanupFiles.push(p);
-    const content = "line1\nline2\nline3\n";
-    require("node:fs").writeFileSync(p, content);
-
-    const result = await readFileTool.handler(
-      JSON.stringify({ path: p, offset: null, limit: null }),
-    );
-    expect(result).toContain("1|line1");
-    expect(result).toContain("2|line2");
-    expect(result).toContain("3|line3");
-  });
-
-  test("reads with offset and limit", async () => {
-    const p = tmpFile("read-test2.txt");
-    cleanupFiles.push(p);
-    require("node:fs").writeFileSync(p, "a\nb\nc\nd\ne\n");
-
-    const result = await readFileTool.handler(JSON.stringify({ path: p, offset: 2, limit: 2 }));
-    expect(result).toBe("2|b\n3|c");
-  });
-
-  test("returns error for missing file", async () => {
-    const result = await readFileTool.handler(
-      JSON.stringify({ path: "/nonexistent/file.txt", offset: null, limit: null }),
-    );
-    expect(result).toContain("Error:");
-  });
-});
-
-describe("write_file", () => {
-  test("writes file and creates dirs", async () => {
-    const p = tmpFile("sub/write-test.txt");
-    cleanupFiles.push(p);
-
-    const result = await writeFileTool.handler(JSON.stringify({ path: p, content: "hello world" }));
-    expect(result).toContain("11 bytes");
-    expect(readFileSync(p, "utf-8")).toBe("hello world");
-  });
-});
-
-describe("patch_file", () => {
-  test("patches file content", async () => {
-    const p = tmpFile("patch-test.txt");
-    cleanupFiles.push(p);
-    require("node:fs").writeFileSync(p, "foo bar baz");
-
-    const result = await patchFileTool.handler(
-      JSON.stringify({ path: p, old_string: "bar", new_string: "qux" }),
-    );
-    expect(result).toContain("Successfully");
-    expect(readFileSync(p, "utf-8")).toBe("foo qux baz");
-  });
-
-  test("errors on not found", async () => {
-    const p = tmpFile("patch-test2.txt");
-    cleanupFiles.push(p);
-    require("node:fs").writeFileSync(p, "foo");
-
-    const result = await patchFileTool.handler(
-      JSON.stringify({ path: p, old_string: "xyz", new_string: "abc" }),
-    );
-    expect(result).toContain("not found");
-  });
-
-  test("errors on non-unique match", async () => {
-    const p = tmpFile("patch-test3.txt");
-    cleanupFiles.push(p);
-    require("node:fs").writeFileSync(p, "aaa bbb aaa");
-
-    const result = await patchFileTool.handler(
-      JSON.stringify({ path: p, old_string: "aaa", new_string: "ccc" }),
-    );
-    expect(result).toContain("not unique");
-  });
-});
-
-describe("shell_exec", () => {
-  test("runs echo", async () => {
-    const result = await shellExecTool.handler(
-      JSON.stringify({ command: "echo hello", timeout: null }),
-    );
-    expect(result.trim()).toBe("hello");
-  });
-
-  test("handles timeout", async () => {
-    const result = await shellExecTool.handler(JSON.stringify({ command: "sleep 10", timeout: 1 }));
-    expect(result).toContain("timed out");
-  });
-});

legacy-packages/workflow-agent-react/package.json

@@ -1,35 +0,0 @@
-{
-  "name": "@uncaged/workflow-agent-react",
-  "version": "0.5.0-alpha.4",
-  "files": [
-    "src",
-    "dist",
-    "package.json"
-  ],
-  "type": "module",
-  "types": "src/index.ts",
-  "exports": {
-    ".": {
-      "bun": "./src/index.ts",
-      "types": "./dist/index.d.ts",
-      "import": "./dist/index.js"
-    }
-  },
-  "scripts": {
-    "test": "bun test"
-  },
-  "dependencies": {
-    "@uncaged/workflow-protocol": "workspace:^",
-    "@uncaged/workflow-reactor": "workspace:^",
-    "@uncaged/workflow-util-agent": "workspace:^"
-  },
-  "devDependencies": {
-    "zod": "^4.0.0"
-  },
-  "peerDependencies": {
-    "zod": "^4.0.0"
-  },
-  "publishConfig": {
-    "access": "public"
-  }
-}

legacy-packages/workflow-agent-react/src/create-react-adapter.ts

@@ -1,69 +0,0 @@
-import type {
-  AdapterFn,
-  RoleResult,
-  ThreadContext,
-  WorkflowRuntime,
-} from "@uncaged/workflow-protocol";
-import { createThreadReactor } from "@uncaged/workflow-reactor";
-import { buildThreadInput } from "@uncaged/workflow-util-agent";
-import * as z from "zod/v4";
-
-import type { ReactAdapterConfig } from "./types.js";
-
-function stripJsonSchemaMeta(json: Record<string, unknown>): Record<string, unknown> {
-  const { $schema: _drop, ...rest } = json;
-  return rest;
-}
-
-function readToolName(parametersSchema: Record<string, unknown>): string {
-  const title = parametersSchema.title;
-  if (typeof title === "string" && title.trim().length > 0) {
-    return title.trim();
-  }
-  return "resolve";
-}
-
-function readToolDescription(parametersSchema: Record<string, unknown>): string {
-  const d = parametersSchema.description;
-  if (typeof d === "string" && d.trim().length > 0) {
-    return d.trim();
-  }
-  return "Submit the final structured result.";
-}
-
-export function createReactAdapter(config: ReactAdapterConfig): AdapterFn {
-  return <T>(prompt: string, schema: z.ZodType<T>) => {
-    const reactor = createThreadReactor<ThreadContext>({
-      llm: config.llm,
-      staticTools: config.tools,
-      structuredToolFromSchema: (s) => {
-        const rawJsonSchema = z.toJSONSchema(s) as Record<string, unknown>;
-        const parameters = stripJsonSchemaMeta(rawJsonSchema);
-        const name = readToolName(parameters);
-        return {
-          name,
-          tool: {
-            type: "function" as const,
-            function: {
-              name,
-              description: readToolDescription(parameters),
-              parameters,
-            },
-          },
-        };
-      },
-      systemPromptForStructuredTool: (_name) => prompt,
-      toolHandler: async (call, _thread) => {
-        return config.toolHandler(call.function.name, call.function.arguments);
-      },
-      maxRounds: config.maxRounds,
-    });
-
-    return async (ctx: ThreadContext, _runtime: WorkflowRuntime): Promise<RoleResult<T>> => {
-      const input = await buildThreadInput(ctx);
-      const result = await reactor({ thread: ctx, input, schema });
-      if (!result.ok) throw new Error(result.error);
-      return { meta: result.value, childThread: null };
-    };
-  };
-}

legacy-packages/workflow-agent-react/src/index.ts

@@ -1,4 +0,0 @@
-export { createReactAdapter } from "./create-react-adapter.js";
-export type { ToolEntry, ToolHandler } from "./tools/index.js";
-export { defaultToolHandler, defaultTools } from "./tools/index.js";
-export type { ReactAdapterConfig, ReactToolHandler } from "./types.js";

legacy-packages/workflow-agent-react/src/tools/defaults.ts

@@ -1,16 +0,0 @@
-import type { ToolDefinition } from "@uncaged/workflow-reactor";
-import { patchFileTool } from "./patch-file.js";
-import { readFileTool } from "./read-file.js";
-import { shellExecTool } from "./shell-exec.js";
-import type { ToolEntry } from "./types.js";
-import { writeFileTool } from "./write-file.js";
-
-const ALL_TOOLS: ToolEntry[] = [readFileTool, writeFileTool, patchFileTool, shellExecTool];
-
-export const defaultTools: readonly ToolDefinition[] = ALL_TOOLS.map((t) => t.definition);
-
-export async function defaultToolHandler(name: string, args: string): Promise<string> {
-  const entry = ALL_TOOLS.find((t) => t.definition.function.name === name);
-  if (!entry) return `Unknown tool: ${name}`;
-  return entry.handler(args);
-}

legacy-packages/workflow-agent-react/src/tools/index.ts

@@ -1,6 +0,0 @@
-export { defaultToolHandler, defaultTools } from "./defaults.js";
-export { patchFileTool } from "./patch-file.js";
-export { readFileTool } from "./read-file.js";
-export { shellExecTool } from "./shell-exec.js";
-export type { ToolEntry, ToolHandler } from "./types.js";
-export { writeFileTool } from "./write-file.js";

legacy-packages/workflow-agent-react/src/tools/patch-file.ts

@@ -1,43 +0,0 @@
-import { readFile, writeFile } from "node:fs/promises";
-import type { ToolEntry } from "./types.js";
-
-export const patchFileTool: ToolEntry = {
-  definition: {
-    type: "function",
-    function: {
-      name: "patch_file",
-      description: "Find and replace a string in a file (first occurrence only).",
-      parameters: {
-        type: "object",
-        properties: {
-          path: { type: "string", description: "Path to the file" },
-          old_string: { type: "string", description: "Text to find" },
-          new_string: { type: "string", description: "Replacement text" },
-        },
-        required: ["path", "old_string", "new_string"],
-      },
-    },
-  },
-  handler: async (args: string): Promise<string> => {
-    try {
-      const parsed = JSON.parse(args) as { path: string; old_string: string; new_string: string };
-      const content = await readFile(parsed.path, "utf-8");
-      const firstIdx = content.indexOf(parsed.old_string);
-      if (firstIdx === -1) {
-        return `Error: old_string not found in ${parsed.path}`;
-      }
-      const secondIdx = content.indexOf(parsed.old_string, firstIdx + 1);
-      if (secondIdx !== -1) {
-        return `Error: old_string is not unique in ${parsed.path} (found multiple occurrences)`;
-      }
-      const updated =
-        content.slice(0, firstIdx) +
-        parsed.new_string +
-        content.slice(firstIdx + parsed.old_string.length);
-      await writeFile(parsed.path, updated);
-      return `Successfully patched ${parsed.path}`;
-    } catch (err) {
-      return `Error: ${err instanceof Error ? err.message : String(err)}`;
-    }
-  },
-};

legacy-packages/workflow-agent-react/src/tools/read-file.ts

@@ -1,43 +0,0 @@
-import { readFile } from "node:fs/promises";
-import type { ToolEntry } from "./types.js";
-
-export const readFileTool: ToolEntry = {
-  definition: {
-    type: "function",
-    function: {
-      name: "read_file",
-      description: "Read a text file and return lines with line numbers.",
-      parameters: {
-        type: "object",
-        properties: {
-          path: { type: "string", description: "Path to the file to read" },
-          offset: {
-            type: ["number", "null"],
-            description: "Start line number (1-indexed, default: 1)",
-          },
-          limit: { type: ["number", "null"], description: "Max lines to read (default: all)" },
-        },
-        required: ["path"],
-      },
-    },
-  },
-  handler: async (args: string): Promise<string> => {
-    try {
-      const parsed = JSON.parse(args) as {
-        path: string;
-        offset: number | null;
-        limit: number | null;
-      };
-      const content = await readFile(parsed.path, "utf-8");
-      const allLines = content.split("\n");
-      const offset = parsed.offset ?? 1;
-      const start = Math.max(0, offset - 1);
-      const end =
-        parsed.limit != null ? Math.min(allLines.length, start + parsed.limit) : allLines.length;
-      const lines = allLines.slice(start, end);
-      return lines.map((line, i) => `${start + i + 1}|${line}`).join("\n");
-    } catch (err) {
-      return `Error: ${err instanceof Error ? err.message : String(err)}`;
-    }
-  },
-};

legacy-packages/workflow-agent-react/src/tools/shell-exec.ts

@@ -1,58 +0,0 @@
-import { execSync } from "node:child_process";
-import type { ToolEntry } from "./types.js";
-
-const MAX_OUTPUT = 10000;
-
-function truncate(text: string): string {
-  return text.length > MAX_OUTPUT ? `${text.slice(0, MAX_OUTPUT)}\n...(truncated)` : text;
-}
-
-function classifyExecError(err: unknown): string {
-  if (
-    err &&
-    typeof err === "object" &&
-    "status" in err &&
-    (err as { status: unknown }).status === null
-  ) {
-    return "Error: command timed out";
-  }
-  if (err && typeof err === "object" && "stderr" in err) {
-    const e = err as { stderr: string; stdout: string; status: number };
-    const combined = `${e.stdout ?? ""}${e.stderr ?? ""}`;
-    return truncate(combined) || `Error: command exited with status ${e.status}`;
-  }
-  return `Error: ${err instanceof Error ? err.message : String(err)}`;
-}
-
-export const shellExecTool: ToolEntry = {
-  definition: {
-    type: "function",
-    function: {
-      name: "shell_exec",
-      description: "Execute a shell command and return stdout + stderr.",
-      parameters: {
-        type: "object",
-        properties: {
-          command: { type: "string", description: "Shell command to run" },
-          timeout: { type: ["number", "null"], description: "Timeout in seconds (default: 30)" },
-        },
-        required: ["command"],
-      },
-    },
-  },
-  handler: async (args: string): Promise<string> => {
-    try {
-      const parsed = JSON.parse(args) as { command: string; timeout: number | null };
-      const timeoutMs = (parsed.timeout ?? 30) * 1000;
-      const output = execSync(parsed.command, {
-        encoding: "utf-8",
-        timeout: timeoutMs,
-        stdio: ["pipe", "pipe", "pipe"],
-        maxBuffer: MAX_OUTPUT * 2,
-      });
-      return truncate(output);
-    } catch (err: unknown) {
-      return classifyExecError(err);
-    }
-  },
-};

legacy-packages/workflow-agent-react/src/tools/types.ts

@@ -1,8 +0,0 @@
-import type { ToolDefinition } from "@uncaged/workflow-reactor";
-
-export type ToolHandler = (args: string) => Promise<string>;
-
-export type ToolEntry = {
-  definition: ToolDefinition;
-  handler: ToolHandler;
-};

legacy-packages/workflow-agent-react/src/tools/write-file.ts

@@ -1,32 +0,0 @@
-import { mkdir, writeFile } from "node:fs/promises";
-import { dirname } from "node:path";
-import type { ToolEntry } from "./types.js";
-
-export const writeFileTool: ToolEntry = {
-  definition: {
-    type: "function",
-    function: {
-      name: "write_file",
-      description: "Write content to a file, creating parent directories as needed.",
-      parameters: {
-        type: "object",
-        properties: {
-          path: { type: "string", description: "Path to write" },
-          content: { type: "string", description: "File content" },
-        },
-        required: ["path", "content"],
-      },
-    },
-  },
-  handler: async (args: string): Promise<string> => {
-    try {
-      const parsed = JSON.parse(args) as { path: string; content: string };
-      await mkdir(dirname(parsed.path), { recursive: true });
-      const buf = Buffer.from(parsed.content, "utf-8");
-      await writeFile(parsed.path, buf);
-      return `Successfully wrote ${buf.length} bytes to ${parsed.path}`;
-    } catch (err) {
-      return `Error: ${err instanceof Error ? err.message : String(err)}`;
-    }
-  },
-};

legacy-packages/workflow-agent-react/src/types.ts

@@ -1,10 +0,0 @@
-import type { LlmFn, ToolDefinition } from "@uncaged/workflow-reactor";
-
-export type ReactToolHandler = (name: string, args: string) => Promise<string>;
-
-export type ReactAdapterConfig = {
-  llm: LlmFn;
-  tools: readonly ToolDefinition[];
-  toolHandler: ReactToolHandler;
-  maxRounds: number;
-};

legacy-packages/workflow-agent-react/tsconfig.json

@@ -1,14 +0,0 @@
-{
-  "extends": "../../tsconfig.json",
-  "compilerOptions": {
-    "rootDir": "src",
-    "outDir": "dist",
-    "composite": true
-  },
-  "include": ["src/**/*.ts"],
-  "references": [
-    { "path": "../workflow-protocol" },
-    { "path": "../workflow-reactor" },
-    { "path": "../workflow-util-agent" }
-  ]
-}

legacy-packages/workflow-cas/CHANGELOG.md

@@ -1,88 +0,0 @@
-# @uncaged/workflow-cas
-
-## 0.5.0-alpha.4
-
-### Patch Changes
-
-- Updated dependencies
-- Updated dependencies [f74b482]
-- Updated dependencies [f74b482]
-  - @uncaged/workflow-util@0.5.0-alpha.4
-  - @uncaged/workflow-protocol@0.5.0-alpha.4
-
-## 0.5.0-alpha.3
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.3
-  - @uncaged/workflow-util@0.5.0-alpha.3
-
-## 0.5.0-alpha.2
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.2
-  - @uncaged/workflow-util@0.5.0-alpha.2
-
-## 0.5.0-alpha.1
-
-### Patch Changes
-
-- @uncaged/workflow-protocol@0.5.0-alpha.1
-- @uncaged/workflow-util@0.5.0-alpha.1
-
-## 0.5.0-alpha.0
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.5.0-alpha.0
-  - @uncaged/workflow-util@0.5.0-alpha.0
-
-## 0.4.5
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.5
-  - @uncaged/workflow-util@0.4.5
-
-## 0.4.4
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.4
-  - @uncaged/workflow-util@0.4.4
-
-## 0.4.3
-
-### Patch Changes
-
-- Include src/ in published packages so bun runtime can resolve the 'bun' exports condition.
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.3
-  - @uncaged/workflow-util@0.4.3
-
-## 0.4.2
-
-### Patch Changes
-
-- Fix workspace dependency resolution: use workspace:^ so published packages resolve to compatible versions instead of exact (non-existent) versions.
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.2
-  - @uncaged/workflow-util@0.4.2
-
-## 0.4.0
-
-### Minor Changes
-
-- Fix package exports for published packages and adopt changesets for version management.
-
-### Patch Changes
-
-- Updated dependencies
-  - @uncaged/workflow-protocol@0.4.0
-  - @uncaged/workflow-util@0.4.0

legacy-packages/workflow-cas/src/index.ts

@@ -1,16 +0,0 @@
-export { createCasStore } from "./cas.js";
-export { hashWorkflowBundleBytes } from "./hash.js";
-export {
-  createContentMerkleNode,
-  getContentMerklePayload,
-  putContentMerkleNode,
-  serializeMerkleNode,
-} from "./merkle.js";
-export {
-  parseCasThreadNode,
-  putContentNodeWithRefs,
-  putStartNode,
-  putStateNode,
-} from "./nodes.js";
-export { findReachableHashes } from "./reachable.js";
-export type { CasStore } from "./types.js";

legacy-packages/workflow-dashboard/index.html

@@ -1,20 +0,0 @@
-<!doctype html>
-<html lang="en">
-  <head>
-    <meta charset="UTF-8" />
-    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
-    <title>Workflow Dashboard</title>
-    <script>
-      (() => {
-        var t = localStorage.getItem("theme");
-        if (t === "dark" || (!t && matchMedia("(prefers-color-scheme: dark)").matches)) {
-          document.documentElement.classList.add("dark");
-        }
-      })();
-    </script>
-  </head>
-  <body>
-    <div id="root"></div>
-    <script type="module" src="/src/main.tsx"></script>
-  </body>
-</html>

legacy-packages/workflow-dashboard/package.json

@@ -1,43 +0,0 @@
-{
-  "name": "@uncaged/workflow-dashboard",
-  "version": "0.1.0",
-  "files": [
-    "dist",
-    "package.json"
-  ],
-  "private": true,
-  "type": "module",
-  "scripts": {
-    "dev": "vite",
-    "build": "vite build",
-    "preview": "vite preview"
-  },
-  "dependencies": {
-    "@radix-ui/react-collapsible": "^1.1.12",
-    "@radix-ui/react-dialog": "^1.1.15",
-    "@radix-ui/react-scroll-area": "^1.2.10",
-    "@radix-ui/react-select": "^2.2.6",
-    "@radix-ui/react-separator": "^1.1.8",
-    "@radix-ui/react-slot": "^1.2.4",
-    "@radix-ui/react-tooltip": "^1.2.8",
-    "@xyflow/react": "^12.10.2",
-    "class-variance-authority": "^0.7.1",
-    "clsx": "^2.1.1",
-    "lucide-react": "^1.16.0",
-    "react": "^19.2.6",
-    "react-dom": "^19.2.6",
-    "react-markdown": "^10.1.0",
-    "react-router": "^7.15.1",
-    "shiki": "^4.0.2",
-    "tailwind-merge": "^3.6.0"
-  },
-  "devDependencies": {
-    "@tailwindcss/vite": "^4.2.4",
-    "@types/react": "^19.2.14",
-    "@types/react-dom": "^19.2.3",
-    "@vitejs/plugin-react": "^6.0.1",
-    "tailwindcss": "^4.2.4",
-    "typescript": "^6.0.3",
-    "vite": "^8.0.11"
-  }
-}

legacy-packages/workflow-dashboard/plugins/vite-limit-line-plugin.ts

@@ -1,372 +0,0 @@
-import { createFilter, type Plugin } from "vite";
-
-type LimitLineOverride = {
-  files: string;
-  maxReactFCLines: number | null;
-  maxFileLines: number | null;
-};
-
-type LimitLineOptions = {
-  maxReactFCLines: number;
-  maxFileLines: number;
-  include: RegExp;
-  exclude: RegExp | null;
-  overrides: Array<LimitLineOverride>;
-};
-
-const DEFAULT_OPTIONS: LimitLineOptions = {
-  maxReactFCLines: 300,
-  maxFileLines: 600,
-  include: /\.[tj]sx$/,
-  exclude: null,
-  overrides: [],
-};
-
-type ResolvedLimits = {
-  maxReactFCLines: number | null;
-  maxFileLines: number | null;
-};
-
-type ComponentInfo = {
-  name: string;
-  startLine: number;
-  lineCount: number;
-};
-
-const PASCAL_CASE = /^[A-Z][A-Za-z0-9]*$/;
-
-// --- AST types (Rolldown ESTree subset) ---
-
-type Identifier = {
-  type: "Identifier";
-  name: string;
-};
-
-type MemberExpression = {
-  type: "MemberExpression";
-  object: AstExpression;
-  property: Identifier;
-};
-
-type CallExpression = {
-  type: "CallExpression";
-  callee: AstExpression;
-  arguments: Array<AstExpression>;
-};
-
-type AstExpression =
-  | Identifier
-  | MemberExpression
-  | CallExpression
-  | {
-      type: string;
-      [key: string]: unknown;
-    };
-
-type VariableDeclarator = {
-  id: Identifier | null;
-  init: AstExpression | null;
-};
-
-type AstStatement = {
-  type: string;
-  id: Identifier | null;
-  declaration: AstStatement | null;
-  declarations: Array<VariableDeclarator>;
-  body: Array<AstStatement>;
-  [key: string]: unknown;
-};
-
-type AstProgram = {
-  type: "Program";
-  body: Array<AstStatement>;
-};
-
-// --- AST helpers ---
-
-function isFunctionLike(node: AstExpression): boolean {
-  return node.type === "ArrowFunctionExpression" || node.type === "FunctionExpression";
-}
-
-const WRAPPER_NAMES = new Set(["memo", "forwardRef", "lazy"]);
-
-function isWrapperCall(node: AstExpression): boolean {
-  if (node.type !== "CallExpression") return false;
-  const call = node as CallExpression;
-  const callee = call.callee;
-
-  if (callee.type === "Identifier") {
-    return WRAPPER_NAMES.has((callee as Identifier).name);
-  }
-
-  if (callee.type === "MemberExpression") {
-    const member = callee as MemberExpression;
-    return member.property.type === "Identifier" && WRAPPER_NAMES.has(member.property.name);
-  }
-
-  return false;
-}
-
-function extractComponentNames(ast: AstProgram): Array<string> {
-  const names: Array<string> = [];
-
-  for (const node of ast.body) {
-    if (node.type === "FunctionDeclaration" && node.id && PASCAL_CASE.test(node.id.name)) {
-      names.push(node.id.name);
-      continue;
-    }
-
-    if (node.type === "ExportNamedDeclaration" && node.declaration) {
-      const decl = node.declaration;
-      if (decl.type === "FunctionDeclaration" && decl.id && PASCAL_CASE.test(decl.id.name)) {
-        names.push(decl.id.name);
-        continue;
-      }
-      if (decl.type === "VariableDeclaration") {
-        collectNamesFromVarDeclaration(decl, names);
-        continue;
-      }
-    }
-
-    if (node.type === "VariableDeclaration") {
-      collectNamesFromVarDeclaration(node, names);
-    }
-  }
-
-  return names;
-}
-
-function collectNamesFromVarDeclaration(node: AstStatement, names: Array<string>): void {
-  for (const declarator of node.declarations ?? []) {
-    if (!declarator.id || !PASCAL_CASE.test(declarator.id.name) || !declarator.init) continue;
-    const init = declarator.init;
-    if (isFunctionLike(init)) {
-      names.push(declarator.id.name);
-    } else if (isWrapperCall(init)) {
-      const args = (init as CallExpression).arguments;
-      if (args.length > 0 && isFunctionLike(args[0])) {
-        names.push(declarator.id.name);
-      }
-    }
-  }
-}
-
-// --- Source measurement ---
-
-function measureComponentInSource(name: string, lines: Array<string>): ComponentInfo | null {
-  const fnPattern = new RegExp(`^(?:export\\s+)?function\\s+${name}\\s*[(<]`);
-  const varPattern = new RegExp(`^(?:export\\s+)?const\\s+${name}\\s*[=:]`);
-
-  for (let i = 0; i < lines.length; i++) {
-    const trimmed = lines[i].trimStart();
-    const isFnDecl = fnPattern.test(trimmed);
-    const isVarDecl = varPattern.test(trimmed);
-    if (!isFnDecl && !isVarDecl) continue;
-
-    if (isFnDecl) {
-      const result = measureFromParams(i, lines);
-      if (result) return { ...result, name };
-      return null;
-    }
-    const result = measureFromArrow(i, lines);
-    if (result) return { ...result, name };
-    return null;
-  }
-
-  return null;
-}
-
-// function Foo(...) { ... } — skip params via parens, then brace-match the body
-function measureFromParams(startLine: number, lines: Array<string>): ComponentInfo | null {
-  let parenDepth = 0;
-  let pastParams = false;
-  let braceDepth = 0;
-
-  for (let j = startLine; j < lines.length; j++) {
-    for (const ch of lines[j]) {
-      if (!pastParams) {
-        if (ch === "(") parenDepth++;
-        else if (ch === ")") {
-          parenDepth--;
-          if (parenDepth === 0) pastParams = true;
-        }
-      } else {
-        if (ch === "{") braceDepth++;
-        else if (ch === "}") {
-          braceDepth--;
-          if (braceDepth === 0) {
-            return { name: "", startLine: startLine + 1, lineCount: j - startLine + 1 };
-          }
-        }
-      }
-    }
-  }
-
-  return null;
-}
-
-// const Foo = (...) => { ... } / const Foo = memo((...) => { ... })
-// Find `=>` first, then brace-match from there to skip type annotations in params
-function measureFromArrow(startLine: number, lines: Array<string>): ComponentInfo | null {
-  let arrowFound = false;
-  let braceDepth = 0;
-  let foundBrace = false;
-
-  for (let j = startLine; j < lines.length; j++) {
-    const line = lines[j];
-    for (let c = 0; c < line.length; c++) {
-      if (!arrowFound) {
-        if (line[c] === "=" && line[c + 1] === ">") {
-          arrowFound = true;
-          c++;
-        }
-        continue;
-      }
-      if (line[c] === "{") {
-        braceDepth++;
-        foundBrace = true;
-      } else if (line[c] === "}") {
-        braceDepth--;
-        if (foundBrace && braceDepth === 0) {
-          return { name: "", startLine: startLine + 1, lineCount: j - startLine + 1 };
-        }
-      }
-    }
-  }
-
-  return null;
-}
-
-// --- Config resolution ---
-
-function createLimitResolver(options: LimitLineOptions): (id: string) => ResolvedLimits {
-  const matchers = options.overrides.map((override) => ({
-    match: createFilter(override.files),
-    maxReactFCLines: override.maxReactFCLines,
-    maxFileLines: override.maxFileLines,
-  }));
-
-  return (id: string): ResolvedLimits => {
-    let maxReactFCLines: number | null = options.maxReactFCLines;
-    let maxFileLines: number | null = options.maxFileLines;
-
-    for (const matcher of matchers) {
-      if (matcher.match(id)) {
-        maxReactFCLines = matcher.maxReactFCLines;
-        maxFileLines = matcher.maxFileLines;
-      }
-    }
-
-    return { maxReactFCLines, maxFileLines };
-  };
-}
-
-function shouldProcess(id: string, options: LimitLineOptions): boolean {
-  return (
-    options.include.test(id) &&
-    !id.includes("node_modules") &&
-    (options.exclude === null || !options.exclude.test(id))
-  );
-}
-
-// --- Plugin ---
-
-function viteLimitLinePlugin(userOptions: Partial<LimitLineOptions> = {}): Array<Plugin> {
-  const options: LimitLineOptions = {
-    ...DEFAULT_OPTIONS,
-    ...userOptions,
-    overrides: userOptions.overrides ?? [],
-  };
-  const resolve = createLimitResolver(options);
-
-  const rawCodeCache = new Map<string, string>();
-
-  return [
-    {
-      name: "vite-plugin-limit-line:pre",
-      enforce: "pre",
-
-      transform(code, id) {
-        if (!shouldProcess(id, options)) return null;
-
-        rawCodeCache.set(id, code);
-
-        const limits = resolve(id);
-        if (limits.maxFileLines === null) return null;
-
-        const totalLines = code.split("\n").length;
-        if (totalLines > limits.maxFileLines) {
-          this.error(
-            [
-              `[vite-limit-line] File too long: ${totalLines} lines (limit: ${limits.maxFileLines})`,
-              `  file: ${id}`,
-              "",
-              "How to fix:",
-              "  Split this file into smaller modules — extract related types, helpers,",
-              "  or sub-components into separate files and re-export from an index.ts.",
-            ].join("\n"),
-          );
-        }
-
-        return null;
-      },
-    },
-    {
-      name: "vite-plugin-limit-line:fc",
-
-      transform(code, id) {
-        if (!shouldProcess(id, options)) return null;
-
-        const limits = resolve(id);
-        if (limits.maxReactFCLines === null) return null;
-
-        const ast = this.parse(code) as unknown as AstProgram;
-        const componentNames = extractComponentNames(ast);
-        if (componentNames.length === 0) return null;
-
-        const raw = rawCodeCache.get(id) ?? code;
-        rawCodeCache.delete(id);
-        const rawLines = raw.split("\n");
-
-        const maxFCLines = limits.maxReactFCLines;
-        const violations: Array<ComponentInfo> = [];
-        for (const name of componentNames) {
-          const info = measureComponentInSource(name, rawLines);
-          if (info && info.lineCount > maxFCLines) {
-            violations.push(info);
-          }
-        }
-
-        if (violations.length > 0) {
-          const details = violations
-            .map(
-              (v) =>
-                `  ${v.name} (line ${v.startLine}): ${v.lineCount} lines (limit: ${maxFCLines})`,
-            )
-            .join("\n");
-
-          this.error(
-            [
-              `[vite-limit-line] React component too long in ${id}:`,
-              details,
-              "",
-              "How to fix:",
-              "  Break each oversized component into smaller ones. Extract reusable",
-              "  sections into child components, move complex logic into custom hooks,",
-              "  and keep each component focused on a single responsibility.",
-            ].join("\n"),
-          );
-        }
-
-        return null;
-      },
-
-      buildEnd() {
-        rawCodeCache.clear();
-      },
-    },
-  ];
-}
-
-export type { LimitLineOptions, LimitLineOverride };
-export { viteLimitLinePlugin };

legacy-packages/workflow-dashboard/src/app.tsx

@@ -1,38 +0,0 @@
-import { useState } from "react";
-import { Navigate, Outlet, useParams } from "react-router";
-import { clearApiKey, hasApiKey } from "./api.ts";
-import { RunDialog } from "./components/run-dialog.tsx";
-import { Sidebar } from "./components/sidebar.tsx";
-import { StatusBar } from "./components/status-bar.tsx";
-import { useTheme } from "./hooks/use-theme.tsx";
-
-export function Layout() {
-  const [authed, setAuthed] = useState(hasApiKey());
-  const { client } = useParams();
-  const [showRun, setShowRun] = useState(false);
-  const { theme, toggleTheme } = useTheme();
-
-  if (!authed) {
-    return <Navigate to="/login" replace />;
-  }
-
-  return (
-    <div className="flex h-screen bg-background">
-      <Sidebar
-        onLogout={() => {
-          clearApiKey();
-          setAuthed(false);
-        }}
-        theme={theme}
-        onToggleTheme={toggleTheme}
-      />
-      <main className="flex-1 overflow-hidden flex flex-col">
-        <StatusBar client={client ?? null} onRun={() => setShowRun(true)} />
-        <div className="flex-1 overflow-auto p-6">
-          <Outlet />
-        </div>
-      </main>
-      {client && <RunDialog client={client} open={showRun} onOpenChange={setShowRun} />}
-    </div>
-  );
-}

legacy-packages/workflow-dashboard/src/components/client-redirect.tsx

@@ -1,31 +0,0 @@
-import { Loader2, Users } from "lucide-react";
-import { Navigate } from "react-router";
-import { listClients } from "../api.ts";
-import { useFetch } from "../hooks.ts";
-
-export function ClientRedirect() {
-  const { status, data } = useFetch(() => listClients(), []);
-
-  if (status === "loading") {
-    return (
-      <div className="flex flex-col items-center justify-center h-full gap-3">
-        <Loader2 className="h-6 w-6 animate-spin text-muted-foreground" />
-        <p className="text-sm text-muted-foreground">Loading clients...</p>
-      </div>
-    );
-  }
-
-  if (status === "ok" && data.length > 0) {
-    return <Navigate to={`/${data[0].name}/threads`} replace />;
-  }
-
-  return (
-    <div className="flex flex-col items-center justify-center h-full gap-3">
-      <Users className="h-12 w-12 text-muted-foreground/50" />
-      <p className="text-sm font-medium">No client selected</p>
-      <p className="text-xs text-muted-foreground">
-        Select a client from the sidebar to get started.
-      </p>
-    </div>
-  );
-}

legacy-packages/workflow-dashboard/src/components/login.tsx

@@ -1,101 +0,0 @@
-import { AlertCircle, Loader2, Moon, Settings, Sun } from "lucide-react";
-import { useState } from "react";
-import { useNavigate } from "react-router";
-import { setApiKey } from "../api.ts";
-import { useTheme } from "../hooks/use-theme.tsx";
-import { Button } from "./ui/button.tsx";
-import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "./ui/card.tsx";
-import { Input } from "./ui/input.tsx";
-
-export function LoginPage() {
-  const navigate = useNavigate();
-  const [key, setKey] = useState("");
-  const [error, setError] = useState<string | null>(null);
-  const [loading, setLoading] = useState(false);
-  const { theme, toggleTheme } = useTheme();
-
-  async function handleSubmit(e: React.FormEvent) {
-    e.preventDefault();
-    if (!key.trim()) return;
-
-    setLoading(true);
-    setError(null);
-
-    const gatewayUrl = import.meta.env.VITE_GATEWAY_URL || "";
-    try {
-      const res = await fetch(`${gatewayUrl}/api/gateway/endpoints`, {
-        headers: { Authorization: `Bearer ${key.trim()}` },
-      });
-      if (res.status === 401) {
-        setError("Invalid API key");
-        setLoading(false);
-        return;
-      }
-      if (!res.ok) {
-        setError(`Server error: ${res.status}`);
-        setLoading(false);
-        return;
-      }
-    } catch (err) {
-      setError(`Connection failed: ${err instanceof Error ? err.message : String(err)}`);
-      setLoading(false);
-      return;
-    }
-
-    setApiKey(key.trim());
-    navigate("/", { replace: true });
-  }
-
-  return (
-    <div className="min-h-screen flex items-center justify-center bg-background relative">
-      <Button
-        variant="ghost"
-        size="icon"
-        className="absolute top-4 right-4 transition-colors duration-200"
-        onClick={toggleTheme}
-      >
-        {theme === "dark" ? <Sun className="h-5 w-5" /> : <Moon className="h-5 w-5" />}
-      </Button>
-      <Card className="w-full max-w-sm shadow-lg transition-all duration-200 hover:shadow-xl hover:border-primary/30">
-        <CardHeader>
-          <CardTitle className="flex items-center gap-2 text-xl tracking-tight">
-            <Settings className="h-5 w-5" />
-            Workflow Dashboard
-          </CardTitle>
-          <CardDescription>Enter your API key to continue</CardDescription>
-        </CardHeader>
-        <CardContent>
-          <form onSubmit={handleSubmit} className="space-y-4">
-            <Input
-              type="password"
-              value={key}
-              onChange={(e) => setKey(e.target.value)}
-              placeholder="API Key"
-              className="transition-all duration-200"
-            />
-            {error && (
-              <p className="text-xs text-destructive flex items-center gap-1.5">
-                <AlertCircle className="h-3.5 w-3.5 shrink-0" />
-                {error}
-              </p>
-            )}
-            <Button
-              type="submit"
-              disabled={loading || !key.trim()}
-              className="w-full transition-all duration-200"
-            >
-              {loading ? (
-                <span className="flex items-center gap-2">
-                  <Loader2 className="h-4 w-4 animate-spin" />
-                  Verifying…
-                </span>
-              ) : (
-                "Login"
-              )}
-            </Button>
-          </form>
-        </CardContent>
-      </Card>
-    </div>
-  );
-}

legacy-packages/workflow-dashboard/src/components/record-card.tsx

@@ -1,130 +0,0 @@
-import { CheckCircle2, Clock, MessageSquare, Rocket, User, XCircle } from "lucide-react";
-import type { RoleRecord, ThreadRecord, ThreadStartRecord, WorkflowResultRecord } from "../api.ts";
-import { cn } from "../lib/utils.ts";
-import { Markdown } from "./markdown.tsx";
-import { Badge } from "./ui/badge.tsx";
-import { Card } from "./ui/card.tsx";
-
-const ROLE_HUES = [262, 210, 35, 150, 330, 180, 15, 280, 55, 195, 345, 120, 240, 75, 305];
-
-function roleHue(role: string): number {
-  let hash = 0;
-  for (let i = 0; i < role.length; i++) {
-    hash = (hash * 31 + role.charCodeAt(i)) | 0;
-  }
-  return ROLE_HUES[Math.abs(hash) % ROLE_HUES.length];
-}
-
-function roleBadgeStyle(role: string): { backgroundColor: string; borderColor: string } {
-  const hue = roleHue(role);
-  return {
-    backgroundColor: `oklch(0.58 0.12 ${hue} / 0.85)`,
-    borderColor: `oklch(0.58 0.12 ${hue} / 0.25)`,
-  };
-}
-
-function formatTime(ts: number | null): string | null {
-  if (ts === null) return null;
-  return new Date(ts).toLocaleTimeString();
-}
-
-function StartCard({ record }: { record: ThreadStartRecord }) {
-  return (
-    <Card className="p-4 transition-all duration-200 overflow-hidden relative">
-      <div className="absolute inset-x-0 top-0 h-0.5 bg-gradient-to-r from-primary/80 via-primary/40 to-transparent" />
-      <div className="flex items-center gap-2 mb-2">
-        <Rocket className="h-5 w-5 text-primary" />
-        <span className="font-semibold text-foreground">{record.workflow}</span>
-        <Badge variant={record.status === "active" ? "success" : "secondary"}>
-          {record.status}
-        </Badge>
-      </div>
-      {record.prompt !== null && (
-        <div className="mt-2 p-3 rounded-md text-sm border-l-2 border-ring bg-muted/50">
-          <div className="text-xs mb-1 text-muted-foreground flex items-center gap-1">
-            <MessageSquare className="h-3 w-3" />
-            Prompt
-          </div>
-          <Markdown content={record.prompt} />
-        </div>
-      )}
-    </Card>
-  );
-}
-
-function RoleMessage({ record, highlighted }: { record: RoleRecord; highlighted: boolean }) {
-  const style = roleBadgeStyle(record.role);
-  return (
-    <Card
-      className={cn(
-        "p-3 text-sm transition-all duration-200 border-l-4",
-        highlighted && "wf-record-card-highlight",
-      )}
-      style={{ borderLeftColor: style.borderColor }}
-    >
-      <div className="flex items-center gap-2 mb-2">
-        <span
-          className="text-xs px-2 py-0.5 rounded font-mono font-medium text-white shadow-sm inline-flex items-center gap-1"
-          style={{ backgroundColor: style.backgroundColor }}
-        >
-          <User className="h-3 w-3" />
-          {record.role}
-        </span>
-        {formatTime(record.timestamp) !== null && (
-          <span className="text-xs ml-auto text-muted-foreground tabular-nums flex items-center gap-1">
-            <Clock className="h-3 w-3" />
-            {formatTime(record.timestamp)}
-          </span>
-        )}
-      </div>
-      <Markdown content={record.content} />
-    </Card>
-  );
-}
-
-function ResultCard({ record }: { record: WorkflowResultRecord }) {
-  const success = record.returnCode === 0;
-  return (
-    <Card
-      className={cn(
-        "p-4 transition-all duration-200 border-l-4",
-        success ? "border-l-success" : "border-l-destructive",
-      )}
-    >
-      <div className="flex items-center gap-2 mb-2">
-        {success ? (
-          <CheckCircle2 className="h-5 w-5 text-success" />
-        ) : (
-          <XCircle className="h-5 w-5 text-destructive" />
-        )}
-        <span className="font-semibold text-sm">{success ? "Completed" : "Failed"}</span>
-        <Badge variant="outline" className="font-mono">
-          exit {record.returnCode}
-        </Badge>
-        {formatTime(record.timestamp) !== null && (
-          <span className="text-xs ml-auto text-muted-foreground tabular-nums flex items-center gap-1">
-            <Clock className="h-3 w-3" />
-            {formatTime(record.timestamp)}
-          </span>
-        )}
-      </div>
-      <Markdown content={record.content} />
-    </Card>
-  );
-}
-
-type RecordCardProps = {
-  record: ThreadRecord;
-  highlighted: boolean;
-};
-
-export function RecordCard({ record, highlighted }: RecordCardProps) {
-  switch (record.type) {
-    case "thread-start":
-      return <StartCard record={record} />;
-    case "role":
-      return <RoleMessage record={record} highlighted={highlighted} />;
-    case "workflow-result":
-      return <ResultCard record={record} />;
-  }
-}

legacy-packages/workflow-dashboard/src/components/run-dialog.tsx

@@ -1,97 +0,0 @@
-import { useState } from "react";
-import { useNavigate } from "react-router";
-import { listWorkflows, runThread } from "../api.ts";
-import { useFetch } from "../hooks.ts";
-import { Button } from "./ui/button.tsx";
-import {
-  Dialog,
-  DialogContent,
-  DialogDescription,
-  DialogFooter,
-  DialogHeader,
-  DialogTitle,
-} from "./ui/dialog.tsx";
-import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from "./ui/select.tsx";
-import { Textarea } from "./ui/textarea.tsx";
-
-type Props = {
-  client: string;
-  open: boolean;
-  onOpenChange: (open: boolean) => void;
-};
-
-export function RunDialog({ client, open, onOpenChange }: Props) {
-  const navigate = useNavigate();
-  const workflows = useFetch(() => listWorkflows(client), [client]);
-  const [workflow, setWorkflow] = useState("");
-  const [prompt, setPrompt] = useState("");
-  const [submitting, setSubmitting] = useState(false);
-  const [error, setError] = useState<string | null>(null);
-
-  async function handleSubmit(e: React.FormEvent) {
-    e.preventDefault();
-    if (!workflow || !prompt) return;
-    setSubmitting(true);
-    setError(null);
-    try {
-      const result = await runThread(client, workflow, prompt);
-      onOpenChange(false);
-      navigate(`/${client}/threads/${result.threadId}`);
-    } catch (err) {
-      setError(err instanceof Error ? err.message : String(err));
-      setSubmitting(false);
-    }
-  }
-
-  return (
-    <Dialog open={open} onOpenChange={onOpenChange}>
-      <DialogContent>
-        <DialogHeader>
-          <DialogTitle>Run Thread</DialogTitle>
-          <DialogDescription>Start a new thread on {client}</DialogDescription>
-        </DialogHeader>
-        <form onSubmit={handleSubmit} className="space-y-4">
-          <div>
-            <label htmlFor="run-workflow" className="text-sm block mb-1.5 text-muted-foreground">
-              Workflow
-            </label>
-            <Select value={workflow} onValueChange={setWorkflow}>
-              <SelectTrigger>
-                <SelectValue placeholder="Select a workflow..." />
-              </SelectTrigger>
-              <SelectContent>
-                {workflows.status === "ok" &&
-                  workflows.data.workflows.map((w) => (
-                    <SelectItem key={w.name} value={w.name}>
-                      {w.name}
-                    </SelectItem>
-                  ))}
-              </SelectContent>
-            </Select>
-          </div>
-          <div>
-            <label htmlFor="run-prompt" className="text-sm block mb-1.5 text-muted-foreground">
-              Prompt
-            </label>
-            <Textarea
-              id="run-prompt"
-              value={prompt}
-              onChange={(e) => setPrompt(e.target.value)}
-              rows={4}
-              placeholder="Enter the task prompt..."
-            />
-          </div>
-          {error && <p className="text-sm text-destructive">{error}</p>}
-          <DialogFooter>
-            <Button type="button" variant="outline" onClick={() => onOpenChange(false)}>
-              Cancel
-            </Button>
-            <Button type="submit" disabled={submitting || !workflow || !prompt}>
-              {submitting ? "Starting..." : "Run"}
-            </Button>
-          </DialogFooter>
-        </form>
-      </DialogContent>
-    </Dialog>
-  );
-}

legacy-packages/workflow-dashboard/src/components/sidebar.tsx

@@ -1,132 +0,0 @@
-import { Loader2, LogOut, Moon, Package, Sun, Zap } from "lucide-react";
-import { useLocation, useNavigate, useParams } from "react-router";
-import type { ClientEndpoint } from "../api.ts";
-import { listClients } from "../api.ts";
-import { useFetch } from "../hooks.ts";
-import { cn } from "../lib/utils.ts";
-import { Button } from "./ui/button.tsx";
-import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from "./ui/select.tsx";
-import { Separator } from "./ui/separator.tsx";
-
-type Props = {
-  onLogout: () => void;
-  theme: "light" | "dark";
-  onToggleTheme: () => void;
-};
-
-export function Sidebar({ onLogout, theme, onToggleTheme }: Props) {
-  const { client } = useParams();
-  const navigate = useNavigate();
-  const location = useLocation();
-  const { status, data } = useFetch(() => listClients(), []);
-
-  const clients: ClientEndpoint[] = status === "ok" ? data : [];
-
-  const view = location.pathname.includes("/workflows") ? "workflows" : "threads";
-
-  const viewItems = [
-    { key: "threads" as const, label: "Threads", icon: Zap },
-    { key: "workflows" as const, label: "Workflows", icon: Package },
-  ];
-
-  return (
-    <aside className="w-56 border-r border-border flex flex-col bg-sidebar">
-      <div className="p-4 border-b border-primary/20">
-        <h1 className="text-xl font-bold text-foreground tracking-tight">Workflow</h1>
-        <p className="text-xs text-muted-foreground mt-0.5 tracking-wide uppercase">Dashboard</p>
-      </div>
-
-      <div className="px-3 py-3">
-        <label
-          className="block text-xs font-medium mb-1.5 text-muted-foreground"
-          htmlFor="client-select"
-        >
-          Client
-        </label>
-        {status === "loading" ? (
-          <div className="h-9 rounded-md border border-input bg-transparent px-3 py-2 text-xs text-muted-foreground flex items-center gap-2">
-            <Loader2 className="h-3.5 w-3.5 animate-spin" />
-            Loading…
-          </div>
-        ) : clients.length === 0 ? (
-          <div className="h-9 rounded-md border border-input bg-transparent px-3 py-2 text-xs text-muted-foreground flex items-center">
-            No clients online
-          </div>
-        ) : (
-          <Select
-            value={client ?? ""}
-            onValueChange={(name) => {
-              if (name) navigate(`/${name}/${view}`);
-            }}
-          >
-            <SelectTrigger className="h-8 text-xs transition-colors duration-200">
-              <SelectValue placeholder="Select client…" />
-            </SelectTrigger>
-            <SelectContent>
-              {clients.map((a) => (
-                <SelectItem key={a.name} value={a.name} className="text-xs">
-                  <span className="flex items-center gap-2">
-                    <span
-                      className={cn(
-                        "inline-block h-2 w-2 rounded-full",
-                        a.status === "online" ? "bg-success animate-pulse" : "bg-destructive",
-                      )}
-                    />
-                    {a.name}
-                  </span>
-                </SelectItem>
-              ))}
-            </SelectContent>
-          </Select>
-        )}
-      </div>
-
-      <Separator />
-
-      <nav className="flex-1 p-2 space-y-1">
-        {viewItems.map((item) => (
-          <Button
-            key={item.key}
-            variant={view === item.key ? "secondary" : "ghost"}
-            size="sm"
-            className={cn(
-              "w-full justify-start gap-2 transition-colors duration-200",
-              view === item.key
-                ? "text-foreground border-l-2 border-primary rounded-l-none"
-                : "text-muted-foreground hover:text-foreground",
-            )}
-            onClick={() => {
-              if (client) navigate(`/${client}/${item.key}`);
-            }}
-          >
-            <item.icon className="h-4 w-4" />
-            {item.label}
-          </Button>
-        ))}
-      </nav>
-
-      <Separator />
-
-      <div className="p-2 space-y-1">
-        <Button
-          variant="ghost"
-          size="sm"
-          className="w-full justify-start gap-2 text-muted-foreground hover:text-foreground transition-colors duration-200"
-          onClick={onToggleTheme}
-        >
-          {theme === "dark" ? <Sun className="h-4 w-4" /> : <Moon className="h-4 w-4" />}
-          {theme === "dark" ? "Light mode" : "Dark mode"}
-        </Button>
-        <Button
-          variant="ghost"
-          size="sm"
-          className="w-full justify-start gap-2 text-muted-foreground hover:text-foreground transition-colors duration-200"
-          onClick={onLogout}
-        >
-          <LogOut className="h-4 w-4" />
-          Logout
-        </Button>
-      </div>
-    </aside>
-  );
-}

legacy-packages/workflow-dashboard/src/components/status-bar.tsx

@@ -1,88 +0,0 @@
-import { Loader2, Play, Wifi, WifiOff } from "lucide-react";
-import { useCallback, useEffect, useRef, useState } from "react";
-import { getClientHealth } from "../api.ts";
-import { Button } from "./ui/button.tsx";
-
-type HealthStatus = "connected" | "disconnected" | "reconnecting";
-
-type Props = {
-  client: string | null;
-  onRun: () => void;
-};
-
-function StatusIndicator({ status }: { status: HealthStatus }) {
-  if (status === "connected") {
-    return (
-      <span className="flex items-center gap-1.5 text-xs text-success transition-colors duration-200">
-        <Wifi className="h-3.5 w-3.5" />
-        Connected
-      </span>
-    );
-  }
-  if (status === "reconnecting") {
-    return (
-      <span className="flex items-center gap-1.5 text-xs text-warning transition-colors duration-200">
-        <Loader2 className="h-3.5 w-3.5 animate-spin" />
-        Reconnecting…
-      </span>
-    );
-  }
-  return (
-    <span className="flex items-center gap-1.5 text-xs text-destructive transition-colors duration-200">
-      <WifiOff className="h-3.5 w-3.5" />
-      Offline
-    </span>
-  );
-}
-
-export function StatusBar({ client, onRun }: Props) {
-  const [status, setStatus] = useState<HealthStatus>("disconnected");
-  const wasConnectedRef = useRef(false);
-
-  const checkHealth = useCallback(async () => {
-    if (!client) {
-      setStatus("disconnected");
-      return;
-    }
-    try {
-      await getClientHealth(client);
-      wasConnectedRef.current = true;
-      setStatus("connected");
-    } catch {
-      if (wasConnectedRef.current) {
-        setStatus("reconnecting");
-      } else {
-        setStatus("disconnected");
-      }
-    }
-  }, [client]);
-
-  useEffect(() => {
-    wasConnectedRef.current = false;
-    setStatus("disconnected");
-    checkHealth();
-    const interval = setInterval(checkHealth, 10_000);
-    return () => clearInterval(interval);
-  }, [checkHealth]);
-
-  return (
-    <div className="flex items-center justify-between px-6 py-2 text-xs border-b border-border bg-card/80 backdrop-blur-sm">
-      <div className="flex items-center gap-4">
-        <span className="text-muted-foreground">
-          {client ? `Client: ${client}` : "No client selected"}
-        </span>
-        <Button
-          variant="default"
-          size="sm"
-          disabled={!client}
-          onClick={onRun}
-          className="h-7 gap-1.5 transition-all duration-200"
-        >
-          <Play className="h-3.5 w-3.5" />
-          Run Thread
-        </Button>
-      </div>
-      <StatusIndicator status={status} />
-    </div>
-  );
-}

legacy-packages/workflow-dashboard/src/components/thread-detail.tsx

@@ -1,308 +0,0 @@
-import { AlertCircle, ArrowLeft, Layers, Loader2, Pause, Play, X } from "lucide-react";
-import { useCallback, useEffect, useMemo, useRef, useState } from "react";
-import { useNavigate, useParams } from "react-router";
-import {
-  getThread,
-  getWorkflowDescriptor,
-  killThread,
-  pauseThread,
-  resumeThread,
-  type ThreadRecord,
-  type WorkflowDescriptor,
-} from "../api.ts";
-import { useFetch } from "../hooks.ts";
-import { useSSE } from "../use-sse.ts";
-import { RecordCard } from "./record-card.tsx";
-import { Badge } from "./ui/badge.tsx";
-import { Button } from "./ui/button.tsx";
-import { Card } from "./ui/card.tsx";
-import { ResizablePanel } from "./ui/resizable-panel.tsx";
-import { type NodeState, WorkflowGraph } from "./workflow-graph/index.ts";
-
-function extractWorkflowName(records: readonly ThreadRecord[]): string | null {
-  for (const r of records) {
-    if (r.type === "thread-start") return r.workflow;
-  }
-  return null;
-}
-
-function computeNodeStates(records: readonly ThreadRecord[]): Map<string, NodeState> {
-  const states = new Map<string, NodeState>();
-  const roleRecords = records.filter(
-    (r): r is Extract<ThreadRecord, { type: "role" }> => r.type === "role",
-  );
-  const hasResult = records.some((r) => r.type === "workflow-result");
-
-  for (let i = 0; i < roleRecords.length; i++) {
-    const role = roleRecords[i].role;
-    const isLast = i === roleRecords.length - 1;
-    states.set(role, !hasResult && isLast ? "active" : "completed");
-  }
-
-  const hasStart = records.some((r) => r.type === "thread-start");
-  if (hasStart) {
-    states.set("__start__", "completed");
-  }
-  if (hasResult) {
-    states.set("__end__", "completed");
-    for (const [k, v] of states) {
-      if (v === "active") states.set(k, "completed");
-    }
-  }
-
-  return states;
-}
-
-export function ThreadDetail() {
-  const params = useParams();
-  const navigate = useNavigate();
-  const client = params.client as string;
-  const threadId = params.threadId as string;
-  const sse = useSSE(client, threadId);
-  const { status, data, error } = useFetch(() => getThread(client, threadId), [client, threadId]);
-  const [actionStatus, setActionStatus] = useState<string | null>(null);
-  const recordsEndRef = useRef<HTMLDivElement>(null);
-  const firstCardByRoleRef = useRef<Map<string, HTMLDivElement>>(new Map());
-  const highlightTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [highlightedRole, setHighlightedRole] = useState<string | null>(null);
-
-  const liveActive = sse.connected && !sse.completed;
-  const records = liveActive
-    ? sse.records
-    : status === "ok"
-      ? data.records
-      : ([] as typeof sse.records);
-
-  const workflowName = useMemo(() => extractWorkflowName(records), [records]);
-
-  const descriptorFetch = useFetch<WorkflowDescriptor | null>(
-    () =>
-      workflowName === null ? Promise.resolve(null) : getWorkflowDescriptor(client, workflowName),
-    [client, workflowName],
-  );
-
-  const descriptor = descriptorFetch.status === "ok" ? descriptorFetch.data : null;
-  const nodeStates = useMemo(() => computeNodeStates(records), [records]);
-
-  const indicesByRole = useMemo(() => {
-    const m = new Map<string, number[]>();
-    for (let i = 0; i < records.length; i++) {
-      const r = records[i];
-      if (r.type === "role") {
-        const list = m.get(r.role) ?? [];
-        list.push(i);
-        m.set(r.role, list);
-      }
-    }
-    return m;
-  }, [records]);
-
-  const clickCycleRef = useRef<Map<string, number>>(new Map());
-
-  const handleGraphNodeClick = useCallback(
-    (nodeId: string) => {
-      if (nodeStates.get(nodeId) === undefined || nodeStates.get(nodeId) === "default") return;
-
-      if (nodeId === "__start__") {
-        const firstCard = document.querySelector('[data-record-index="0"]');
-        if (firstCard !== null) firstCard.scrollIntoView({ behavior: "smooth", block: "center" });
-        return;
-      }
-
-      if (nodeId === "__end__") {
-        recordsEndRef.current?.scrollIntoView({ behavior: "smooth", block: "end" });
-        return;
-      }
-
-      const indices = indicesByRole.get(nodeId);
-      if (indices === undefined || indices.length === 0) return;
-
-      const cycle = clickCycleRef.current.get(nodeId) ?? 0;
-      const idx = indices[cycle % indices.length];
-      clickCycleRef.current.set(nodeId, cycle + 1);
-
-      const el = document.querySelector(`[data-record-index="${idx}"]`);
-      if (el !== null) {
-        el.scrollIntoView({ behavior: "smooth", block: "center" });
-        if (highlightTimerRef.current !== null) clearTimeout(highlightTimerRef.current);
-        setHighlightedRole(nodeId);
-        highlightTimerRef.current = setTimeout(() => {
-          setHighlightedRole(null);
-          highlightTimerRef.current = null;
-        }, 1500);
-      }
-    },
-    [nodeStates, indicesByRole],
-  );
-
-  useEffect(() => {
-    return () => {
-      if (highlightTimerRef.current !== null) clearTimeout(highlightTimerRef.current);
-    };
-  }, []);
-
-  // biome-ignore lint/correctness/useExhaustiveDependencies: scroll when the rendered record list grows
-  useEffect(() => {
-    recordsEndRef.current?.scrollIntoView({ behavior: "smooth" });
-  }, [records.length]);
-
-  async function handleAction(action: "kill" | "pause" | "resume") {
-    setActionStatus(`${action}ing...`);
-    try {
-      const fn = action === "kill" ? killThread : action === "pause" ? pauseThread : resumeThread;
-      await fn(client, threadId);
-      setActionStatus(null);
-    } catch (e) {
-      setActionStatus(`${action} failed: ${e instanceof Error ? e.message : String(e)}`);
-    }
-  }
-
-  return (
-    <div>
-      <div className="flex items-center justify-between mb-4">
-        <Button
-          variant="ghost"
-          className="gap-1.5 px-2 text-muted-foreground hover:text-foreground transition-colors duration-200"
-          onClick={() => navigate(`/${client}/threads`)}
-        >
-          <ArrowLeft className="h-4 w-4" />
-          Back to threads
-        </Button>
-        <div className="flex gap-1 rounded-lg border border-border bg-muted/30 p-1">
-          <Button
-            variant="outline"
-            size="sm"
-            className="transition-colors duration-200"
-            onClick={() => handleAction("pause")}
-          >
-            <Pause className="h-3.5 w-3.5 text-warning" />
-            Pause
-          </Button>
-          <Button
-            variant="outline"
-            size="sm"
-            className="transition-colors duration-200"
-            onClick={() => handleAction("resume")}
-          >
-            <Play className="h-3.5 w-3.5 text-success" />
-            Resume
-          </Button>
-          <Button
-            variant="outline"
-            size="sm"
-            className="transition-colors duration-200"
-            onClick={() => handleAction("kill")}
-          >
-            <X className="h-3.5 w-3.5 text-destructive" />
-            Kill
-          </Button>
-        </div>
-      </div>
-
-      <h2 className="text-xl font-semibold mb-2 font-mono tracking-tight flex items-center gap-2 flex-wrap">
-        <span>{threadId}</span>
-        {sse.connected && !sse.completed && (
-          <Badge variant="success" className="animate-pulse flex items-center gap-1.5">
-            <span className="inline-block h-2 w-2 rounded-full bg-success-foreground" />
-            Live
-          </Badge>
-        )}
-      </h2>
-      {actionStatus && (
-        <Badge variant="secondary" className="mb-4 text-xs font-normal">
-          {actionStatus}
-        </Badge>
-      )}
-
-      <div className="flex gap-4" style={{ minHeight: "calc(100vh - 120px)" }}>
-        {descriptor !== null && descriptor.graph.edges.length > 0 && (
-          <ResizablePanel
-            defaultWidth={360}
-            minWidth={240}
-            maxWidth={560}
-            className={null}
-            style={{
-              position: "sticky",
-              top: 16,
-              height: "calc(100vh - 120px)",
-              alignSelf: "flex-start",
-            }}
-          >
-            <Card className="h-full flex flex-col overflow-hidden">
-              <div className="flex items-center justify-between px-3 py-2 text-xs text-muted-foreground bg-muted/50 border-b border-border">
-                <span className="font-mono flex items-center gap-1.5">
-                  <Layers className="h-3.5 w-3.5" />
-                  Workflow graph
-                  {workflowName !== null && (
-                    <span className="ml-2 text-foreground">{workflowName}</span>
-                  )}
-                </span>
-                <span className="tabular-nums">
-                  {descriptor.graph.edges.length} edge
-                  {descriptor.graph.edges.length === 1 ? "" : "s"}
-                </span>
-              </div>
-              <div className="flex-1">
-                <WorkflowGraph
-                  graph={descriptor.graph}
-                  roles={descriptor.roles}
-                  nodeStates={nodeStates}
-                  onNodeClick={handleGraphNodeClick}
-                />
-              </div>
-            </Card>
-          </ResizablePanel>
-        )}
-
-        <div className="flex-1 min-w-0">
-          {status === "loading" && !liveActive && records.length === 0 && (
-            <div className="flex flex-col items-center justify-center py-16 text-muted-foreground gap-3">
-              <Loader2 className="h-6 w-6 animate-spin" />
-              <span className="text-sm">Loading thread...</span>
-            </div>
-          )}
-          {status === "error" && !liveActive && (
-            <div className="flex items-center gap-2 py-8 justify-center text-destructive">
-              <AlertCircle className="h-5 w-5" />
-              <span className="text-sm">Error: {error}</span>
-            </div>
-          )}
-          {(status === "ok" || liveActive || records.length > 0) && (
-            <div className="border-l-2 border-border ml-2 pl-4 space-y-3">
-              {records.map((r, i) => {
-                const key = `${threadId}-${i}`;
-                if (r.type === "role") {
-                  const roleIndices = indicesByRole.get(r.role);
-                  const isFirstForRole = roleIndices !== undefined && roleIndices[0] === i;
-                  const flash = highlightedRole === r.role;
-                  return (
-                    <div
-                      key={key}
-                      data-record-index={i}
-                      className="relative"
-                      ref={(el) => {
-                        if (!isFirstForRole) return;
-                        if (el !== null) firstCardByRoleRef.current.set(r.role, el);
-                        else firstCardByRoleRef.current.delete(r.role);
-                      }}
-                    >
-                      <div className="absolute -left-[1.3rem] top-4 h-2.5 w-2.5 rounded-full border-2 border-border bg-background" />
-                      <RecordCard record={r} highlighted={flash} />
-                    </div>
-                  );
-                }
-                return (
-                  <div key={key} data-record-index={i} className="relative">
-                    <div className="absolute -left-[1.3rem] top-4 h-2.5 w-2.5 rounded-full border-2 border-border bg-background" />
-                    <RecordCard record={r} highlighted={false} />
-                  </div>
-                );
-              })}
-              <div ref={recordsEndRef} aria-hidden />
-            </div>
-          )}
-        </div>
-      </div>
-    </div>
-  );
-}

legacy-packages/workflow-dashboard/src/components/thread-list.tsx

@@ -1,88 +0,0 @@
-import { AlertCircle, Clock, Loader2, Workflow, Zap } from "lucide-react";
-import { useNavigate, useParams } from "react-router";
-import { listThreads } from "../api.ts";
-import { useFetch } from "../hooks.ts";
-import { Badge } from "./ui/badge.tsx";
-import { Card } from "./ui/card.tsx";
-
-function statusVariant(status: string): "success" | "destructive" | "secondary" {
-  if (status === "completed") return "success";
-  if (status === "failed") return "destructive";
-  return "secondary";
-}
-
-export function ThreadList() {
-  const params = useParams();
-  const navigate = useNavigate();
-  const client = params.client as string;
-  const { status, data, error } = useFetch(() => listThreads(client), [client]);
-
-  if (status === "loading")
-    return (
-      <div className="flex flex-col items-center justify-center py-16 gap-3">
-        <Loader2 className="h-4 w-4 animate-spin text-muted-foreground" />
-        <p className="text-sm text-muted-foreground">Loading threads...</p>
-      </div>
-    );
-
-  if (status === "error")
-    return (
-      <div className="flex flex-col items-center justify-center py-16 gap-3">
-        <AlertCircle className="h-5 w-5 text-destructive" />
-        <p className="text-sm text-destructive">Error: {error}</p>
-      </div>
-    );
-
-  const threads = [...data.threads].sort((a, b) => {
-    if (!a.startedAt && !b.startedAt) return 0;
-    if (!a.startedAt) return 1;
-    if (!b.startedAt) return -1;
-    return b.startedAt.localeCompare(a.startedAt);
-  });
-
-  return (
-    <div>
-      <h2 className="text-xl font-semibold tracking-tight mb-4">Threads</h2>
-      {threads.length === 0 ? (
-        <div className="flex flex-col items-center justify-center py-16 gap-3">
-          <Zap className="h-12 w-12 text-muted-foreground/50" />
-          <p className="text-sm font-medium">No threads</p>
-          <p className="text-xs text-muted-foreground">
-            Run a workflow to create your first thread.
-          </p>
-        </div>
-      ) : (
-        <div className="space-y-2">
-          {threads.map((t) => (
-            <Card
-              key={t.threadId}
-              className="p-4 cursor-pointer hover:bg-accent/50 hover:shadow-sm transition-all duration-200"
-              onClick={() => navigate(`/${client}/threads/${t.threadId}`)}
-            >
-              <div className="flex items-center justify-between">
-                <code className="font-mono text-sm text-foreground">{t.threadId}</code>
-                {t.status && (
-                  <Badge variant={statusVariant(t.status)} className="text-xs">
-                    {t.status}
-                  </Badge>
-                )}
-              </div>
-              {t.workflow && (
-                <p className="text-sm mt-1 font-medium text-foreground flex items-center gap-1.5">
-                  <Workflow className="h-3.5 w-3.5 text-muted-foreground" />
-                  {t.workflow}
-                </p>
-              )}
-              {t.startedAt && (
-                <p className="text-xs mt-1 text-muted-foreground flex items-center gap-1.5">
-                  <Clock className="h-3 w-3" />
-                  {t.startedAt}
-                </p>
-              )}
-            </Card>
-          ))}
-        </div>
-      )}
-    </div>
-  );
-}

legacy-packages/workflow-dashboard/src/components/ui/badge.tsx

@@ -1,30 +0,0 @@
-import { cva, type VariantProps } from "class-variance-authority";
-import type { HTMLAttributes } from "react";
-import { cn } from "../../lib/utils.ts";
-
-const badgeVariants = cva(
-  "inline-flex items-center rounded-md border px-2.5 py-0.5 text-xs font-semibold transition-colors focus:outline-none focus:ring-2 focus:ring-ring focus:ring-offset-2",
-  {
-    variants: {
-      variant: {
-        default: "border-transparent bg-primary text-primary-foreground shadow",
-        secondary: "border-transparent bg-secondary text-secondary-foreground",
-        destructive: "border-transparent bg-destructive text-destructive-foreground shadow",
-        outline: "text-foreground",
-        success: "border-transparent bg-success text-success-foreground shadow",
-        warning: "border-transparent bg-warning text-warning-foreground shadow",
-      },
-    },
-    defaultVariants: {
-      variant: "default",
-    },
-  },
-);
-
-export type BadgeProps = HTMLAttributes<HTMLDivElement> & VariantProps<typeof badgeVariants>;
-
-function Badge({ className, variant, ...props }: BadgeProps) {
-  return <div className={cn(badgeVariants({ variant }), className)} {...props} />;
-}
-
-export { Badge, badgeVariants };

legacy-packages/workflow-dashboard/src/components/ui/button.tsx

@@ -1,45 +0,0 @@
-import { Slot } from "@radix-ui/react-slot";
-import { cva, type VariantProps } from "class-variance-authority";
-import type { ButtonHTMLAttributes } from "react";
-import { cn } from "../../lib/utils.ts";
-
-const buttonVariants = cva(
-  "inline-flex items-center justify-center gap-2 whitespace-nowrap rounded-md text-sm font-medium transition-colors focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring disabled:pointer-events-none disabled:opacity-50 [&_svg]:pointer-events-none [&_svg]:size-4 [&_svg]:shrink-0",
-  {
-    variants: {
-      variant: {
-        default: "bg-primary text-primary-foreground shadow hover:bg-primary/90",
-        destructive: "bg-destructive text-destructive-foreground shadow-sm hover:bg-destructive/90",
-        outline:
-          "border border-input bg-background shadow-sm hover:bg-accent hover:text-accent-foreground",
-        secondary: "bg-secondary text-secondary-foreground shadow-sm hover:bg-secondary/80",
-        ghost: "hover:bg-accent hover:text-accent-foreground",
-        link: "text-primary underline-offset-4 hover:underline",
-        success: "border border-success text-success hover:bg-success/10",
-        warning: "border border-warning text-warning hover:bg-warning/10",
-      },
-      size: {
-        default: "h-9 px-4 py-2",
-        sm: "h-8 rounded-md px-3 text-xs",
-        lg: "h-10 rounded-md px-8",
-        icon: "h-9 w-9",
-      },
-    },
-    defaultVariants: {
-      variant: "default",
-      size: "default",
-    },
-  },
-);
-
-export type ButtonProps = ButtonHTMLAttributes<HTMLButtonElement> &
-  VariantProps<typeof buttonVariants> & {
-    asChild?: boolean;
-  };
-
-function Button({ className, variant, size, asChild = false, ...props }: ButtonProps) {
-  const Comp = asChild ? Slot : "button";
-  return <Comp className={cn(buttonVariants({ variant, size, className }))} {...props} />;
-}
-
-export { Button, buttonVariants };

legacy-packages/workflow-dashboard/src/components/ui/card.tsx

@@ -1,36 +0,0 @@
-import type { HTMLAttributes } from "react";
-import { cn } from "../../lib/utils.ts";
-
-function Card({ className, ...props }: HTMLAttributes<HTMLDivElement>) {
-  return (
-    <div
-      className={cn(
-        "rounded-lg border border-border bg-card text-card-foreground shadow-sm",
-        className,
-      )}
-      {...props}
-    />
-  );
-}
-
-function CardHeader({ className, ...props }: HTMLAttributes<HTMLDivElement>) {
-  return <div className={cn("flex flex-col space-y-1.5 p-6", className)} {...props} />;
-}
-
-function CardTitle({ className, ...props }: HTMLAttributes<HTMLDivElement>) {
-  return <div className={cn("font-semibold leading-none tracking-tight", className)} {...props} />;
-}
-
-function CardDescription({ className, ...props }: HTMLAttributes<HTMLDivElement>) {
-  return <div className={cn("text-sm text-muted-foreground", className)} {...props} />;
-}
-
-function CardContent({ className, ...props }: HTMLAttributes<HTMLDivElement>) {
-  return <div className={cn("p-6 pt-0", className)} {...props} />;
-}
-
-function CardFooter({ className, ...props }: HTMLAttributes<HTMLDivElement>) {
-  return <div className={cn("flex items-center p-6 pt-0", className)} {...props} />;
-}
-
-export { Card, CardContent, CardDescription, CardFooter, CardHeader, CardTitle };