Initial commit

Author: kelunik

.gitignore

@@ -0,0 +1,2 @@
+/composer.lock
+/vendor/

composer.json

@@ -0,0 +1,32 @@
+{
+    "name": "kelunik/php-http-artax",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Niklas Keller",
+            "email": "[email protected]"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "Kelunik\\Http\\Adapter\\Artax\\": "src"
+        }
+    },
+    "require": {
+        "amphp/artax": "dev-master",
+        "php-http/httplug": "^1.1",
+        "php-http/discovery": "^1.2"
+    },
+    "require-dev": {
+        "amphp/phpunit-util": "^1",
+        "php-http/client-integration-tests": "^0.6.0",
+        "php-http/message": "^1.6"
+    },
+    "provide": {
+        "php-http/client-implementation": "1.0"
+    },
+    "scripts": {
+        "test": "vendor/bin/phpunit"
+    }
+}

phpunit.xml.dist

@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit colors="true" bootstrap="vendor/autoload.php">
+    <testsuites>
+        <testsuite name="Artax Adapter Test Suite">
+            <directory>test</directory>
+        </testsuite>
+    </testsuites>
+    <php>
+        <server name="TEST_SERVER" value="http://127.0.0.1:10000/server.php" />
+    </php>
+    <filter>
+        <whitelist>
+            <directory suffix=".php">src/</directory>
+        </whitelist>
+    </filter>
+    <listeners>
+        <listener class="Amp\PHPUnit\LoopReset" />
+    </listeners>
+</phpunit>

src/Client.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace Kelunik\Http\Adapter\Artax;
+
+use Amp\Artax;
+use Amp\Promise;
+use Http\Client\Exception\RequestException;
+use Http\Client\HttpClient;
+use Http\Discovery\MessageFactoryDiscovery;
+use Http\Discovery\StreamFactoryDiscovery;
+use Http\Message\ResponseFactory;
+use Http\Message\StreamFactory;
+use Psr\Http\Message\RequestInterface;
+use function Amp\call;
+
+class Client implements HttpClient {
+    private $client;
+    private $responseFactory;
+    private $streamFactory;
+
+    public function __construct(Artax\Client $client = null, ResponseFactory $responseFactory = null, StreamFactory $streamFactory = null) {
+        $this->client = $client ?? new Artax\DefaultClient;
+        $this->responseFactory = $responseFactory ?? MessageFactoryDiscovery::find();
+        $this->streamFactory = $streamFactory ?? StreamFactoryDiscovery::find();
+    }
+
+    /** @inheritdoc */
+    public function sendRequest(RequestInterface $request) {
+        return Promise\wait(call(function () use ($request) {
+            /** @var Artax\Request $req */
+            $req = new Artax\Request($request->getUri(), $request->getMethod());
+            $req = $req->withProtocolVersions([$request->getProtocolVersion()]);
+            $req = $req->withHeaders($request->getHeaders());
+            $req = $req->withBody((string) $request->getBody());
+
+            try {
+                /** @var Artax\Response $resp */
+                $resp = yield $this->client->request($req, [
+                    Artax\Client::OP_MAX_REDIRECTS => 0,
+                ]);
+            } catch (Artax\HttpException $e) {
+                throw new RequestException($e->getMessage(), $request, $e);
+            }
+
+            $respBody = $resp->getBody();
+            $bodyStream = $this->streamFactory->createStream();
+
+            while (null !== $chunk = yield $respBody->read()) {
+                $bodyStream->write($chunk);
+            }
+
+            $bodyStream->rewind();
+
+            return $this->responseFactory->createResponse(
+                $resp->getStatus(),
+                $resp->getReason(),
+                $resp->getHeaders(),
+                $bodyStream,
+                $resp->getProtocolVersion()
+            );
+        }));
+    }
+}

test/ClientTest.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace Kelunik\Http\Adapter\Artax\Test;
+
+use Amp\Artax;
+use Http\Client\HttpClient;
+use Http\Client\Tests\HttpClientTest;
+use Kelunik\Http\Adapter\Artax\Client;
+
+class ClientTest extends HttpClientTest {
+    /** @return HttpClient */
+    protected function createHttpAdapter() {
+        $client = new Artax\DefaultClient;
+        $client->setOption(Artax\Client::OP_TRANSFER_TIMEOUT, 1000);
+
+        return new Client($client);
+    }
+
+    /**
+     * @dataProvider requestProvider
+     * @group        integration
+     */
+    public function testSendRequest($method, $uri, array $headers, $body) {
+        if ($method === "TRACE") {
+            $this->markTestSkipped("Currently skipped, because Artax refuses to send bodies for TRACE requests");
+        }
+
+        parent::testSendRequest($method, $uri, $headers, $body);
+    }
+}