feat(workflow): query runs by workspace

Author: Waishnav

src/workflow-store.test.ts

@@ -135,6 +135,32 @@ try {
   assert.equal(store.getRun(run2.id)?.status, "completed");
   assert.equal(store.getRun(run2.id)?.resultJson, JSON.stringify({ ok: 1 }));
 
+  const otherProjectRun = store.createRun({
+    name: "other-project",
+    source: "inline",
+    scriptPath: join(root, "other.js"),
+    scriptHash: "other",
+    workspaceRoot: join(root, "other-project"),
+  });
+  assert.deepEqual(
+    store
+      .listRunsForWorkspace(join(root, "project"))
+      .map((entry) => entry.id)
+      .sort(),
+    [run.id, run2.id].sort(),
+  );
+  assert.deepEqual(
+    store
+      .listRunsForWorkspace(join(root, "project"), { statuses: ["completed"] })
+      .map((entry) => entry.id),
+    [run2.id],
+  );
+  assert.equal(
+    store.listRunsForWorkspace(join(root, "other-project"))[0]?.id,
+    otherProjectRun.id,
+  );
+  assert.deepEqual(store.listEvents(run.id, 2).map((event) => event.seq), [2, 3]);
+
   // Reap: stale heartbeat + dead pid (force heartbeat via shared sqlite handle)
   const run3 = store.createRun({
     name: "stale",

src/workflow-store.ts

@@ -248,6 +248,40 @@ export class WorkflowStore {
     return rows.map(rowToRun);
   }
 
+  listRunsForWorkspace(
+    workspaceRoot: string,
+    options: {
+      statuses?: WorkflowRunStatus[];
+      limit?: number;
+    } = {},
+  ): WorkflowRunRecord[] {
+    const root = resolve(workspaceRoot);
+    const limit = Math.max(1, Math.min(options.limit ?? 50, 500));
+    const statuses = options.statuses?.filter((status, index, values) =>
+      values.indexOf(status) === index,
+    );
+
+    if (!statuses?.length) {
+      const rows = this.database.sqlite
+        .prepare(
+          "select * from workflow_runs where workspace_root = ? order by updated_at desc limit ?",
+        )
+        .all(root, limit) as WorkflowRunRow[];
+      return rows.map(rowToRun);
+    }
+
+    const placeholders = statuses.map(() => "?").join(", ");
+    const rows = this.database.sqlite
+      .prepare(
+        `select * from workflow_runs
+         where workspace_root = ? and status in (${placeholders})
+         order by updated_at desc
+         limit ?`,
+      )
+      .all(root, ...statuses, limit) as WorkflowRunRow[];
+    return rows.map(rowToRun);
+  }
+
   /**
    * Atomically claim a starting run for the worker.
    * Returns undefined if the run is missing or not claimable.
@@ -570,6 +604,21 @@ export class WorkflowStore {
     };
   }
 
+  listEvents(runId: string, limit = 100): WorkflowEventRecord[] {
+    const capped = Math.max(1, Math.min(limit, WORKFLOW_LIMITS.eventDrainMax));
+    const rows = this.database.sqlite
+      .prepare(
+        `select * from (
+           select * from workflow_events
+           where run_id = ?
+           order by seq desc
+           limit ?
+         ) order by seq asc`,
+      )
+      .all(runId, capped) as WorkflowEventRow[];
+    return rows.map(rowToEvent);
+  }
+
   beginAgentCall(input: BeginAgentCallInput): WorkflowAgentCallRecord {
     const now = isoNow();
     const isolation: AgentIsolationMode = input.isolation === "worktree" ? "worktree" : "shared";