Function readSqliteShellRun

packages/storage/src/shell-run-store.ts:114–129

(
  db: import('node:sqlite').DatabaseSync,
  sessionId: string,
  shellRunId: string,
)

}

function readSqliteShellRun(
  db: import('node:sqlite').DatabaseSync,
  sessionId: string,
  shellRunId: string,
): ShellRunRecord {
  const row = db
    .prepare(`
      SELECT record_json
      FROM core_shell_runs
      WHERE session_id = ? AND shell_run_id = ?
    `)
    .get(sessionId, shellRunId) as { record_json?: unknown } | undefined;
  if (!row) throw shellRunNotFoundError(shellRunId);
  if (typeof row.record_json !== 'string') throw new Error('Invalid SQLite ShellRun row');
  return normalizeShellRunRecord(JSON.parse(row.record_json), sessionId, shellRunId);
}

function sanitizeJson(_key: string, value: unknown): unknown {
  return value === undefined ? undefined : value;