<?php
require 'vendor/autoload.php';

use PFinal\AsyncioHttp\Client;
use function PfinalClub\Asyncio\run;

run(function() {
$client = new Client();

    // Simple GET request
    $response = $client->get('https://api.github.com/users/octocat');
echo $response->getBody();

    // POST with JSON
$response = $client->post('https://api.example.com/users', [
        'json' => ['name' => 'Alice', 'email' => 'alice@example.com']
]);
    
    echo "Status: {$response->getStatusCode()}\n";
});

use function PfinalClub\Asyncio\{run, create_task, gather};

run(function() {
    $client = new Client();
    
    // Create concurrent tasks
    $tasks = [
        create_task(fn() => $client->get('https://api.github.com/users/octocat')),
        create_task(fn() => $client->get('https://api.github.com/users/torvalds')),
        create_task(fn() => $client->get('https://api.github.com/users/gvanrossum')),
    ];
    
    // Execute concurrently and wait for all
    $responses = gather(...$tasks);
    
    foreach ($responses as $i => $response) {
        echo "User {$i}: {$response->getStatusCode()}\n";
    }
});

use PFinal\AsyncioHttp\Pool;

run(function() {
    $client = new Client();
    
    // Create 100 requests
    $requests = [];
        for ($i = 1; $i <= 100; $i++) {
        $requests[] = fn() => $client->get("https://api.example.com/items/{$i}");
    }
    
    // Execute with concurrency limit of 25
    $results = Pool::batch($client, $requests, [
        'concurrency' => 25,
        'fulfilled' => fn($response, $index) => echo "✅ Request {$index} succeeded\n",
        'rejected' => fn($e, $index) => echo "❌ Request {$index} failed: {$e->getMessage()}\n",
    ]);
    
    $successCount = count(array_filter($results, fn($r) => $r['state'] === 'fulfilled'));
    echo "Success: {$successCount}/100\n";
});

// ❌ Traditional async libraries (Guzzle, ReactPHP)
$promise = $client->getAsync('https://api.example.com');
$response = $promise->wait();  // Explicit wait

// ✅ pfinalclub/asyncio (Fiber-based)
$response = $client->get('https://api.example.com');  // Auto-async!

use PFinal\AsyncioHttp\Handler\{HandlerStack, AsyncioHandler};
use PFinal\AsyncioHttp\Middleware\{RetryMiddleware, RedirectMiddleware, LogMiddleware};

run(function() {
    $handler = new AsyncioHandler();
    $stack = HandlerStack::create($handler);
    
    // Add retry middleware with exponential backoff
    $stack->push(new RetryMiddleware([
        'max' => 3,
        'delay' => RetryMiddleware::exponentialBackoff(500, 5000),
        'on_retry' => fn($attempt) => echo "Retry attempt {$attempt}\n",
    ]), 'retry');
    
    // Add redirect middleware
    $stack->push(new RedirectMiddleware(['max' => 5]), 'redirect');
    
    // Add logging middleware
    $stack->push(new LogMiddleware($logger), 'log');
    
    $client = new Client(['handler' => $stack]);
    
    // Requests automatically retry, redirect, and log
    $response = $client->get('https://api.example.com/data');
});

$response = $client->request('POST', 'https://api.example.com/data', [
    // Query parameters
    'query' => ['page' => 1, 'limit' => 20],
    
    // Headers
    'headers' => [
        'User-Agent' => 'MyApp/1.0',
        'Accept' => 'application/json',
    ],
    
    // JSON body
    'json' => ['name' => 'Bob', 'age' => 30],
    
    // Form data
    'form_params' => ['username' => 'bob', 'password' => 'secret'],
    
    // Raw body
    'body' => 'raw data',
    
    // Timeout (seconds)
    'timeout' => 10,
    
    // SSL verification
    'verify' => true,
    
    // Retry configuration
    'retry' => [
        'max' => 3,
        'delay' => 1000,  // milliseconds
    ],
    
    // Redirect configuration
    'allow_redirects' => [
        'max' => 5,
        'strict' => false,
    ],
    
    // Proxy
    'proxy' => [
        'http' => 'tcp://proxy.example.com:8080',
        'https' => 'tcp://proxy.example.com:8080',
    ],
]);

class GitHubClient
{
    private Client $client;
    
    public function __construct(string $token)
    {
        $this->client = new Client([
            'base_uri' => 'https://api.github.com',
            'headers' => [
                'Authorization' => "Bearer {$token}",
                'Accept' => 'application/vnd.github.v3+json',
            ],
            'timeout' => 10,
        ]);
    }
    
    public function getUser(string $username): array
    {
        $response = $this->client->get("/users/{$username}");
        return json_decode($response->getBody(), true);
    }
    
    public function getReposConcurrently(string $username, int $pages = 3): array
    {
        // Fetch multiple pages concurrently
        $tasks = [];
        for ($page = 1; $page <= $pages; $page++) {
            $tasks[] = create_task(fn() => $this->client->get("/users/{$username}/repos", [
                'query' => ['page' => $page, 'per_page' => 100]
            ]));
        }
        
        $responses = gather(...$tasks);
        
        $repos = [];
        foreach ($responses as $response) {
            $repos = array_merge($repos, json_decode($response->getBody(), true));
        }
        
        return $repos;
    }
}

// Usage
run(function() {
    $github = new GitHubClient('your-token-here');
    
    $user = $github->getUser('octocat');
    echo "User: {$user['name']}\n";
    
    $repos = $github->getReposConcurrently('octocat', 3);
    echo "Total repos: " . count($repos) . "\n";
});

run(function() {
    $client = new Client(['timeout' => 10]);
    
    // Fetch homepage
    $response = $client->get('https://news.ycombinator.com');
    preg_match_all('/<a href="(item\?id=\d+)">/', $response->getBody(), $matches);
    $links = array_slice($matches[1], 0, 30);
    
    // Scrape all links concurrently (10 concurrent requests)
    $tasks = array_map(
        fn($link) => fn() => $client->get("https://news.ycombinator.com/{$link}"),
        $links
    );
    
    $results = Pool::batch($client, $tasks, [
        'concurrency' => 10,
        'fulfilled' => fn($response, $i) => echo "✅ Scraped: {$links[$i]}\n",
        'rejected' => fn($e, $i) => echo "❌ Failed: {$links[$i]}\n",
    ]);
    
    echo "Scraped: " . count($results) . " pages\n";
});