Function syncRunsFromSnapshot

packages/ai-devtools/src/store/hook-registry.ts:693–754

(
  state: HookRegistryState,
  snapshot: HookStateSnapshotEvent,
  eventId: string,
)

}

function syncRunsFromSnapshot(
  state: HookRegistryState,
  snapshot: HookStateSnapshotEvent,
  eventId: string,
): void {
  const rawRuns = (snapshot.state as { runs?: unknown }).runs
  if (!Array.isArray(rawRuns)) return
  for (const candidate of rawRuns) {
    if (!candidate || typeof candidate !== 'object') continue
    const run = candidate as {
      id?: unknown
      status?: unknown
      startedAt?: unknown
      updatedAt?: unknown
      completedAt?: unknown
      error?: unknown
    }
    if (typeof run.id !== 'string') continue
    const status = normalizeRunStatusFromSnapshot(run.status)
    if (status === null) {
      console.warn(
        `[ai-devtools] unknown run.status in snapshot for hook "${snapshot.hookId}": ${String(run.status)}; skipping run "${run.id}"`,
      )
      continue
    }
    const startedAt =
      typeof run.startedAt === 'number' ? run.startedAt : snapshot.timestamp
    const updatedAt =
      typeof run.updatedAt === 'number' ? run.updatedAt : startedAt
    const existing = state.runs[run.id]
    if (!existing) {
      state.runs[run.id] = {
        id: run.id,
        hookId: snapshot.hookId,
        status,
        startedAt,
        updatedAt,
        ...(typeof run.completedAt === 'number'
          ? { completedAt: run.completedAt }
          : isTerminalRunStatus(status)
            ? { completedAt: updatedAt }
            : {}),
        ...(typeof run.error === 'string' ? { error: run.error } : {}),
        eventIds: [eventId],
      }
    } else {
      existing.hookId = snapshot.hookId
      existing.status = status
      existing.updatedAt = updatedAt
      if (typeof run.completedAt === 'number') {
        existing.completedAt = run.completedAt
      } else if (isTerminalRunStatus(status) && !existing.completedAt) {
        existing.completedAt = updatedAt
      }
      if (typeof run.error === 'string') existing.error = run.error
      if (!existing.eventIds.includes(eventId)) {
        existing.eventIds.push(eventId)
      }