example.php

<?php

/**
 * Orbit — runnable demo.  `php example.php`
 *
 * Uses a scripted prober so the demo needs no live proxies or network.
 * In real use you'd just call `$pool->check()` and let the curl_multi prober
 * test them for you.
 *
 * @author  Vxsilisk — Orbit
 * @license MIT
 */
require __DIR__ . '/autoload.php';

$pool = Pool::fromList([
    '203.0.113.1:8080',
    'user:secret@203.0.113.2:3128',
    'socks5://203.0.113.3:1080',
    '203.0.113.4:8080',
])->strategy(Strategy::LeastLatency);

echo "Loaded {$pool->count()} proxies.\n\n";

// Pretend a health check came back (in production: $pool->check('https://httpbin.org/ip')).
$scripted = new class(['203.0.113.4:8080']) implements ProberInterface {
    public function __construct(private array $deadHosts) {}
    public function probe(array $proxies, string $url, int $timeout, int $concurrency): array
    {
        $latencies = [0.42, 0.19, 0.88, 0.0];
        $out = [];
        foreach (array_values($proxies) as $i => $p) {
            $dead = in_array("{$p->host}:{$p->port}", $this->deadHosts, true);
            $out[$p->id()] = ['ok' => !$dead, 'latency' => $dead ? null : $latencies[$i]];
        }
        return $out;
    }
};

$summary = $pool->check(prober: $scripted);
echo "Health check: {$summary['alive']} alive, {$summary['dead']} dead of {$summary['checked']}.\n\n";

echo "Rotating (least-latency first):\n";
for ($i = 0; $i < 5; $i++) {
    $proxy = $pool->tryNext();
    if ($proxy === null) {
        echo "  pool exhausted\n";
        break;
    }
    $latency = $proxy->latency !== null ? sprintf('%.0fms', $proxy->latency * 1000) : '—';
    echo "  → {$proxy->id()}  ({$latency})\n";

    // Simulate the 3rd pick failing, so it drops into cooldown.
    $pool->report($proxy, $i !== 2, $proxy->latency);
}

echo "\nPool stats:\n";
foreach ($pool->stats() as $key => $value) {
    printf("  %-13s %s\n", $key, is_float($value) ? sprintf('%.3fs', $value) : $value);
}

// The intended pairing with PulsarX:
//
//   $s = new Pulsar();
//   $proxy = $pool->next();
//   $r = $s->get($url, server: $proxy->forPulsar());
//   $pool->report($proxy, $r->ok(), $r->getElapsed());