Function insertRun

packages/core/src/progress/store.ts:94–135

(input: StartRunInput)

}

export async function insertRun(input: StartRunInput): Promise<AgentRun> {
  await ensureTable();
  const client = getDbExec();
  const id = input.id ?? randomUUID();
  const now = Date.now();
  try {
    await client.execute({
      sql: `INSERT INTO progress_runs
        (id, owner, title, step, percent, status, metadata, started_at, updated_at, completed_at)
        VALUES (?, ?, ?, ?, NULL, 'running', ?, ?, ?, NULL)`,
      args: [
        id,
        input.owner,
        input.title,
        input.step ?? null,
        input.metadata ? JSON.stringify(input.metadata) : null,
        now,
        now,
      ],
    });
  } catch (err) {
    if (input.id && isUniqueViolation(err)) {
      throw new Error(
        `insertRun: run id "${input.id}" already exists for this owner`,
      );
    }
    throw err;
  }
  bumpPoll(input.owner);
  return {
    id,
    owner: input.owner,
    title: input.title,
    step: input.step,
    percent: null,
    status: "running",
    metadata: input.metadata,
    startedAt: new Date(now).toISOString(),
    updatedAt: new Date(now).toISOString(),
    completedAt: null,
  };
}

export async function getRun(
  id: string,