Function getOwnerConfig

services/security-sync/src/sync.ts:277–405

(
  db: WorkerDb,
  owner: SecurityReviewOwner
)

function toSyncRunProgress(
  runId: string,
  result: SyncResult,
  completedRepos: string[],
  chunkIndex: number,
  noProgressChunks: number
): SyncRunProgressWrite {
  return {
    runId,
    completedRepos,
    staleRepos: result.staleRepos,
    authInvalidRepos: result.authInvalidRepos,
    synced: result.synced,
    errors: result.errors,
    skipped: result.skipped,
    authInvalid: result.authInvalid,
    reauthRequired: result.reauthRequired,
    noProgressChunks,
    chunkIndex,
  };
}

function readLastCompletedRunId(runtimeState: Record<string, unknown>): string | null {
  const value = runtimeState.last_completed_run_id;
  return typeof value === 'string' ? value : null;
}

function readSyncRunRunId(runtimeState: Record<string, unknown>): string | null {
  const value = runtimeState.sync_run;
  if (
    value &&
    typeof value === 'object' &&
    typeof (value as { runId?: unknown }).runId === 'string'
  ) {
    return (value as { runId: string }).runId;
  }
  return null;
}

type SyncLeaseReadOutcome =
  | { kind: 'completed' }
  | { kind: 'stale_chunk'; holderRunId: string | null; holderChunkIndex: number | null }
  | { kind: 'superseded'; holderRunId: string | null; holderChunkIndex: number | null };

/**
 * Classifies a runtime_state read that did not acquire the lease. `completed`
 * means this run already finished. `stale_chunk` means a newer chunk of this
 * same run holds the lease, or no different run id is visible at all (the lease
 * vanished in a millisecond race). `superseded` means a different run id is
 * actually visible on the lease or the cursor.
 */
function classifySyncLeaseRead(
  runtimeState: Record<string, unknown>,
  runId: string,
  chunkIndex: number
): SyncLeaseReadOutcome {
  if (readLastCompletedRunId(runtimeState) === runId) return { kind: 'completed' };
  const parsedLease = SyncLeaseSchema.safeParse(runtimeState.sync_lease);
  const lease = parsedLease.success ? parsedLease.data : null;