cb57093d03
## Summary Wave 17 organizes Fusion into **domain folders** (stacks on #2397). ### Layout - **core/types/** — board, task, agents, settings, merge, workflow, mesh, … - **core/src/** — agents, ai, async-stores, workflows, tasks, config, db, … - **dashboard/app/api/** — client, tasks, agents, git, missions, planning, … - **engine/src/** — agents, auth, execution, merge, missions, overseer, worktree, … Root keepers retained for large entrypoints (`store.ts`, `executor.ts`, `merger.ts`, …). Public barrels (`@fusion/core`, `@fusion/engine`, `app/api.ts` → legacy) stay stable. ## Test plan - [x] `@fusion/core` typecheck - [x] `@fusion/engine` typecheck (pre-existing playwright-core noise only) - [ ] CI merge gate **Stack:** #2394 → #2397 → **this PR**
74 lines
2.4 KiB
TypeScript
74 lines
2.4 KiB
TypeScript
import type { WorkflowIrNode } from "@fusion/core";
|
|
|
|
import type {
|
|
WorkflowNodeExecutionContext,
|
|
WorkflowNodeHandler,
|
|
WorkflowNodeResult,
|
|
} from "./workflow-graph-executor.js";
|
|
|
|
export type WorkflowNodeRunnerKind = WorkflowIrNode["kind"];
|
|
|
|
export type WorkflowNodeRunnerContext = WorkflowNodeExecutionContext;
|
|
|
|
export interface WorkflowNodeRunner {
|
|
readonly kind: WorkflowNodeRunnerKind;
|
|
run(node: WorkflowIrNode, context: WorkflowNodeRunnerContext): Promise<WorkflowNodeResult>;
|
|
}
|
|
|
|
export type WorkflowNodeRunnerMap = Partial<Record<WorkflowNodeRunnerKind, WorkflowNodeRunner>>;
|
|
|
|
export interface WorkflowNodeRunnerRegistryOptions {
|
|
runners?: Iterable<WorkflowNodeRunner>;
|
|
handlers?: Partial<Record<WorkflowNodeRunnerKind, WorkflowNodeHandler>>;
|
|
}
|
|
|
|
/*
|
|
FNXC:WorkflowNodeRunners 2026-07-01-00:00:
|
|
Workflow node behavior is being extracted from monolithic executor/reviewer/triage paths into typed engine-owned runners while workflow definitions remain declarative.
|
|
This registry is intentionally an adapter first: it preserves the existing WorkflowNodeHandler call contract and lets later units move node kinds one at a time without changing graph traversal semantics.
|
|
*/
|
|
export class WorkflowNodeRunnerRegistry {
|
|
private readonly runners = new Map<WorkflowNodeRunnerKind, WorkflowNodeRunner>();
|
|
|
|
public constructor(options: WorkflowNodeRunnerRegistryOptions = {}) {
|
|
if (options.handlers) {
|
|
for (const [kind, handler] of Object.entries(options.handlers) as Array<[
|
|
WorkflowNodeRunnerKind,
|
|
WorkflowNodeHandler | undefined,
|
|
]>) {
|
|
if (handler) this.register(handlerBackedRunner(kind, handler));
|
|
}
|
|
}
|
|
|
|
for (const runner of options.runners ?? []) {
|
|
this.register(runner);
|
|
}
|
|
}
|
|
|
|
public register(runner: WorkflowNodeRunner): void {
|
|
this.runners.set(runner.kind, runner);
|
|
}
|
|
|
|
public get(kind: WorkflowNodeRunnerKind): WorkflowNodeRunner | undefined {
|
|
return this.runners.get(kind);
|
|
}
|
|
|
|
public toHandlers(): Partial<Record<WorkflowNodeRunnerKind, WorkflowNodeHandler>> {
|
|
const handlers: Partial<Record<WorkflowNodeRunnerKind, WorkflowNodeHandler>> = {};
|
|
for (const [kind, runner] of this.runners) {
|
|
handlers[kind] = (node, context) => runner.run(node, context);
|
|
}
|
|
return handlers;
|
|
}
|
|
}
|
|
|
|
export function handlerBackedRunner(
|
|
kind: WorkflowNodeRunnerKind,
|
|
handler: WorkflowNodeHandler,
|
|
): WorkflowNodeRunner {
|
|
return {
|
|
kind,
|
|
run: (node, context) => handler(node, context),
|
|
};
|
|
}
|