HttpStatusBasedFailureDetector.php

<?php
declare(strict_types = 1);

namespace Interrupt\FailureDetectors;

use Interrupt\Contracts\FailureDetectorInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Detects failure based on HTTP Response Status Code (5xx range)
 */
class HttpStatusBasedFailureDetector implements FailureDetectorInterface {
  /**
   * @var int[]
   */
  protected array $failureCodes;

  /**
   * @link https://github.com/ackintosh/ganesha/blob/master/src/Ganesha/HttpClient/RestFailureDetector.php#L20-L41
   */
  public const FAILURE_CODES = [
    500, // Internal Server Error
    501, // Not Implemented
    502, // Bad Gateway
    503, // Service Unavailable
    504, // Gateway Timeout
    505, // HTTP Version Not Supported
    506, // Variant Also Negotiates
    507, // Insufficient Storage
    508, // Loop Detected
    509, // Bandwidth Limit Exceeded
    510, // Not Extended
    511, // Network Authentication Required
    520, // Origin Error
    521, // Origin Declined Request
    522, // Connection Timed Out
    523, // Proxy Declined Request
    524, // Timeout Occurred
    525, // SSL Handshake Failed
    526, // Invalid SSL Certificate
    527  // Railgun Error
  ];

  /**
   * @param int[] $failureCodes
   */
  public function __construct(array $failureCodes = []) {
    $this->failureCodes = $failureCodes ?: self::FAILURE_CODES;
  }

  public function isFailure(ResponseInterface $response): bool {
    return in_array($response->getStatusCode(), $this->failureCodes, true);
  }
}