/home/smartonegroup/public_html/veroserv/vendor/spatie/ray/src/Client.php
<?php

namespace Spatie\Ray;

use Exception;
use Spatie\Ray\Exceptions\StopExecutionRequested;
use Spatie\Ray\Origin\Hostname;

class Client
{
    protected static $cache = [];

    /** @var int */
    protected $portNumber;

    /** @var string */
    protected $host;

    /** @var string */
    protected $fingerprint;

    /** @var mixed */
    protected $curlHandle = null;

    public function __construct(int $portNumber = 23517, string $host = 'localhost')
    {
        $this->fingerprint = $host . ':' . $portNumber;

        $this->portNumber = $portNumber;

        $this->host = $host;
    }

    public function __destruct()
    {
        if ($this->curlHandle) {
            curl_close($this->curlHandle);
            $this->curlHandle = null;
        }
    }

    public function serverIsAvailable(): bool
    {
        // purge expired entries from the cache
        static::$cache = array_filter(static::$cache, function ($data) {
            return microtime(true) < $data[1];
        });

        if (! isset(static::$cache[$this->fingerprint])) {
            $this->performAvailabilityCheck();
        }

        return static::$cache[$this->fingerprint][0] ?? true;
    }

    public function performAvailabilityCheck(): bool
    {
        try {
            $curlHandle = $this->getCurlHandleForUrl('get', '_availability_check');

            curl_exec($curlHandle);

            $success = curl_errno($curlHandle) === CURLE_HTTP_NOT_FOUND;
            // expire the cache entry after 30 sec
            $expiresAt = microtime(true) + 30.0;

            static::$cache[$this->fingerprint] = [$success, $expiresAt];
        } finally {
            return $success ?? false;
        }
    }

    public function send(Request $request): void
    {
        if (! $this->serverIsAvailable()) {
            return;
        }

        $curlHandle = $this->getCurlHandleForUrl('get', '');

        $curlError = null;

        curl_setopt($this->curlHandle, CURLOPT_POSTFIELDS, $request->toJson());
        curl_exec($curlHandle);

        if (curl_errno($curlHandle)) {
            $curlError = curl_error($curlHandle);
        }

        if ($curlError) {
            // do nothing for now
        }
    }

    public function lockExists(string $lockName): bool
    {
        if (! $this->serverIsAvailable()) {
            return false;
        }

        $queryString = http_build_query([
            'hostname' => Hostname::get(),
            'project_name' => Ray::$projectName,
        ]);

        $curlHandle = $this->getCurlHandleForUrl('get', "locks/{$lockName}?{$queryString}");
        $curlError = null;

        try {
            $curlResult = curl_exec($curlHandle);

            if (curl_errno($curlHandle)) {
                $curlError = curl_error($curlHandle);
            }

            if ($curlError) {
                throw new Exception();
            }

            if (! $curlResult) {
                return false;
            }

            $response = json_decode($curlResult, true);

            if ($response['stop_execution'] ?? false) {
                throw StopExecutionRequested::make();
            }

            return $response['active'] ?? false;
        } catch (Exception $exception) {
            if ($exception instanceof StopExecutionRequested) {
                throw $exception;
            }
        }

        return false;
    }

    protected function getCurlHandleForUrl(string $method, string $url)
    {
        return $this->getCurlHandle($method, "http://{$this->host}:{$this->portNumber}/{$url}");
    }

    protected function getCurlHandle(string $method, string $fullUrl)
    {
        if (! $this->curlHandle) {
            $this->curlHandle = curl_init();
        }

        curl_reset($this->curlHandle);
        curl_setopt($this->curlHandle, CURLOPT_URL, $fullUrl);

        curl_setopt($this->curlHandle, CURLOPT_HTTPHEADER, array_merge([
            'Accept: application/json',
            'Content-Type: application/json',
        ]));

        curl_setopt($this->curlHandle, CURLOPT_USERAGENT, 'Ray 1.0');
        curl_setopt($this->curlHandle, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($this->curlHandle, CURLOPT_TIMEOUT, 2);
        curl_setopt($this->curlHandle, CURLOPT_SSL_VERIFYPEER, true);
        curl_setopt($this->curlHandle, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
        curl_setopt($this->curlHandle, CURLOPT_ENCODING, '');
        curl_setopt($this->curlHandle, CURLINFO_HEADER_OUT, true);
        curl_setopt($this->curlHandle, CURLOPT_FAILONERROR, true);

        if ($method === 'post') {
            curl_setopt($this->curlHandle, CURLOPT_POST, true);
        }

        return $this->curlHandle;
    }
}
[D] Concerns
[D] Exceptions
[D] Origin
[D] Payloads
[D] PHPStan
[D] Rector
[D] Settings
[D] Support
[F] ArgumentConverter.php
[F] Client.php
[F] error_log
[F] helpers.php
[F] PayloadFactory.php
[F] Ray.php
[F] Request.php