Configuration と可搬性

export interface Rider {
  run(spec: FlowSpec, inputs: JsonValue, deps: RunDeps): Promise<Run>;
  resume(runId: string, deps: RunDeps): Promise<Run>;
}

/**
 * エンジンが必要とするものはすべて注入される (T2/T4)。エンジンは
 * cloud SDK を import せず、global を読まず、clock/RNG/network/fs/secrets
 * にはこれらを通じてのみ触れる。実行場所を変えるには実装を差し替える。
 */
export interface RunDeps {
  store: Store;        // Run + Journal を永続化する (SQLite default)
  journal: Journal;    // append-only event sink
  tools: ToolHost;     // registry から ToolContracts を resolve + invoke する
  clock: Clock;        // now(): string — replay 中は決定論的
  random: Random;      // next(): number — seed 付き、replay 中は決定論的
  secrets: Secrets;    // resolve(ref): string — `secrets` 対応 tool のみ
  env: EnvView;        // allow-listed environment values
  logger: Logger;      // structured, secret-masked
  signal?: AbortSignal;// cancellation
}

// pseudo-shape, どの launcher でも約30行
async function launch(spec: FlowSpec, inputs: JsonValue) {
  const deps = buildRunDeps(env);     // 1. この環境用に capability を配線する
  const rider = createRider(config);  // 2. エンジンを構築する
  const run = await rider.run(spec, inputs, deps); // 3. 実行する
  return present(run);                // 4. host 向けに結果の形を整える
}

const rider = createRider({ maxConcurrency: 8 });