Run queries

import { createEngine } from "@sverka/runtime";
import type {
  RuntimeDriver,
  ShellExecuteRequest,
  ShellResult,
} from "@sverka/runtime";
import { join } from "node:path";
import { tmpdir } from "node:os";

const testDir = join(tmpdir(), "sverka-test");

const driver: RuntimeDriver = {
  name: "shell",
  canExecute: () => true,
  executeShell: async (req: ShellExecuteRequest): Promise<ShellResult> => ({
    exitCode: 0,
    stdout: "",
    stderr: "",
    durationMs: 1,
    timedOut: false,
  }),
};
const engine = createEngine({ drivers: [driver] });

// `plan` is a RunPlan — obtain it by binding a DefinitionGraph:
//   const graph = synthesize(project);
//   const plan = bindRunPlan({ graph, entryId: "ci/on-push" });
// See the Workflow API docs for full details.
// (Snippet is illustrative — replace `plan` with a real RunPlan before running.)
const plan = {} as never; // placeholder — not a valid RunPlan

const iter = engine.run({
  plan,
  workspace: "./ws",
  artifactDir: join(testDir, "art"),
});
for await (const event of iter) {
  if (event.type === "run-started") {
    // Query is available immediately after run-started
    const state = engine.query();
    console.log(state);
    // {
    //   runId: "run-123",
    //   planId: "rp-abc",
    //   status: "running",
    //   startedAt: 1725379200000,
    //   steps: [
    //     { stepId: "ci/lint", state: "pending" },
    //     { stepId: "ci/build", state: "pending" },
    //   ]
    // }
  }
  if (event.type === "step-succeeded") {
    const state = engine.query();
    const step = state?.steps.find((s) => s.stepId === event.stepId);
    console.log(`${step?.stepId}: ${step?.state} (${step?.durationMs}ms)`);
  }
}

interface RunState {
  runId: string;
  planId: string;
  status: "running" | "success" | "failure" | "cancelled" | "suspended";
  startedAt: number;
  steps: Array<{
    stepId: string;
    state:
      | "pending"
      | "ready"
      | "running"
      | "succeeded"
      | "failed"
      | "cancelled"
      | "skipped";
    durationMs?: number;
  }>;
}