async http

Author: CodeWithSushil

.gitignore

@@ -29,3 +29,4 @@ Homestead.json
 .phpactor.json
 auth.json
 composer.lock
+.phpunit.cache/

.phpunit.cache/test-results

@@ -1 +1 @@
-{"version":1,"defects":{"AsyncHttpClientTest::test_simple_get_request":8},"times":{"AsyncHttpClientTest::test_simple_get_request":0.02}}
+{"version":1,"defects":{"AsyncHttpClientTest::test_simple_get_request":5},"times":{"AsyncHttpClientTest::test_simple_get_request":1.039}}

composer.json

@@ -4,7 +4,9 @@
     "type": "library",
     "require": {
         "php": "^8.4",
-        "ext-sockets": "*"
+        "ext-sockets": "*",
+        "psr/http-client": "^1.0",
+        "psr/http-message": "^2.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^12.2",

phpunit.xml

@@ -4,9 +4,9 @@
          bootstrap="vendor/autoload.php"
          cacheDirectory=".phpunit.cache"
          executionOrder="depends,defects"
-         requireCoverageMetadata="true"
-         beStrictAboutCoverageMetadata="true"
-         beStrictAboutOutputDuringTests="true"
+         requireCoverageMetadata="false"
+         beStrictAboutCoverageMetadata="false"
+         beStrictAboutOutputDuringTests="false"
          displayDetailsOnPhpunitDeprecations="true"
          failOnPhpunitDeprecation="true"
          failOnRisky="true"

src/Http/AsyncHttpClient.php

@@ -0,0 +1,94 @@
+<?php
+
+namespace Async\Http;
+
+class AsyncHttpClient
+{
+    public function get(string $url, array $headers = []): \Generator
+    {
+        return $this->request('GET', $url, $headers);
+    }
+
+    public function post(string $url, array $headers = [], string $body = ''): \Generator
+    {
+        return $this->request('POST', $url, $headers, $body);
+    }
+
+    public function request(string $method, string $url, array $headers = [], string $body = ''): \Generator
+    {
+        $parts = parse_url($url);
+        $scheme = $parts['scheme'] ?? 'http';
+        $host = $parts['host'] ?? 'localhost';
+        $port = $scheme === 'https' ? 443 : 80;
+        $path = $parts['path'] ?? '/';
+        $query = $parts['query'] ?? '';
+        if ($query) {
+            $path .= '?'.$query;
+        }
+
+        $remote = ($scheme === 'https' ? 'ssl://' : '').$host.':'.$port;
+        $errno = $errstr = null;
+
+        $fp = stream_socket_client($remote, $errno, $errstr, 5, STREAM_CLIENT_CONNECT | STREAM_CLIENT_ASYNC_CONNECT);
+        if (! $fp) {
+            throw new \Exception("Connection failed: $errstr");
+        }
+
+        stream_set_blocking($fp, false);
+
+        // Build request headers
+        $headerStr = "$method $path HTTP/1.1\r\n";
+        $headerStr .= "Host: $host\r\n";
+        $headerStr .= "Connection: close\r\n";
+
+        foreach ($headers as $k => $v) {
+            $headerStr .= "$k: $v\r\n";
+        }
+
+        if ($body !== '') {
+            $headerStr .= 'Content-Length: '.strlen($body)."\r\n";
+        }
+
+        $headerStr .= "\r\n".$body;
+
+        fwrite($fp, $headerStr);
+
+        // Wait for response
+        $read = [$fp];
+        $write = null;
+        $except = null;
+        if (stream_select($read, $write, $except, 5)) {
+            $response = '';
+            while (! feof($fp)) {
+                $chunk = fread($fp, 8192);
+                if ($chunk === false) {
+                    break;
+                }
+                $response .= $chunk;
+            }
+            fclose($fp);
+
+            // Split headers and body
+            [$rawHeaders, $body] = explode("\r\n\r\n", $response, 2);
+
+            return yield new HttpResponse($rawHeaders, $body);
+        } else {
+            throw new \Exception('Timeout waiting for response');
+        }
+    }
+
+    public function put(string $url, array $headers = [], string $body = ''): \Generator
+    {
+        return $this->request('PUT', $url, $headers, $body);
+    }
+
+    public function patch(string $url, array $headers = [], string $body = ''): \Generator
+    {
+        return $this->request('PATCH', $url, $headers, $body);
+    }
+
+    public function delete(string $url, array $headers = []): \Generator
+    {
+        return $this->request('DELETE', $url, $headers);
+    }
+}

src/Http/HttpResponse.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace Async\Http;
+
+class HttpResponse
+{
+    public int $statusCode;
+
+    public array $headers = [];
+
+    public string $body;
+
+    public function __construct(string $rawHeaders, string $body)
+    {
+        $this->body = $body;
+        $lines = explode("\r\n", $rawHeaders);
+        $statusLine = array_shift($lines);
+        preg_match('#HTTP/\d\.\d\s+(\d+)#', $statusLine, $matches);
+        $this->statusCode = (int) ($matches[1] ?? 0);
+
+        foreach ($lines as $line) {
+            if (strpos($line, ':') !== false) {
+                [$key, $value] = explode(':', $line, 2);
+                $this->headers[trim($key)] = trim($value);
+            }
+        }
+    }
+
+    public function getBody(): \Psr\Http\Message\StreamInterface
+    {
+        return new Stream($this->body);
+    }
+
+    public function json(): mixed
+    {
+        return json_decode($this->body, true);
+    }
+
+    public function text(): string
+    {
+        return $this->body;
+    }
+}

src/Http/Promise.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace Async\Http;
+
+class Promise
+{
+    private \Fiber $fiber;
+
+    public function __construct(callable $callback)
+    {
+        $this->fiber = new \Fiber($callback);
+    }
+
+    public function await()
+    {
+        return $this->fiber->start();
+    }
+}

src/Http/Stream.php

@@ -0,0 +1,81 @@
+<?php
+
+namespace Async\Http;
+
+use Psr\Http\Message\StreamInterface;
+
+class Stream implements StreamInterface
+{
+    private string $contents;
+
+    public function __construct(string $contents)
+    {
+        $this->contents = $contents;
+    }
+
+    public function __toString(): string
+    {
+        return $this->contents;
+    }
+
+    public function close(): void {}
+
+    public function detach()
+    {
+        return null;
+    }
+
+    public function getSize(): ?int
+    {
+        return strlen($this->contents);
+    }
+
+    public function tell(): int
+    {
+        return 0;
+    }
+
+    public function eof(): bool
+    {
+        return true;
+    }
+
+    public function isSeekable(): bool
+    {
+        return false;
+    }
+
+    public function seek($offset, $whence = SEEK_SET): void {}
+
+    public function rewind(): void {}
+
+    public function isWritable(): bool
+    {
+        return false;
+    }
+
+    public function write($string): int
+    {
+        return 0;
+    }
+
+    public function isReadable(): bool
+    {
+        return true;
+    }
+
+    public function read($length): string
+    {
+        return substr($this->contents, 0, $length);
+    }
+
+    public function getContents(): string
+    {
+        return $this->contents;
+    }
+
+    public function getMetadata($key = null): mixed
+    {
+        return null;
+    }
+}

tests/AsyncHttpClientTest.php

@@ -1,9 +1,8 @@
 <?php
 
+use Async\Http\AsyncHttpClient;
 use PHPUnit\Framework\TestCase;
 
-// use Async\Http\AsyncHttpClient;
-
 class AsyncHttpClientTest extends TestCase
 {
     public function test_simple_get_request()