Function getPostgresErrorCode

packages/internal/src/db/transaction.ts:95–120

(error: unknown)

}

function getPostgresErrorCode(error: unknown): string | null {
  if (!error || typeof error !== 'object') {
    return null
  }

  let current: unknown = error
  const seen = new Set<object>()
  let depth = 0

  while (current && typeof current === 'object' && depth < MAX_ERROR_CAUSE_DEPTH) {
    if (seen.has(current)) {
      return null // Circular reference detected
    }
    seen.add(current)

    const record = current as Record<string, unknown>
    if (typeof record.code === 'string' && PG_ERROR_CODE_REGEX.test(record.code)) {
      return record.code
    }

    current = record.cause
    depth += 1
  }

  return null
}

/**
 * Checks if an error is a retryable PostgreSQL error.