scripts/retry-transient-ci-run.ts

Rama main · réplica de lectura del repositorio original.

import { spawnSync } from 'node:child_process'
import { argv, env, exit } from 'node:process'

export type TransientCiJobFailure = 'runner_shutdown' | 'supabase_docker_image_pull' | 'supabase_docker_port_bind' | 'supabase_edge_runtime_health_check'

interface WorkflowJobStep {
  conclusion: string | null
  name: string
}

interface WorkflowJob {
  conclusion: string | null
  id: number
  name: string
  steps?: WorkflowJobStep[]
}

interface WorkflowJobsResponse {
  jobs: WorkflowJob[]
}

interface WorkflowRunResponse {
  conclusion: string | null
  run_attempt: number
  status: string
}

const RUNNER_SHUTDOWN_TRAILER = /##\[error\]The runner has received a shutdown signal\.[\s\S]{0,1000}##\[error\]Process completed with exit code 143\.[\s\S]{0,1000}Cleaning up orphan processes(?:\r?\n[^\r\n]*Terminate orphan process: pid \(\d+\) \([^)]+\))*\s*$/i
const GITHUB_READ_ATTEMPTS = 3
const GITHUB_READ_RETRY_DELAY_MS = 1000
const TRANSIENT_GITHUB_READ_FAILURE = /(?:HTTP (?:500|502|503|504)\b|error connecting to api\.github\.com|connection reset by peer|TLS handshake timeout|unexpected EOF)/i

export function getTransientCiJobFailure(
  output: string,
  failedStepNames: string[],
): TransientCiJobFailure | null {
  if (RUNNER_SHUTDOWN_TRAILER.test(output))
    return 'runner_shutdown'

  if (!failedStepNames.some(name => /Supabase Start/i.test(name)))
    return null

  const terminalClassifications = [...output.matchAll(/SUPABASE_START_FINAL_FAILURE=(docker_image_pull|docker_port_bind|edge_runtime_health_check|non_transient)/g)]
  const startupFailure = terminalClassifications.at(-1)?.[1] ?? null
  if (startupFailure === 'docker_image_pull')
    return 'supabase_docker_image_pull'
  if (startupFailure === 'docker_port_bind')
    return 'supabase_docker_port_bind'
  if (startupFailure === 'edge_runtime_health_check')
    return 'supabase_edge_runtime_health_check'
  return null
}

export function isTransientGitHubReadFailure(output: string): boolean {
  return TRANSIENT_GITHUB_READ_FAILURE.test(output)
}

function wait(milliseconds: number): void {
  Atomics.wait(new Int32Array(new SharedArrayBuffer(4)), 0, 0, milliseconds)
}

function runGh(args: string[], retryTransientReadFailure = false): string {
  for (let attempt = 1; attempt <= GITHUB_READ_ATTEMPTS; attempt++) {
    const result = spawnSync('gh', args, {
      encoding: 'utf8',
      env,
      maxBuffer: 50 * 1024 * 1024,
    })
    if (result.status === 0)
      return result.stdout

    const details = result.stderr.trim() || result.stdout.trim() || `exit ${result.status ?? 'unknown'}`
    if (!retryTransientReadFailure || !isTransientGitHubReadFailure(details) || attempt === GITHUB_READ_ATTEMPTS)
      throw new Error(`gh ${args.join(' ')} failed: ${details}`)

    console.warn(`Transient GitHub API read failure (attempt ${attempt}/${GITHUB_READ_ATTEMPTS}); retrying.`)
    wait(GITHUB_READ_RETRY_DELAY_MS * attempt)
  }

  throw new Error('Unreachable GitHub API retry state')
}

function readJson<T>(args: string[]): T {
  return JSON.parse(runGh(args, true)) as T
}

function main(): void {
  const [repository, runId] = argv.slice(2)
  if (!repository || !runId || !/^\d+$/.test(runId)) {
    console.error('Usage: bun scripts/retry-transient-ci-run.ts <owner/repository> <run-id>')
    exit(2)
  }

  const run = readJson<WorkflowRunResponse>(['api', `repos/${repository}/actions/runs/${runId}`])
  if (run.run_attempt !== 1 || run.status !== 'completed' || run.conclusion !== 'failure') {
    console.log(`Run ${runId} is not an eligible first-attempt failure; no retry requested.`)
    return
  }

  const jobs = readJson<WorkflowJobsResponse>([
    'api',
    `repos/${repository}/actions/runs/${runId}/attempts/${run.run_attempt}/jobs?per_page=100`,
  ]).jobs
  const failedJobs = jobs.filter(job => job.conclusion === 'failure')
  if (failedJobs.length === 0) {
    console.log(`Run ${runId} has no failed jobs to classify; no retry requested.`)
    return
  }

  const classifications = failedJobs.map((job) => {
    const log = runGh(['api', `repos/${repository}/actions/jobs/${job.id}/logs`], true)
    const failedStepNames = job.steps?.filter(step => step.conclusion === 'failure').map(step => step.name) ?? []
    return {
      failure: getTransientCiJobFailure(log, failedStepNames),
      job,
    }
  })

  for (const { failure, job } of classifications)
    console.log(`${job.name}: ${failure ?? 'not_transient'}`)

  if (classifications.some(({ failure }) => failure === null)) {
    console.log(`Run ${runId} includes a non-transient failure; no jobs will be retried.`)
    return
  }

  runGh(['api', '--method', 'POST', `repos/${repository}/actions/runs/${runId}/rerun-failed-jobs`])
  console.log(`Requested one retry of all failed jobs in run ${runId}.`)
}

if (import.meta.main) {
  try {
    main()
  }
  catch (error) {
    console.error(error instanceof Error ? error.message : String(error))
    exit(1)
  }
}