Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 83992a71cd | |||
| fbfd31a042 | |||
| d99a376b60 | |||
| a536efee00 |
@@ -0,0 +1,9 @@
|
|||||||
|
---
|
||||||
|
"@united-workforce/cli": minor
|
||||||
|
"@united-workforce/util": patch
|
||||||
|
---
|
||||||
|
|
||||||
|
feat: replace $START `_` status with `new`/`resume` semantics
|
||||||
|
|
||||||
|
BREAKING: All workflow YAML files must update `$START._` to `$START.new` + `$START.resume`.
|
||||||
|
The `resume` edge prompt replaces the previously hardcoded resume message in the CLI.
|
||||||
@@ -264,7 +264,8 @@ roles:
|
|||||||
|
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: "bootstrap", prompt: "Set up the Docker container and verify uwf is runnable." }
|
new: { role: "bootstrap", prompt: "Set up the Docker container and verify uwf is runnable." }
|
||||||
|
resume: { role: "bootstrap", prompt: "Review the previous run output and continue the walkthrough." }
|
||||||
bootstrap:
|
bootstrap:
|
||||||
pass: { role: "config-and-registry", prompt: "Container {{{containerName}}} is ready. Validate config and workflow registration." }
|
pass: { role: "config-and-registry", prompt: "Container {{{containerName}}} is ready. Validate config and workflow registration." }
|
||||||
fail: { role: "$END", prompt: "Bootstrap failed: {{{error}}}. No container was created." }
|
fail: { role: "$END", prompt: "Bootstrap failed: {{{error}}}. No container was created." }
|
||||||
|
|||||||
@@ -227,7 +227,8 @@ roles:
|
|||||||
required: [$status, error]
|
required: [$status, error]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: "planner", prompt: "Analyze the issue and produce an implementation plan." }
|
new: { role: "planner", prompt: "Analyze the issue and produce an implementation plan." }
|
||||||
|
resume: { role: "planner", prompt: "Review the previous run output and continue the work." }
|
||||||
planner:
|
planner:
|
||||||
insufficient_info: { role: "$SUSPEND", prompt: "信息不足,需要补充:{{{reason}}}" }
|
insufficient_info: { role: "$SUSPEND", prompt: "信息不足,需要补充:{{{reason}}}" }
|
||||||
ready: { role: "developer", prompt: "Implement the TDD test spec (CAS hash: {{{plan}}}) in repo {{{repoPath}}}. Repo remote: {{{repoRemote}}}." }
|
ready: { role: "developer", prompt: "Implement the TDD test spec (CAS hash: {{{plan}}}) in repo {{{repoPath}}}. Repo remote: {{{repoRemote}}}." }
|
||||||
|
|||||||
@@ -200,7 +200,7 @@ payload:
|
|||||||
|
|
||||||
- `roles` — 内联定义,每个 role 的 `meta` 是独立的 ocas_ref(指向 ocas 内置 JSON Schema 节点)
|
- `roles` — 内联定义,每个 role 的 `meta` 是独立的 ocas_ref(指向 ocas 内置 JSON Schema 节点)
|
||||||
- `graph` — `Record<Role | "$START", Record<Status, Target>>`,每个 Target = `{ role, prompt }`
|
- `graph` — `Record<Role | "$START", Record<Status, Target>>`,每个 Target = `{ role, prompt }`
|
||||||
- Status 来自上一个 role 输出的 `status` 字段,`$START` 用 `_` 作为初始 status
|
- Status 来自上一个 role 输出的 `$status` 字段,`$START` 使用 `new`(首次启动)和 `resume`(恢复已完成的 thread)作为 status
|
||||||
- Prompt 模板使用 Mustache 渲染,变量来自 lastOutput
|
- Prompt 模板使用 Mustache 渲染,变量来自 lastOutput
|
||||||
- 不含 agent binding — agent 配置在 `~/.uwf/config.yaml` 中管理
|
- 不含 agent binding — agent 配置在 `~/.uwf/config.yaml` 中管理
|
||||||
|
|
||||||
@@ -208,7 +208,7 @@ Moderator 的求值逻辑:
|
|||||||
|
|
||||||
```typescript
|
```typescript
|
||||||
evaluate(graph, lastRole, lastOutput) → { role, prompt }
|
evaluate(graph, lastRole, lastOutput) → { role, prompt }
|
||||||
// 1. status = lastRole === "$START" ? "_" : lastOutput.status
|
// 1. status = lastOutput.$status (e.g. "new" for $START first run, "resume" for completed thread resume)
|
||||||
// 2. target = graph[lastRole][status]
|
// 2. target = graph[lastRole][status]
|
||||||
// 3. prompt = mustache.render(target.prompt, lastOutput)
|
// 3. prompt = mustache.render(target.prompt, lastOutput)
|
||||||
```
|
```
|
||||||
@@ -422,8 +422,8 @@ type StepNodePayload = StepRecord & {
|
|||||||
Moderator 使用 `evaluate(graph, lastRole, lastOutput)` 进行同步 status-based routing:
|
Moderator 使用 `evaluate(graph, lastRole, lastOutput)` 进行同步 status-based routing:
|
||||||
|
|
||||||
```typescript
|
```typescript
|
||||||
// graph[lastRole][lastOutput.status] → Target { role, prompt }
|
// graph[lastRole][lastOutput.$status] → Target { role, prompt }
|
||||||
// $START 角色使用 "_" 作为初始 status
|
// $START 使用 "new"(首次启动)和 "resume"(恢复已完成 thread)作为 status
|
||||||
// prompt 通过 Mustache 模板渲染,变量来自 lastOutput
|
// prompt 通过 Mustache 模板渲染,变量来自 lastOutput
|
||||||
```
|
```
|
||||||
|
|
||||||
|
|||||||
@@ -35,6 +35,7 @@ roles:
|
|||||||
required: [$status, thesis, keyPoints]
|
required: [$status, thesis, keyPoints]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: "analyst", prompt: "Analyze the topic in the task and produce a structured summary with key points." }
|
new: { role: "analyst", prompt: "Analyze the topic in the task and produce a structured summary with key points." }
|
||||||
|
resume: { role: "analyst", prompt: "Review the previous analysis output and continue with additional context." }
|
||||||
analyst:
|
analyst:
|
||||||
done: { role: "$END", prompt: "Analysis complete. Finish the workflow." }
|
done: { role: "$END", prompt: "Analysis complete. Finish the workflow." }
|
||||||
|
|||||||
@@ -53,7 +53,8 @@ roles:
|
|||||||
required: [$status, argument]
|
required: [$status, argument]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: "against", prompt: "Present your opening argument against the proposition." }
|
new: { role: "against", prompt: "Present your opening argument against the proposition." }
|
||||||
|
resume: { role: "against", prompt: "Review the previous debate output and continue the argument against the proposition." }
|
||||||
against:
|
against:
|
||||||
conceded: { role: "$END", prompt: "The against side conceded. Debate over." }
|
conceded: { role: "$END", prompt: "The against side conceded. Debate over." }
|
||||||
continue: { role: "for", prompt: "Counter the opposing argument: {{{argument}}}" }
|
continue: { role: "for", prompt: "Counter the opposing argument: {{{argument}}}" }
|
||||||
|
|||||||
@@ -25,6 +25,7 @@ roles:
|
|||||||
required: [$status, summary]
|
required: [$status, summary]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: "fixer", prompt: "Fix the code issue described in the task prompt." }
|
new: { role: "fixer", prompt: "Fix the code issue described in the task prompt." }
|
||||||
|
resume: { role: "fixer", prompt: "Review the previous run output and continue fixing the code issue." }
|
||||||
fixer:
|
fixer:
|
||||||
done: { role: "$END", prompt: "Fix complete." }
|
done: { role: "$END", prompt: "Fix complete." }
|
||||||
|
|||||||
@@ -215,7 +215,8 @@ roles:
|
|||||||
required: [$status, error]
|
required: [$status, error]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: "planner", prompt: "Analyze the issue and produce an implementation plan." }
|
new: { role: "planner", prompt: "Analyze the issue and produce an implementation plan." }
|
||||||
|
resume: { role: "planner", prompt: "Review the previous run output and continue the work." }
|
||||||
planner:
|
planner:
|
||||||
insufficient_info: { role: "$SUSPEND", prompt: "信息不足,需要补充:{{{reason}}}" }
|
insufficient_info: { role: "$SUSPEND", prompt: "信息不足,需要补充:{{{reason}}}" }
|
||||||
ready: { role: "developer", prompt: "Implement the TDD test spec (CAS hash: {{{plan}}}) in repo {{{repoPath}}}." }
|
ready: { role: "developer", prompt: "Implement the TDD test spec (CAS hash: {{{plan}}}) in repo {{{repoPath}}}." }
|
||||||
|
|||||||
@@ -58,7 +58,10 @@ describe("C1: adapter JSON round-trip integration", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Do the work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Do the work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume the work", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "completed", location: null } },
|
worker: { done: { role: "$END", prompt: "completed", location: null } },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -45,10 +45,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["done"] }
|
$status: { type: string, enum: ["done"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: roleA
|
role: roleA
|
||||||
prompt: "Do A"
|
prompt: "Do A"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: roleA
|
||||||
|
prompt: "Resume A"
|
||||||
|
location: null
|
||||||
roleA:
|
roleA:
|
||||||
ready:
|
ready:
|
||||||
role: roleB
|
role: roleB
|
||||||
@@ -107,10 +111,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["done"] }
|
$status: { type: string, enum: ["done"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: roleA
|
role: roleA
|
||||||
prompt: "Do A"
|
prompt: "Do A"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: roleA
|
||||||
|
prompt: "Resume A"
|
||||||
|
location: null
|
||||||
roleA:
|
roleA:
|
||||||
pass:
|
pass:
|
||||||
role: roleB
|
role: roleB
|
||||||
@@ -150,10 +158,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["done"] }
|
$status: { type: string, enum: ["done"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: worker
|
role: worker
|
||||||
prompt: "Work"
|
prompt: "Work"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: worker
|
||||||
|
prompt: "Resume work"
|
||||||
|
location: null
|
||||||
worker:
|
worker:
|
||||||
done:
|
done:
|
||||||
role: $END
|
role: $END
|
||||||
|
|||||||
@@ -36,7 +36,8 @@ roles:
|
|||||||
required: [$status]
|
required: [$status]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: analyst, prompt: 'Analyze the task' }
|
new: { role: analyst, prompt: 'Analyze the task' }
|
||||||
|
resume: { role: analyst, prompt: 'Review the previous run output and continue the work.' }
|
||||||
analyst:
|
analyst:
|
||||||
analyzed: { role: developer, prompt: 'Implement the change' }
|
analyzed: { role: developer, prompt: 'Implement the change' }
|
||||||
developer:
|
developer:
|
||||||
|
|||||||
@@ -25,7 +25,8 @@ roles:
|
|||||||
required: [$status]
|
required: [$status]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: planner, prompt: 'Plan the task' }
|
new: { role: planner, prompt: 'Plan the task' }
|
||||||
|
resume: { role: planner, prompt: 'Review the previous run output and continue the work.' }
|
||||||
planner:
|
planner:
|
||||||
ready: { role: worker, prompt: 'Do the work' }
|
ready: { role: worker, prompt: 'Do the work' }
|
||||||
worker:
|
worker:
|
||||||
|
|||||||
@@ -28,7 +28,8 @@ roles:
|
|||||||
required: [$status]
|
required: [$status]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: developer, prompt: 'Implement the change' }
|
new: { role: developer, prompt: 'Implement the change' }
|
||||||
|
resume: { role: developer, prompt: 'Review the previous run output and continue the work.' }
|
||||||
developer:
|
developer:
|
||||||
review_needed: { role: reviewer, prompt: 'Review the change' }
|
review_needed: { role: reviewer, prompt: 'Review the change' }
|
||||||
reviewer:
|
reviewer:
|
||||||
|
|||||||
@@ -27,7 +27,8 @@ roles:
|
|||||||
required: [$status]
|
required: [$status]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: planner, prompt: 'Plan the task' }
|
new: { role: planner, prompt: 'Plan the task' }
|
||||||
|
resume: { role: planner, prompt: 'Review the previous run output and continue the work.' }
|
||||||
planner:
|
planner:
|
||||||
ready: { role: worker, prompt: 'Work on branch {{{branch}}} in {{{repoPath}}}' }
|
ready: { role: worker, prompt: 'Work on branch {{{branch}}} in {{{repoPath}}}' }
|
||||||
worker:
|
worker:
|
||||||
|
|||||||
@@ -18,7 +18,8 @@ roles:
|
|||||||
required: [$status]
|
required: [$status]
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: planner, prompt: 'Analyze the task' }
|
new: { role: planner, prompt: 'Analyze the task' }
|
||||||
|
resume: { role: planner, prompt: 'Review the previous run output and continue the work.' }
|
||||||
planner:
|
planner:
|
||||||
insufficient_info: { role: '$SUSPEND', prompt: 'Need more info: {{{reason}}}' }
|
insufficient_info: { role: '$SUSPEND', prompt: 'Need more info: {{{reason}}}' }
|
||||||
ready: { role: '$END', prompt: 'Done' }
|
ready: { role: '$END', prompt: 'Done' }
|
||||||
|
|||||||
@@ -5,7 +5,12 @@ import { evaluate } from "../moderator/evaluate.js";
|
|||||||
|
|
||||||
const solveIssueGraph: WorkflowPayload["graph"] = {
|
const solveIssueGraph: WorkflowPayload["graph"] = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "planner", prompt: "Start planning from the issue in the task.", location: null },
|
new: { role: "planner", prompt: "Start planning from the issue in the task.", location: null },
|
||||||
|
resume: {
|
||||||
|
role: "planner",
|
||||||
|
prompt: "Review the previous run output and continue the work.",
|
||||||
|
location: null,
|
||||||
|
},
|
||||||
},
|
},
|
||||||
planner: {
|
planner: {
|
||||||
planned: { role: "developer", prompt: "Implement the plan: {{plan}}", location: null },
|
planned: { role: "developer", prompt: "Implement the plan: {{plan}}", location: null },
|
||||||
@@ -20,8 +25,8 @@ const solveIssueGraph: WorkflowPayload["graph"] = {
|
|||||||
};
|
};
|
||||||
|
|
||||||
describe("evaluate", () => {
|
describe("evaluate", () => {
|
||||||
test("$START → first role (unit status _)", () => {
|
test("$START → first role (status new)", () => {
|
||||||
const result = evaluate(solveIssueGraph, "$START", { $status: "_" });
|
const result = evaluate(solveIssueGraph, "$START", { $status: "new" });
|
||||||
expect(result).toEqual({
|
expect(result).toEqual({
|
||||||
ok: true,
|
ok: true,
|
||||||
value: {
|
value: {
|
||||||
@@ -32,6 +37,18 @@ describe("evaluate", () => {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test("$START → first role (status resume)", () => {
|
||||||
|
const result = evaluate(solveIssueGraph, "$START", { $status: "resume" });
|
||||||
|
expect(result).toEqual({
|
||||||
|
ok: true,
|
||||||
|
value: {
|
||||||
|
role: "planner",
|
||||||
|
prompt: "Review the previous run output and continue the work.",
|
||||||
|
location: null,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
test("status-based routing (reviewer rejected → developer)", () => {
|
test("status-based routing (reviewer rejected → developer)", () => {
|
||||||
const result = evaluate(solveIssueGraph, "reviewer", {
|
const result = evaluate(solveIssueGraph, "reviewer", {
|
||||||
$status: "rejected",
|
$status: "rejected",
|
||||||
@@ -95,7 +112,7 @@ describe("evaluate", () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
test("missing role in graph → error", () => {
|
test("missing role in graph → error", () => {
|
||||||
const result = evaluate(solveIssueGraph, "unknown-role", { $status: "_" });
|
const result = evaluate(solveIssueGraph, "unknown-role", { $status: "new" });
|
||||||
expect(result.ok).toBe(false);
|
expect(result.ok).toBe(false);
|
||||||
if (!result.ok) {
|
if (!result.ok) {
|
||||||
expect(result.error.message).toBe('no transitions defined for role "unknown-role"');
|
expect(result.error.message).toBe('no transitions defined for role "unknown-role"');
|
||||||
|
|||||||
@@ -9,31 +9,25 @@ import {
|
|||||||
cmdPromptAdapterDeveloping,
|
cmdPromptAdapterDeveloping,
|
||||||
cmdPromptBootstrap,
|
cmdPromptBootstrap,
|
||||||
cmdPromptList,
|
cmdPromptList,
|
||||||
cmdPromptSetup,
|
|
||||||
cmdPromptUsage,
|
cmdPromptUsage,
|
||||||
cmdPromptUsageReference,
|
|
||||||
cmdPromptWorkflowAuthoring,
|
cmdPromptWorkflowAuthoring,
|
||||||
} from "../commands/prompt.js";
|
} from "../commands/prompt.js";
|
||||||
|
|
||||||
describe("prompt commands", () => {
|
describe("prompt commands", () => {
|
||||||
test("prompt list returns new prompt names", () => {
|
test("prompt list returns prompt names (no bootstrap)", () => {
|
||||||
const result = cmdPromptList();
|
const result = cmdPromptList();
|
||||||
expect(result).toBeInstanceOf(Array);
|
expect(result).toBeInstanceOf(Array);
|
||||||
expect(result).toContain("usage");
|
expect(result).toContain("usage");
|
||||||
expect(result).toContain("workflow-authoring");
|
expect(result).toContain("workflow-authoring");
|
||||||
expect(result).toContain("adapter-developing");
|
expect(result).toContain("adapter-developing");
|
||||||
expect(result).toContain("bootstrap");
|
expect(result).not.toContain("bootstrap");
|
||||||
expect(result).not.toContain("user");
|
|
||||||
expect(result).not.toContain("author");
|
|
||||||
expect(result).not.toContain("developer");
|
|
||||||
expect(result).not.toContain("adapter");
|
|
||||||
for (const name of result) {
|
for (const name of result) {
|
||||||
expect(name).toMatch(/^\S+$/);
|
expect(name).toMatch(/^\S+$/);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
test("prompt usage-reference returns non-empty markdown string with frontmatter", () => {
|
test("prompt usage returns only the usage reference with frontmatter", () => {
|
||||||
const result = cmdPromptUsageReference();
|
const result = cmdPromptUsage();
|
||||||
expect(typeof result).toBe("string");
|
expect(typeof result).toBe("string");
|
||||||
expect(result).toContain("uwf");
|
expect(result).toContain("uwf");
|
||||||
expect(result).toContain("thread");
|
expect(result).toContain("thread");
|
||||||
@@ -42,6 +36,9 @@ describe("prompt commands", () => {
|
|||||||
expect(result).toContain("---");
|
expect(result).toContain("---");
|
||||||
expect(result).toContain("name:");
|
expect(result).toContain("name:");
|
||||||
expect(result).toContain("version:");
|
expect(result).toContain("version:");
|
||||||
|
// Should NOT contain other references
|
||||||
|
expect(result).not.toContain("Workflow Authoring Reference");
|
||||||
|
expect(result).not.toContain("Adapter Developing Reference");
|
||||||
expect(result.length).toBeGreaterThan(500);
|
expect(result.length).toBeGreaterThan(500);
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -71,44 +68,19 @@ describe("prompt commands", () => {
|
|||||||
expect(result.length).toBeGreaterThan(500);
|
expect(result.length).toBeGreaterThan(500);
|
||||||
});
|
});
|
||||||
|
|
||||||
test("prompt bootstrap returns non-empty skill with frontmatter", () => {
|
test("prompt bootstrap returns framework-agnostic setup instructions", () => {
|
||||||
const result = cmdPromptBootstrap();
|
const result = cmdPromptBootstrap();
|
||||||
expect(typeof result).toBe("string");
|
expect(typeof result).toBe("string");
|
||||||
expect(result).toContain("uwf");
|
|
||||||
expect(result).toContain("---");
|
|
||||||
expect(result.length).toBeGreaterThan(100);
|
|
||||||
});
|
|
||||||
|
|
||||||
test("prompt usage combines remaining references (no developer)", () => {
|
|
||||||
const result = cmdPromptUsage();
|
|
||||||
expect(typeof result).toBe("string");
|
|
||||||
expect(result).toContain("Usage Reference");
|
|
||||||
expect(result).toContain("Workflow Authoring Reference");
|
|
||||||
expect(result).toContain("Adapter Developing Reference");
|
|
||||||
expect(result).not.toContain("Developer Reference");
|
|
||||||
expect(result).toContain("---");
|
|
||||||
expect(result.length).toBeGreaterThan(2000);
|
|
||||||
});
|
|
||||||
|
|
||||||
test("prompt setup returns simplified setup instructions", () => {
|
|
||||||
const result = cmdPromptSetup();
|
|
||||||
expect(typeof result).toBe("string");
|
|
||||||
expect(result).toContain("uwf Skill Setup");
|
|
||||||
expect(result).toContain("uwf prompt bootstrap");
|
|
||||||
expect(result).toContain("SKILL.md");
|
|
||||||
expect(result).toContain("version");
|
|
||||||
expect(result).not.toMatch(/\bbun (install|run|test|changeset|version|release)\b/);
|
|
||||||
});
|
|
||||||
|
|
||||||
test("prompt setup references new subcommand names", () => {
|
|
||||||
const result = cmdPromptSetup();
|
|
||||||
expect(result).toContain("uwf prompt usage");
|
expect(result).toContain("uwf prompt usage");
|
||||||
expect(result).toContain("uwf prompt workflow-authoring");
|
expect(result).toContain("uwf prompt workflow-authoring");
|
||||||
expect(result).toContain("uwf prompt adapter-developing");
|
expect(result).toContain("uwf prompt adapter-developing");
|
||||||
expect(result).not.toContain("uwf prompt user");
|
expect(result).toContain("uwf-usage");
|
||||||
expect(result).not.toContain("uwf prompt author");
|
expect(result).toContain("uwf-workflow-authoring");
|
||||||
expect(result).not.toContain("uwf prompt developer");
|
expect(result).toContain("uwf-adapter-developing");
|
||||||
expect(result).not.toMatch(/uwf prompt adapter\b(?!-developing)/);
|
// Should NOT contain Hermes-specific paths
|
||||||
|
expect(result).not.toContain("~/.hermes/skills/");
|
||||||
|
expect(result).not.toContain("> ~/.hermes/");
|
||||||
|
expect(result.length).toBeGreaterThan(100);
|
||||||
});
|
});
|
||||||
|
|
||||||
test("prompt help subcommand is suppressed", { timeout: 30_000 }, () => {
|
test("prompt help subcommand is suppressed", { timeout: 30_000 }, () => {
|
||||||
@@ -119,11 +91,12 @@ describe("prompt commands", () => {
|
|||||||
});
|
});
|
||||||
expect(output).not.toMatch(/help\s+\[command\]/i);
|
expect(output).not.toMatch(/help\s+\[command\]/i);
|
||||||
expect(output).toContain("usage");
|
expect(output).toContain("usage");
|
||||||
expect(output).toContain("setup");
|
expect(output).toContain("bootstrap");
|
||||||
expect(output).toContain("workflow-authoring");
|
expect(output).toContain("workflow-authoring");
|
||||||
expect(output).toContain("adapter-developing");
|
expect(output).toContain("adapter-developing");
|
||||||
expect(output).toContain("bootstrap");
|
|
||||||
expect(output).toContain("list");
|
expect(output).toContain("list");
|
||||||
expect(output).not.toContain("developer");
|
// Removed subcommands should not appear as command names
|
||||||
|
expect(output).not.toMatch(/^\s+setup\s/m);
|
||||||
|
expect(output).not.toContain("usage-reference");
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -253,7 +253,10 @@ describe("thread read timing", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "go", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "go", location: null },
|
||||||
|
resume: { role: "worker", prompt: "resume", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "", location: null } },
|
worker: { done: { role: "$END", prompt: "", location: null } },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
@@ -319,7 +322,10 @@ describe("thread read timing", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "go", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "go", location: null },
|
||||||
|
resume: { role: "worker", prompt: "resume", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "", location: null } },
|
worker: { done: { role: "$END", prompt: "", location: null } },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -57,10 +57,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["ready"] }
|
$status: { type: string, enum: ["ready"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: planner
|
role: planner
|
||||||
prompt: "Plan the work"
|
prompt: "Plan the work"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: planner
|
||||||
|
prompt: "Resume the work"
|
||||||
|
location: null
|
||||||
planner:
|
planner:
|
||||||
ready:
|
ready:
|
||||||
role: $END
|
role: $END
|
||||||
@@ -113,10 +117,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["ready"] }
|
$status: { type: string, enum: ["ready"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: planner
|
role: planner
|
||||||
prompt: "Plan"
|
prompt: "Plan"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: planner
|
||||||
|
prompt: "Resume"
|
||||||
|
location: null
|
||||||
planner:
|
planner:
|
||||||
ready:
|
ready:
|
||||||
role: $END
|
role: $END
|
||||||
@@ -156,10 +164,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["ready"] }
|
$status: { type: string, enum: ["ready"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: planner
|
role: planner
|
||||||
prompt: "Plan"
|
prompt: "Plan"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: planner
|
||||||
|
prompt: "Resume"
|
||||||
|
location: null
|
||||||
planner:
|
planner:
|
||||||
ready:
|
ready:
|
||||||
role: $END
|
role: $END
|
||||||
|
|||||||
@@ -70,7 +70,10 @@ async function setupSuspendedThread(mode: MockAgentMode): Promise<{
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume the work", location: null },
|
||||||
|
},
|
||||||
worker: {
|
worker: {
|
||||||
needs_input: {
|
needs_input: {
|
||||||
role: "$SUSPEND",
|
role: "$SUSPEND",
|
||||||
@@ -233,7 +236,10 @@ describe("uwf thread resume", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "Done", location: null } },
|
worker: { done: { role: "$END", prompt: "Done", location: null } },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
@@ -479,7 +485,10 @@ describe("uwf thread resume - completed threads", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume the work", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "reviewer", prompt: "Review the work", location: null } },
|
worker: { done: { role: "reviewer", prompt: "Review the work", location: null } },
|
||||||
reviewer: { done: { role: "$END", prompt: "Done", location: null } },
|
reviewer: { done: { role: "$END", prompt: "Done", location: null } },
|
||||||
},
|
},
|
||||||
@@ -610,7 +619,7 @@ echo '${adapterJson}'
|
|||||||
expect(cliOutput.done).toBe(false);
|
expect(cliOutput.done).toBe(false);
|
||||||
|
|
||||||
const capturedPrompt = await readFile(promptCapturePath, "utf8");
|
const capturedPrompt = await readFile(promptCapturePath, "utf8");
|
||||||
expect(capturedPrompt).toContain("Previous run completed");
|
expect(capturedPrompt).toContain("Resume the work");
|
||||||
expect(capturedPrompt).toContain("Additional context");
|
expect(capturedPrompt).toContain("Additional context");
|
||||||
|
|
||||||
const storeModule = await import("../store.js");
|
const storeModule = await import("../store.js");
|
||||||
@@ -640,7 +649,10 @@ echo '${adapterJson}'
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "Done", location: null } },
|
worker: { done: { role: "$END", prompt: "Done", location: null } },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
@@ -688,7 +700,10 @@ echo '${adapterJson}'
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "Done", location: null } },
|
worker: { done: { role: "$END", prompt: "Done", location: null } },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -34,10 +34,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["ready"] }
|
$status: { type: string, enum: ["ready"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: planner
|
role: planner
|
||||||
prompt: "Plan the work"
|
prompt: "Plan the work"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: planner
|
||||||
|
prompt: "Resume the work"
|
||||||
|
location: null
|
||||||
planner:
|
planner:
|
||||||
ready:
|
ready:
|
||||||
role: $END
|
role: $END
|
||||||
@@ -66,10 +70,14 @@ roles:
|
|||||||
question: { type: string }
|
question: { type: string }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: worker
|
role: worker
|
||||||
prompt: "Start work"
|
prompt: "Start work"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: worker
|
||||||
|
prompt: "Resume work"
|
||||||
|
location: null
|
||||||
worker:
|
worker:
|
||||||
needs_input:
|
needs_input:
|
||||||
role: $SUSPEND
|
role: $SUSPEND
|
||||||
|
|||||||
@@ -57,10 +57,14 @@ roles:
|
|||||||
$status: { type: string, enum: ["ready"] }
|
$status: { type: string, enum: ["ready"] }
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: planner
|
role: planner
|
||||||
prompt: "Plan the work"
|
prompt: "Plan the work"
|
||||||
location: null
|
location: null
|
||||||
|
resume:
|
||||||
|
role: planner
|
||||||
|
prompt: "Resume the work"
|
||||||
|
location: null
|
||||||
planner:
|
planner:
|
||||||
ready:
|
ready:
|
||||||
role: $END
|
role: $END
|
||||||
|
|||||||
@@ -58,7 +58,10 @@ describe("suspend step CAS chain and threads.yaml metadata", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume work", location: null },
|
||||||
|
},
|
||||||
worker: {
|
worker: {
|
||||||
needs_input: {
|
needs_input: {
|
||||||
role: "$SUSPEND",
|
role: "$SUSPEND",
|
||||||
|
|||||||
@@ -55,7 +55,10 @@ describe("suspended thread display", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume work", location: null },
|
||||||
|
},
|
||||||
worker: {
|
worker: {
|
||||||
needs_input: {
|
needs_input: {
|
||||||
role: "$SUSPEND",
|
role: "$SUSPEND",
|
||||||
@@ -162,7 +165,10 @@ describe("suspended thread display", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume work", location: null },
|
||||||
|
},
|
||||||
worker: {
|
worker: {
|
||||||
needs_input: {
|
needs_input: {
|
||||||
role: "$SUSPEND",
|
role: "$SUSPEND",
|
||||||
@@ -248,7 +254,10 @@ describe("suspended thread display", () => {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "Start work", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "Start work", location: null },
|
||||||
|
resume: { role: "worker", prompt: "Resume work", location: null },
|
||||||
|
},
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -51,7 +51,10 @@ function makeWorkflow(overrides?: Partial<WorkflowPayload>): WorkflowPayload {
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "writer", prompt: "Begin writing", location: null } },
|
$START: {
|
||||||
|
new: { role: "writer", prompt: "Begin writing", location: null },
|
||||||
|
resume: { role: "writer", prompt: "Review previous output and continue", location: null },
|
||||||
|
},
|
||||||
writer: { done: { role: "reviewer", prompt: "Review this: {{{plan}}}", location: null } },
|
writer: { done: { role: "reviewer", prompt: "Review this: {{{plan}}}", location: null } },
|
||||||
reviewer: {
|
reviewer: {
|
||||||
approved: { role: "$END", prompt: "Done: {{{summary}}}", location: null },
|
approved: { role: "$END", prompt: "Done: {{{summary}}}", location: null },
|
||||||
@@ -135,27 +138,38 @@ describe("Suite 2: Graph Structure", () => {
|
|||||||
expect(errors.some((e) => e.includes("$START must be defined in graph"))).toBe(true);
|
expect(errors.some((e) => e.includes("$START must be defined in graph"))).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
test("2.2 $START has multiple status keys", () => {
|
test("2.2 $START missing resume edge", () => {
|
||||||
const wf = makeWorkflow();
|
const wf = makeWorkflow();
|
||||||
wf.graph.$START = {
|
wf.graph.$START = {
|
||||||
_: { role: "writer", prompt: "Begin", location: null },
|
new: { role: "writer", prompt: "Begin", location: null },
|
||||||
other: { role: "reviewer", prompt: "Also", location: null },
|
|
||||||
};
|
};
|
||||||
const errors = validateWorkflow(wf);
|
const errors = validateWorkflow(wf);
|
||||||
expect(
|
expect(
|
||||||
errors.some((e) => e.includes('$START must have exactly one edge with status "_"')),
|
errors.some((e) => e.includes('$START must have edges with statuses "new" and "resume"')),
|
||||||
).toBe(true);
|
).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
test("2.3 $START edge uses non-_ status", () => {
|
test("2.3 $START missing new edge", () => {
|
||||||
const wf = makeWorkflow();
|
const wf = makeWorkflow();
|
||||||
wf.graph.$START = { ready: { role: "writer", prompt: "Begin", location: null } };
|
wf.graph.$START = {
|
||||||
|
resume: { role: "writer", prompt: "Resume", location: null },
|
||||||
|
};
|
||||||
const errors = validateWorkflow(wf);
|
const errors = validateWorkflow(wf);
|
||||||
expect(
|
expect(
|
||||||
errors.some((e) => e.includes('$START must have exactly one edge with status "_"')),
|
errors.some((e) => e.includes('$START must have edges with statuses "new" and "resume"')),
|
||||||
).toBe(true);
|
).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test("2.3b $START with new and resume passes", () => {
|
||||||
|
const wf = makeWorkflow();
|
||||||
|
wf.graph.$START = {
|
||||||
|
new: { role: "writer", prompt: "Begin", location: null },
|
||||||
|
resume: { role: "writer", prompt: "Resume", location: null },
|
||||||
|
};
|
||||||
|
const errors = validateWorkflow(wf);
|
||||||
|
expect(errors.some((e) => e.includes("$START must have edges"))).toBe(false);
|
||||||
|
});
|
||||||
|
|
||||||
test("2.4 $END has outgoing edges", () => {
|
test("2.4 $END has outgoing edges", () => {
|
||||||
const wf = makeWorkflow();
|
const wf = makeWorkflow();
|
||||||
wf.graph.$END = { _: { role: "writer", prompt: "Loop", location: null } };
|
wf.graph.$END = { _: { role: "writer", prompt: "Loop", location: null } };
|
||||||
@@ -193,15 +207,18 @@ describe("Suite 2: Graph Structure", () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
describe("Suite 3: Status-Edge Consistency", () => {
|
describe("Suite 3: Status-Edge Consistency", () => {
|
||||||
test("3.1 user role using _ graph key is rejected", () => {
|
test("3.1 user role using _ graph key is treated as an unknown status", () => {
|
||||||
|
// "_" is no longer special-cased — it's just a status key that does not
|
||||||
|
// match the role's $status enum, so it surfaces as extra/missing keys.
|
||||||
const wf = makeWorkflow();
|
const wf = makeWorkflow();
|
||||||
wf.graph.writer = { _: { role: "reviewer", prompt: "Review", location: null } };
|
wf.graph.writer = { _: { role: "reviewer", prompt: "Review", location: null } };
|
||||||
const errors = validateWorkflow(wf);
|
const errors = validateWorkflow(wf);
|
||||||
expect(
|
expect(errors.some((e) => e.includes('role "writer" graph has extra status keys: _'))).toBe(
|
||||||
errors.some((e) =>
|
true,
|
||||||
e.includes('role "writer" must use explicit $status keys in graph, not "_"'),
|
);
|
||||||
),
|
expect(errors.some((e) => e.includes('role "writer" graph is missing status keys: done'))).toBe(
|
||||||
).toBe(true);
|
true,
|
||||||
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
test("3.2 user role graph key not matching $status enum", () => {
|
test("3.2 user role graph key not matching $status enum", () => {
|
||||||
@@ -240,13 +257,16 @@ describe("Suite 3: Status-Edge Consistency", () => {
|
|||||||
).toBe(true);
|
).toBe(true);
|
||||||
});
|
});
|
||||||
|
|
||||||
test("3.5 multi-exit role with _ key", () => {
|
test("3.5 multi-exit role with _ key is treated as an unknown status", () => {
|
||||||
const wf = makeWorkflow();
|
const wf = makeWorkflow();
|
||||||
wf.graph.reviewer = { _: { role: "$END", prompt: "Done", location: null } };
|
wf.graph.reviewer = { _: { role: "$END", prompt: "Done", location: null } };
|
||||||
const errors = validateWorkflow(wf);
|
const errors = validateWorkflow(wf);
|
||||||
|
expect(errors.some((e) => e.includes('role "reviewer" graph has extra status keys: _'))).toBe(
|
||||||
|
true,
|
||||||
|
);
|
||||||
expect(
|
expect(
|
||||||
errors.some((e) =>
|
errors.some((e) =>
|
||||||
e.includes('role "reviewer" must use explicit $status keys in graph, not "_"'),
|
e.includes('role "reviewer" graph is missing status keys: approved, rejected'),
|
||||||
),
|
),
|
||||||
).toBe(true);
|
).toBe(true);
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -38,7 +38,10 @@ function makeMinimalPayload(name: string, description: string): WorkflowPayload
|
|||||||
},
|
},
|
||||||
},
|
},
|
||||||
graph: {
|
graph: {
|
||||||
$START: { _: { role: "worker", prompt: "start working", location: null } },
|
$START: {
|
||||||
|
new: { role: "worker", prompt: "start working", location: null },
|
||||||
|
resume: { role: "worker", prompt: "resume working", location: null },
|
||||||
|
},
|
||||||
worker: { done: { role: "$END", prompt: "done", location: null } },
|
worker: { done: { role: "$END", prompt: "done", location: null } },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|||||||
+4
-20
@@ -8,9 +8,7 @@ import {
|
|||||||
cmdPromptAdapterDeveloping,
|
cmdPromptAdapterDeveloping,
|
||||||
cmdPromptBootstrap,
|
cmdPromptBootstrap,
|
||||||
cmdPromptList,
|
cmdPromptList,
|
||||||
cmdPromptSetup,
|
|
||||||
cmdPromptUsage,
|
cmdPromptUsage,
|
||||||
cmdPromptUsageReference,
|
|
||||||
cmdPromptWorkflowAuthoring,
|
cmdPromptWorkflowAuthoring,
|
||||||
} from "./commands/prompt.js";
|
} from "./commands/prompt.js";
|
||||||
import { cmdSetup, cmdSetupInteractive } from "./commands/setup.js";
|
import { cmdSetup, cmdSetupInteractive } from "./commands/setup.js";
|
||||||
@@ -509,23 +507,16 @@ prompt.addHelpCommand(false);
|
|||||||
|
|
||||||
prompt
|
prompt
|
||||||
.command("usage")
|
.command("usage")
|
||||||
.description("Print the complete skill content (all references combined)")
|
.description("Print the usage reference (CLI guide + typical workflows)")
|
||||||
.action(() => {
|
.action(() => {
|
||||||
console.log(cmdPromptUsage());
|
console.log(cmdPromptUsage());
|
||||||
});
|
});
|
||||||
|
|
||||||
prompt
|
prompt
|
||||||
.command("setup")
|
.command("bootstrap")
|
||||||
.description("Print setup instructions for installing the uwf skill")
|
.description("Print setup instructions for installing uwf skills")
|
||||||
.action(() => {
|
.action(() => {
|
||||||
console.log(cmdPromptSetup());
|
console.log(cmdPromptBootstrap());
|
||||||
});
|
|
||||||
|
|
||||||
prompt
|
|
||||||
.command("usage-reference")
|
|
||||||
.description("Print the usage reference (CLI guide + typical workflows)")
|
|
||||||
.action(() => {
|
|
||||||
console.log(cmdPromptUsageReference());
|
|
||||||
});
|
});
|
||||||
|
|
||||||
prompt
|
prompt
|
||||||
@@ -542,13 +533,6 @@ prompt
|
|||||||
console.log(cmdPromptAdapterDeveloping());
|
console.log(cmdPromptAdapterDeveloping());
|
||||||
});
|
});
|
||||||
|
|
||||||
prompt
|
|
||||||
.command("bootstrap")
|
|
||||||
.description("Print the bootstrap skill YAML for Hermes agents")
|
|
||||||
.action(() => {
|
|
||||||
console.log(cmdPromptBootstrap());
|
|
||||||
});
|
|
||||||
|
|
||||||
prompt
|
prompt
|
||||||
.command("list")
|
.command("list")
|
||||||
.description("List all available prompt names")
|
.description("List all available prompt names")
|
||||||
|
|||||||
@@ -1,14 +1,13 @@
|
|||||||
import {
|
import {
|
||||||
generateAdapterDevelopingReference,
|
generateAdapterDevelopingReference,
|
||||||
generateBootstrapReference,
|
|
||||||
generateUsageReference,
|
generateUsageReference,
|
||||||
generateWorkflowAuthoringReference,
|
generateWorkflowAuthoringReference,
|
||||||
|
VERSION,
|
||||||
} from "@united-workforce/util";
|
} from "@united-workforce/util";
|
||||||
|
|
||||||
export {
|
export {
|
||||||
generateAdapterDevelopingReference as cmdPromptAdapterDeveloping,
|
generateAdapterDevelopingReference as cmdPromptAdapterDeveloping,
|
||||||
generateBootstrapReference as cmdPromptBootstrap,
|
generateUsageReference as cmdPromptUsage,
|
||||||
generateUsageReference as cmdPromptUsageReference,
|
|
||||||
generateWorkflowAuthoringReference as cmdPromptWorkflowAuthoring,
|
generateWorkflowAuthoringReference as cmdPromptWorkflowAuthoring,
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -16,24 +15,16 @@ const PROMPT_ENTRIES: ReadonlyArray<{ name: string; generate: () => string }> =
|
|||||||
{ name: "usage", generate: generateUsageReference },
|
{ name: "usage", generate: generateUsageReference },
|
||||||
{ name: "workflow-authoring", generate: generateWorkflowAuthoringReference },
|
{ name: "workflow-authoring", generate: generateWorkflowAuthoringReference },
|
||||||
{ name: "adapter-developing", generate: generateAdapterDevelopingReference },
|
{ name: "adapter-developing", generate: generateAdapterDevelopingReference },
|
||||||
{ name: "bootstrap", generate: generateBootstrapReference },
|
|
||||||
];
|
];
|
||||||
|
|
||||||
export function cmdPromptList(): ReadonlyArray<string> {
|
export function cmdPromptList(): ReadonlyArray<string> {
|
||||||
return PROMPT_ENTRIES.map((e) => e.name);
|
return PROMPT_ENTRIES.map((e) => e.name);
|
||||||
}
|
}
|
||||||
|
|
||||||
export function cmdPromptUsage(): string {
|
export function cmdPromptBootstrap(): string {
|
||||||
return PROMPT_ENTRIES.filter((e) => e.name !== "bootstrap")
|
return `# uwf Skill Bootstrap
|
||||||
.map((e) => e.generate())
|
|
||||||
.join("\n\n---\n\n");
|
|
||||||
}
|
|
||||||
|
|
||||||
export function cmdPromptSetup(): string {
|
Install or update the uwf (United Workforce) skills for your agent.
|
||||||
return `# uwf Skill Setup
|
|
||||||
|
|
||||||
You are being asked to install or update the uwf (United Workforce) skill
|
|
||||||
so that you know how to use the \`uwf\` CLI for workflow orchestration.
|
|
||||||
|
|
||||||
## Steps
|
## Steps
|
||||||
|
|
||||||
@@ -42,40 +33,30 @@ so that you know how to use the \`uwf\` CLI for workflow orchestration.
|
|||||||
uwf --help
|
uwf --help
|
||||||
\`\`\`
|
\`\`\`
|
||||||
If not installed: \`npm install -g @united-workforce/cli\`
|
If not installed: \`npm install -g @united-workforce/cli\`
|
||||||
|
Current version: ${VERSION}
|
||||||
|
|
||||||
2. **Clean up old versions of the skill** (if any exist):
|
2. **Install the skills** by running each command below and creating a skill from its output:
|
||||||
- Look for any existing uwf/workflow skill files in your skill directories
|
- Run \`uwf prompt usage\` → create a skill named \`uwf-usage\`
|
||||||
(e.g. \`~/.hermes/skills/uwf/SKILL.md\` or similar paths).
|
- Run \`uwf prompt workflow-authoring\` → create a skill named \`uwf-workflow-authoring\`
|
||||||
- If a skill exists, read its \`version\` from the YAML frontmatter.
|
- Run \`uwf prompt adapter-developing\` → create a skill named \`uwf-adapter-developing\`
|
||||||
- If the version matches the current CLI version (\`uwf --version\`), you're done — no update needed.
|
|
||||||
- If the version is older, **delete the old skill file** before proceeding.
|
|
||||||
|
|
||||||
3. **Install the bootstrap skill:**
|
Each command outputs a complete SKILL.md with YAML frontmatter — use your agent framework's skill creation API to save them.
|
||||||
\`\`\`bash
|
|
||||||
uwf prompt bootstrap > ~/.hermes/skills/uwf/SKILL.md
|
|
||||||
\`\`\`
|
|
||||||
The bootstrap prompt already includes complete YAML frontmatter — no editing needed.
|
|
||||||
|
|
||||||
4. **Verify** the skill is loadable by your agent framework.
|
3. **Verify** the skills are loadable by your agent framework.
|
||||||
|
|
||||||
## Individual prompts
|
## Updating
|
||||||
|
|
||||||
Each prompt outputs a complete SKILL.md with frontmatter — pipe directly to a file:
|
When \`uwf\` is upgraded, re-run \`uwf prompt bootstrap\` and follow the steps again.
|
||||||
|
The skill content is bundled with the CLI — always use \`uwf prompt <name>\` to get
|
||||||
|
content matching your installed version.
|
||||||
|
|
||||||
|
## Available prompts
|
||||||
|
|
||||||
\`\`\`bash
|
\`\`\`bash
|
||||||
uwf prompt list # list available prompt names
|
uwf prompt list # list available prompt names
|
||||||
uwf prompt usage > ~/.hermes/skills/uwf-usage/SKILL.md # CLI usage guide
|
uwf prompt usage # CLI usage guide
|
||||||
uwf prompt workflow-authoring > ~/.hermes/skills/uwf-workflow-authoring/SKILL.md
|
uwf prompt workflow-authoring # workflow YAML design guide
|
||||||
uwf prompt adapter-developing > ~/.hermes/skills/uwf-adapter-developing/SKILL.md
|
uwf prompt adapter-developing # building agent adapters
|
||||||
uwf prompt bootstrap > ~/.hermes/skills/uwf/SKILL.md # bootstrap skill
|
|
||||||
\`\`\`
|
\`\`\`
|
||||||
|
|
||||||
## Notes
|
|
||||||
|
|
||||||
- The skill content is bundled with the CLI and versioned with it — always use
|
|
||||||
\`uwf prompt usage\` to get the content matching your installed version.
|
|
||||||
- Do NOT hand-edit the skill body. If the CLI is updated, re-run \`uwf prompt setup\`
|
|
||||||
and follow the steps again.
|
|
||||||
- When upgrading, always delete the old skill first to avoid stale instructions.
|
|
||||||
`;
|
`;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -911,7 +911,7 @@ function resolveEvaluateArgs(
|
|||||||
chain: ChainState,
|
chain: ChainState,
|
||||||
): { lastRole: string; lastOutput: EvaluateLastOutput } {
|
): { lastRole: string; lastOutput: EvaluateLastOutput } {
|
||||||
if (chain.headIsStart) {
|
if (chain.headIsStart) {
|
||||||
return { lastRole: START_ROLE, lastOutput: { [STATUS_KEY]: "_" } };
|
return { lastRole: START_ROLE, lastOutput: { [STATUS_KEY]: "new" } };
|
||||||
}
|
}
|
||||||
|
|
||||||
const lastStep = chain.stepsNewestFirst[0];
|
const lastStep = chain.stepsNewestFirst[0];
|
||||||
@@ -1037,7 +1037,6 @@ function archiveThread(uwf: UwfStore, threadId: ThreadId, _workflow: CasRef, _he
|
|||||||
completeThread(uwf.varStore, threadId, "completed");
|
completeThread(uwf.varStore, threadId, "completed");
|
||||||
}
|
}
|
||||||
|
|
||||||
// biome-ignore lint/complexity/noExcessiveCognitiveComplexity: orchestration function with inherent branching
|
|
||||||
export async function cmdThreadResume(
|
export async function cmdThreadResume(
|
||||||
storageRoot: string,
|
storageRoot: string,
|
||||||
threadId: ThreadId,
|
threadId: ThreadId,
|
||||||
@@ -1101,7 +1100,7 @@ export async function cmdThreadResume(
|
|||||||
|
|
||||||
// status === "completed"
|
// status === "completed"
|
||||||
const workflow = loadWorkflowPayload(uwf, workflowHash);
|
const workflow = loadWorkflowPayload(uwf, workflowHash);
|
||||||
const startResult = evaluate(workflow.graph, START_ROLE, {});
|
const startResult = evaluate(workflow.graph, START_ROLE, { [STATUS_KEY]: "resume" });
|
||||||
if (!startResult.ok) {
|
if (!startResult.ok) {
|
||||||
fail(`failed to evaluate $START: ${startResult.error.message}`);
|
fail(`failed to evaluate $START: ${startResult.error.message}`);
|
||||||
}
|
}
|
||||||
@@ -1113,11 +1112,7 @@ export async function cmdThreadResume(
|
|||||||
}
|
}
|
||||||
|
|
||||||
const startRole = startResult.value.role;
|
const startRole = startResult.value.role;
|
||||||
const completedPromptPrefix = "Previous run completed. Resuming with additional context.";
|
const completedResumePrompt = buildResumePrompt(startResult.value.prompt, supplement);
|
||||||
const completedResumePrompt =
|
|
||||||
supplement !== null && supplement !== ""
|
|
||||||
? `${completedPromptPrefix}\n\n${supplement}`
|
|
||||||
: completedPromptPrefix;
|
|
||||||
|
|
||||||
const updatedEntry = { ...entry, status: "idle" as const, completedAt: null };
|
const updatedEntry = { ...entry, status: "idle" as const, completedAt: null };
|
||||||
setThread(uwf.varStore, threadId, updatedEntry);
|
setThread(uwf.varStore, threadId, updatedEntry);
|
||||||
|
|||||||
@@ -6,11 +6,11 @@ describe("Edge prompt template variable resolution", () => {
|
|||||||
test("returns error when rendered prompt is empty string", () => {
|
test("returns error when rendered prompt is empty string", () => {
|
||||||
const graph = {
|
const graph = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "classifier", prompt: "{{{userPrompt}}}", location: null },
|
new: { role: "classifier", prompt: "{{{userPrompt}}}", location: null },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const result = evaluate(graph, "$START", {});
|
const result = evaluate(graph, "$START", { $status: "new" });
|
||||||
|
|
||||||
expect(result.ok).toBe(false);
|
expect(result.ok).toBe(false);
|
||||||
if (!result.ok) {
|
if (!result.ok) {
|
||||||
@@ -22,11 +22,11 @@ describe("Edge prompt template variable resolution", () => {
|
|||||||
test("returns error when rendered prompt is whitespace-only", () => {
|
test("returns error when rendered prompt is whitespace-only", () => {
|
||||||
const graph = {
|
const graph = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "classifier", prompt: " {{{userPrompt}}} ", location: null },
|
new: { role: "classifier", prompt: " {{{userPrompt}}} ", location: null },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const result = evaluate(graph, "$START", {});
|
const result = evaluate(graph, "$START", { $status: "new" });
|
||||||
|
|
||||||
expect(result.ok).toBe(false);
|
expect(result.ok).toBe(false);
|
||||||
if (!result.ok) {
|
if (!result.ok) {
|
||||||
@@ -38,11 +38,11 @@ describe("Edge prompt template variable resolution", () => {
|
|||||||
test("succeeds when all template variables resolve to non-empty values", () => {
|
test("succeeds when all template variables resolve to non-empty values", () => {
|
||||||
const graph = {
|
const graph = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "classifier", prompt: "{{{userPrompt}}}", location: null },
|
new: { role: "classifier", prompt: "{{{userPrompt}}}", location: null },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const result = evaluate(graph, "$START", { userPrompt: "Fix the bug" });
|
const result = evaluate(graph, "$START", { $status: "new", userPrompt: "Fix the bug" });
|
||||||
|
|
||||||
expect(result.ok).toBe(true);
|
expect(result.ok).toBe(true);
|
||||||
if (result.ok) {
|
if (result.ok) {
|
||||||
@@ -53,11 +53,11 @@ describe("Edge prompt template variable resolution", () => {
|
|||||||
test("succeeds with static (no-variable) prompt", () => {
|
test("succeeds with static (no-variable) prompt", () => {
|
||||||
const graph = {
|
const graph = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "classifier", prompt: "Classify this input", location: null },
|
new: { role: "classifier", prompt: "Classify this input", location: null },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const result = evaluate(graph, "$START", {});
|
const result = evaluate(graph, "$START", { $status: "new" });
|
||||||
|
|
||||||
expect(result.ok).toBe(true);
|
expect(result.ok).toBe(true);
|
||||||
if (result.ok) {
|
if (result.ok) {
|
||||||
@@ -68,11 +68,11 @@ describe("Edge prompt template variable resolution", () => {
|
|||||||
test("succeeds when prompt has mix of static text and unresolved variables", () => {
|
test("succeeds when prompt has mix of static text and unresolved variables", () => {
|
||||||
const graph = {
|
const graph = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "classifier", prompt: "Please handle: {{{userPrompt}}}", location: null },
|
new: { role: "classifier", prompt: "Please handle: {{{userPrompt}}}", location: null },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const result = evaluate(graph, "$START", {});
|
const result = evaluate(graph, "$START", { $status: "new" });
|
||||||
|
|
||||||
expect(result.ok).toBe(true);
|
expect(result.ok).toBe(true);
|
||||||
if (result.ok) {
|
if (result.ok) {
|
||||||
@@ -83,11 +83,11 @@ describe("Edge prompt template variable resolution", () => {
|
|||||||
test("returns error when ALL variables missing and no static text remains", () => {
|
test("returns error when ALL variables missing and no static text remains", () => {
|
||||||
const graph = {
|
const graph = {
|
||||||
$START: {
|
$START: {
|
||||||
_: { role: "classifier", prompt: "{{{a}}}{{{b}}}", location: null },
|
new: { role: "classifier", prompt: "{{{a}}}{{{b}}}", location: null },
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
const result = evaluate(graph, "$START", {});
|
const result = evaluate(graph, "$START", { $status: "new" });
|
||||||
|
|
||||||
expect(result.ok).toBe(false);
|
expect(result.ok).toBe(false);
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -6,10 +6,7 @@ import type { EvaluateResult, Result } from "./types.js";
|
|||||||
// Disable HTML escaping — prompts are plain text, not HTML.
|
// Disable HTML escaping — prompts are plain text, not HTML.
|
||||||
mustache.escape = (text: string) => text;
|
mustache.escape = (text: string) => text;
|
||||||
|
|
||||||
const START_ROLE = "$START";
|
|
||||||
const SUSPEND_ROLE = "$SUSPEND";
|
const SUSPEND_ROLE = "$SUSPEND";
|
||||||
// $START is a special entry node with no agent output — it always uses this key.
|
|
||||||
const START_STATUS = "_";
|
|
||||||
|
|
||||||
type LastOutput = Record<string, unknown>;
|
type LastOutput = Record<string, unknown>;
|
||||||
|
|
||||||
@@ -21,9 +18,7 @@ export function evaluate(
|
|||||||
lastOutput: LastOutput,
|
lastOutput: LastOutput,
|
||||||
): Result<EvaluateResult, Error> {
|
): Result<EvaluateResult, Error> {
|
||||||
let status: string;
|
let status: string;
|
||||||
if (lastRole === START_ROLE) {
|
if (typeof lastOutput[STATUS_KEY] === "string") {
|
||||||
status = START_STATUS;
|
|
||||||
} else if (typeof lastOutput[STATUS_KEY] === "string") {
|
|
||||||
status = lastOutput[STATUS_KEY] as string;
|
status = lastOutput[STATUS_KEY] as string;
|
||||||
} else {
|
} else {
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -97,9 +97,9 @@ function checkGraphStructure(payload: WorkflowPayload, errors: string[]): void {
|
|||||||
if (!graphNodes.has("$START")) {
|
if (!graphNodes.has("$START")) {
|
||||||
errors.push("$START must be defined in graph");
|
errors.push("$START must be defined in graph");
|
||||||
} else {
|
} else {
|
||||||
const startKeys = Object.keys(payload.graph.$START);
|
const startKeys = new Set(Object.keys(payload.graph.$START));
|
||||||
if (startKeys.length !== 1 || startKeys[0] !== "_") {
|
if (!startKeys.has("new") || !startKeys.has("resume")) {
|
||||||
errors.push('$START must have exactly one edge with status "_"');
|
errors.push('$START must have edges with statuses "new" and "resume"');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -190,22 +190,13 @@ function checkOneOfDiscriminant(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/** Check status-edge consistency for a user role. "_" is reserved for $START and rejected here. */
|
/** Check status-edge consistency for a user role. */
|
||||||
function checkStatusEdges(
|
function checkStatusEdges(
|
||||||
roleName: string,
|
roleName: string,
|
||||||
graphKeys: Set<string>,
|
graphKeys: Set<string>,
|
||||||
statusSet: Set<string>,
|
statusSet: Set<string>,
|
||||||
errors: string[],
|
errors: string[],
|
||||||
): void {
|
): void {
|
||||||
if (graphKeys.has("_")) {
|
|
||||||
errors.push(`role "${roleName}" must use explicit $status keys in graph, not "_"`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (statusSet.has("_")) {
|
|
||||||
errors.push(`role "${roleName}" $status enum must use explicit values, not "_"`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const extraKeys = [...graphKeys].filter((k) => !statusSet.has(k));
|
const extraKeys = [...graphKeys].filter((k) => !statusSet.has(k));
|
||||||
const missingKeys = [...statusSet].filter((k) => !graphKeys.has(k));
|
const missingKeys = [...statusSet].filter((k) => !graphKeys.has(k));
|
||||||
if (extraKeys.length > 0) {
|
if (extraKeys.length > 0) {
|
||||||
|
|||||||
@@ -57,13 +57,13 @@ function isGraph(value: unknown): boolean {
|
|||||||
if (!isRecord(value)) {
|
if (!isRecord(value)) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return Object.entries(value).every(([node, statusMap]) => {
|
return Object.values(value).every((statusMap) => {
|
||||||
if (!isRecord(statusMap)) {
|
if (!isRecord(statusMap)) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return Object.entries(statusMap).every(([status, target]) => {
|
return Object.entries(statusMap).every(([status, target]) => {
|
||||||
// "_" is only valid as a status key for the $START entry node.
|
// "_" is no longer a valid status key anywhere — $START uses "new"/"resume".
|
||||||
if (status === "_" && node !== "$START") {
|
if (status === "_") {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
return isTarget(target);
|
return isTarget(target);
|
||||||
|
|||||||
@@ -1,40 +0,0 @@
|
|||||||
export function generateBootstrapReference(): string {
|
|
||||||
return `---
|
|
||||||
name: uwf
|
|
||||||
description: "United Workforce (uwf) — YAML 状态机工作流引擎。任务涉及 workflow 时加载此 skill。"
|
|
||||||
tags: [workflow, uwf]
|
|
||||||
triggers:
|
|
||||||
- uwf
|
|
||||||
- workflow
|
|
||||||
- 工作流
|
|
||||||
---
|
|
||||||
|
|
||||||
# uwf (United Workforce)
|
|
||||||
|
|
||||||
YAML 状态机工作流引擎。当用户提到「workflow」「工作流」时,指的是 **uwf workflow**(YAML 定义的状态机),不是 Hermes skill。用 \`uwf\` CLI 操作,不要混淆。
|
|
||||||
|
|
||||||
## 首次使用
|
|
||||||
|
|
||||||
运行以下命令获取完整用法:
|
|
||||||
|
|
||||||
\`\`\`bash
|
|
||||||
uwf prompt usage # 完整用法文档(所有引用合并)
|
|
||||||
uwf prompt workflow-authoring # workflow 编写指南(role 定义、graph 路由、schema)
|
|
||||||
uwf prompt adapter-developing # adapter 开发指南(构建新的 agent adapter)
|
|
||||||
\`\`\`
|
|
||||||
|
|
||||||
## 快速参考
|
|
||||||
|
|
||||||
\`\`\`bash
|
|
||||||
uwf workflow list # 查看已注册 workflow
|
|
||||||
uwf workflow add <file.yaml> # 注册 workflow
|
|
||||||
uwf thread start <workflow> -p "prompt" # 创建 thread
|
|
||||||
uwf thread exec <thread-id> -c 10 # 执行最多 10 步
|
|
||||||
uwf thread list # 查看所有 thread
|
|
||||||
\`\`\`
|
|
||||||
|
|
||||||
## 示例 workflow
|
|
||||||
|
|
||||||
参考项目 \`examples/\` 目录下的 YAML 文件(analyze-topic、debate、solve-issue)。
|
|
||||||
`;
|
|
||||||
}
|
|
||||||
@@ -2,7 +2,6 @@ export { generateActorReference } from "./actor-reference.js";
|
|||||||
export { generateAdapterDevelopingReference } from "./adapter-developing-reference.js";
|
export { generateAdapterDevelopingReference } from "./adapter-developing-reference.js";
|
||||||
export { generateArchitectureReference } from "./architecture-reference.js";
|
export { generateArchitectureReference } from "./architecture-reference.js";
|
||||||
export { encodeUint64AsCrockford } from "./base32.js";
|
export { encodeUint64AsCrockford } from "./base32.js";
|
||||||
export { generateBootstrapReference } from "./bootstrap-reference.js";
|
|
||||||
export { generateCliReference } from "./cli-reference.js";
|
export { generateCliReference } from "./cli-reference.js";
|
||||||
export { env } from "./env.js";
|
export { env } from "./env.js";
|
||||||
export type {
|
export type {
|
||||||
|
|||||||
@@ -16,7 +16,8 @@ The graph is a nested map: \`Record<Role | "$START", Record<Status, Target>>\`.
|
|||||||
\`\`\`yaml
|
\`\`\`yaml
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_: { role: planner, prompt: "Analyze the issue." }
|
new: { role: planner, prompt: "Analyze the issue." }
|
||||||
|
resume: { role: planner, prompt: "Review the previous run output and continue." }
|
||||||
planner:
|
planner:
|
||||||
ready: { role: developer, prompt: "Implement the plan (CAS hash: {{{plan}}})." }
|
ready: { role: developer, prompt: "Implement the plan (CAS hash: {{{plan}}})." }
|
||||||
insufficient_info: { role: $END, prompt: "Not enough info." }
|
insufficient_info: { role: $END, prompt: "Not enough info." }
|
||||||
@@ -41,7 +42,7 @@ Edge prompts use triple-brace Mustache syntax (\`{{{field}}}\`) to interpolate v
|
|||||||
|
|
||||||
## Special Nodes
|
## Special Nodes
|
||||||
|
|
||||||
- \`$START\` — entry point; uses status key \`_\` (unconditional) since there is no previous output
|
- \`$START\` — entry point; uses status keys \`new\` (first start) and \`resume\` (resuming a completed thread)
|
||||||
- \`$END\` — terminal node; thread completes when reached and is moved to history
|
- \`$END\` — terminal node; thread completes when reached and is moved to history
|
||||||
|
|
||||||
## Integration with Steps
|
## Integration with Steps
|
||||||
|
|||||||
@@ -40,7 +40,8 @@ roles: # named actors
|
|||||||
|
|
||||||
graph: # status-based routing
|
graph: # status-based routing
|
||||||
$START:
|
$START:
|
||||||
_: { role: planner, prompt: "Analyze the issue." }
|
new: { role: planner, prompt: "Analyze the issue." }
|
||||||
|
resume: { role: planner, prompt: "Review the previous run output and continue." }
|
||||||
planner:
|
planner:
|
||||||
ready: { role: developer, prompt: "Implement {{{plan}}}." }
|
ready: { role: developer, prompt: "Implement {{{plan}}}." }
|
||||||
failed: { role: $END, prompt: "Failed: {{{error}}}" }
|
failed: { role: $END, prompt: "Failed: {{{error}}}" }
|
||||||
@@ -113,7 +114,7 @@ graph[role][$status] → { role: nextRole, prompt: edgePrompt }
|
|||||||
|
|
||||||
| Node | Purpose |
|
| Node | Purpose |
|
||||||
|------|---------|
|
|------|---------|
|
||||||
| \`$START\` | Entry point — status key is always \`_\` (unconditional) |
|
| \`$START\` | Entry point — status keys \`new\` (first start) and \`resume\` (resuming a completed thread) |
|
||||||
| \`$END\` | Terminal — thread completes and is archived |
|
| \`$END\` | Terminal — thread completes and is archived |
|
||||||
|
|
||||||
### Edge Prompts
|
### Edge Prompts
|
||||||
@@ -178,7 +179,7 @@ ocas get <output-hash>
|
|||||||
1. Every \`$status\` value in a role's frontmatter has a matching edge in the graph
|
1. Every \`$status\` value in a role's frontmatter has a matching edge in the graph
|
||||||
2. Every field referenced in edge prompts (\`{{{field}}}\`) exists in the source role's schema
|
2. Every field referenced in edge prompts (\`{{{field}}}\`) exists in the source role's schema
|
||||||
3. Every role referenced in the graph exists in \`roles\`
|
3. Every role referenced in the graph exists in \`roles\`
|
||||||
4. \`$START\` has exactly one edge with key \`_\`
|
4. \`$START\` has edges with keys \`new\` and \`resume\`
|
||||||
5. At least one path leads to \`$END\`
|
5. At least one path leads to \`$END\`
|
||||||
6. No orphan roles (defined but never routed to)
|
6. No orphan roles (defined but never routed to)
|
||||||
|
|
||||||
|
|||||||
@@ -32,7 +32,8 @@ roles: # named actors in the workflow
|
|||||||
|
|
||||||
graph: # status-based routing (nested map)
|
graph: # status-based routing (nested map)
|
||||||
$START:
|
$START:
|
||||||
_: { role: planner, prompt: "Analyze the issue." }
|
new: { role: planner, prompt: "Analyze the issue." }
|
||||||
|
resume: { role: planner, prompt: "Review the previous run output and continue." }
|
||||||
planner:
|
planner:
|
||||||
ready: { role: developer, prompt: "Implement plan {{{plan}}}." }
|
ready: { role: developer, prompt: "Implement plan {{{plan}}}." }
|
||||||
insufficient_info: { role: $END, prompt: "Not enough info." }
|
insufficient_info: { role: $END, prompt: "Not enough info." }
|
||||||
@@ -70,10 +71,10 @@ Record<Role | "$START", Record<Status, { role: string, prompt: string }>>
|
|||||||
| Level | Key | Value |
|
| Level | Key | Value |
|
||||||
|-------|-----|-------|
|
|-------|-----|-------|
|
||||||
| Outer | Role name or \`$START\` | Status map for that role |
|
| Outer | Role name or \`$START\` | Status map for that role |
|
||||||
| Inner | \`$status\` value (or \`_\` for unconditional) | Target: \`{ role, prompt }\` |
|
| Inner | \`$status\` value | Target: \`{ role, prompt }\` |
|
||||||
|
|
||||||
### Special Nodes
|
### Special Nodes
|
||||||
- \`$START\` — entry point; uses status key \`_\` (unconditional, no previous output)
|
- \`$START\` — entry point; uses status keys \`new\` (first start) and \`resume\` (resuming a completed thread)
|
||||||
- \`$END\` — terminal node; thread completes when reached
|
- \`$END\` — terminal node; thread completes when reached
|
||||||
|
|
||||||
### Edge Prompts
|
### Edge Prompts
|
||||||
|
|||||||
@@ -21,9 +21,12 @@ graph:
|
|||||||
role: package-metadata
|
role: package-metadata
|
||||||
prompt: Biome setup failed ({{{reason}}}), but continue. Standardize package metadata for repo at {{{repoPath}}}.
|
prompt: Biome setup failed ({{{reason}}}), but continue. Standardize package metadata for repo at {{{repoPath}}}.
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: workspace
|
role: workspace
|
||||||
prompt: Set up bun workspace structure for repo at {{{repoPath}}}.
|
prompt: Set up bun workspace structure for repo at {{{repoPath}}}.
|
||||||
|
resume:
|
||||||
|
role: workspace
|
||||||
|
prompt: Review the previous run output and continue setting up the bun workspace structure for repo at {{{repoPath}}}.
|
||||||
release:
|
release:
|
||||||
done:
|
done:
|
||||||
role: testing
|
role: testing
|
||||||
|
|||||||
@@ -283,9 +283,12 @@ roles:
|
|||||||
- error
|
- error
|
||||||
graph:
|
graph:
|
||||||
$START:
|
$START:
|
||||||
_:
|
new:
|
||||||
role: planner
|
role: planner
|
||||||
prompt: Analyze the issue and produce an implementation plan.
|
prompt: Analyze the issue and produce an implementation plan.
|
||||||
|
resume:
|
||||||
|
role: planner
|
||||||
|
prompt: Review the previous run output and continue the work.
|
||||||
planner:
|
planner:
|
||||||
insufficient_info:
|
insufficient_info:
|
||||||
role: $SUSPEND
|
role: $SUSPEND
|
||||||
|
|||||||
Reference in New Issue
Block a user