Update guzzle6 adapater with httplug new contract

Author: joelwurtz

composer.json

@@ -15,14 +15,22 @@
         }
     ],
     "require": {
-        "php": ">=5.4",
+        "php": ">=5.5.0",
         "php-http/httplug": "^1.0@dev",
+        "php-http/utils": "^0.1@dev",
         "guzzlehttp/guzzle": "^6.0"
     },
     "require-dev": {
         "ext-curl": "*",
-        "php-http/adapter-integration-tests": "^0.1"
+        "php-http/message-factory": "dev-master as 0.1.1",
+        "php-http/adapter-integration-tests": "dev-feature/httplug"
     },
+    "repositories": [
+        {
+            "type": "vcs",
+            "url": "https://github.com/joelwurtz/adapter-integration-tests"
+        }
+    ],
     "provide": {
         "php-http/client-implementation": "1.0"
     },

src/Guzzle6HttpAdapter.php

@@ -15,36 +15,46 @@
 use GuzzleHttp\ClientInterface;
 use GuzzleHttp\Exception\RequestException;
 use GuzzleHttp\Pool;
+use Http\Client\Exception\BatchException;
+use Http\Client\Exception\HttpException;
+use Http\Client\Exception\NetworkException;
+use Http\Client\HttpClient;
+use Http\Client\Utils\BatchResult;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
 
 /**
  * @author David de Boer <[email protected]>
  */
-class Guzzle6HttpAdapter implements HttpAdapter
+class Guzzle6HttpAdapter implements HttpClient
 {
     /**
      * @var ClientInterface
      */
     private $client;
 
     /**
-     * @param ClientInterface|null $client
+     * @var array Options to pass when sending one or multiple requests with guzzle
      */
-    public function __construct(ClientInterface $client = null)
+    private $options;
+
+    /**
+     * @param ClientInterface|null $client  Guzzle client
+     * @param array                $options Options to pass when sending one or multiple requests with guzzle
+     */
+    public function __construct(ClientInterface $client = null, array $options = [])
     {
-        $this->client = $client ?: new Client();
+        $this->client  = $client ?: new Client();
+        $this->options = $this->buildOptions($options);
     }
 
     /**
      * {@inheritdoc}
      */
-    public function sendRequest(RequestInterface $request, array $options = [])
+    public function sendRequest(RequestInterface $request)
     {
-        $options = $this->buildOptions($options);
-
         try {
-            return $this->client->send($request, $options);
+            return $this->client->send($request, $this->options);
         } catch (RequestException $e) {
             throw $this->createException($e);
         }
@@ -53,56 +63,42 @@ public function sendRequest(RequestInterface $request, array $options = [])
     /**
      * {@inheritdoc}
      */
-    public function sendRequests(array $requests, array $options = [])
+    public function sendRequests(array $requests)
     {
-        $options = $this->buildOptions($options);
+        $poolResult  = Pool::batch($this->client, $requests, ['options' => $this->options]);
+        $batchResult = new BatchResult();
 
-        $results = Pool::batch($this->client, $requests, $options);
-
-        $exceptions = [];
-        $responses = [];
-
-        foreach ($results as $result) {
+        foreach ($poolResult as $index => $result) {
             if ($result instanceof ResponseInterface) {
-                $responses[] = $result;
-            } elseif ($result instanceof RequestException) {
-                $exceptions[] = $this->createException($result);
+                $batchResult = $batchResult->addResponse($requests[$index], $result);
             }
-        }
 
-        if (count($exceptions) > 0) {
-            throw new Exception\MultiHttpAdapterException($exceptions, $responses);
+            if ($result instanceof RequestException) {
+                $batchResult = $batchResult->addException($requests[$index], $this->createException($result));
+            }
         }
 
-        return $results;
-    }
+        if ($batchResult->hasExceptions()) {
+            throw new BatchException($batchResult);
+        }
 
-    /**
-     * {@inheritdoc}
-     */
-    public function getName()
-    {
-        return 'guzzle6';
+        return $batchResult;
     }
 
     /**
-     * Converts a Guzzle exception into an HttpAdapter exception
+     * Converts a Guzzle exception into an Httplug exception
      *
      * @param RequestException $exception
      *
-     * @return Exception\HttpAdapterException
+     * @return HttpException|NetworkException Return an HttpException if response is available, NetworkException otherwise
      */
     private function createException(RequestException $exception)
     {
-        $adapterException = new Exception\HttpAdapterException(
-            $exception->getMessage(),
-            0,
-            $exception
-        );
-        $adapterException->setResponse($exception->getResponse());
-        $adapterException->setRequest($exception->getRequest());
-
-        return $adapterException;
+        if ($exception->hasResponse()) {
+            return new HttpException($exception->getMessage(), $exception->getRequest(), $exception->getResponse(), $exception);
+        }
+
+        return new NetworkException($exception->getMessage(), $exception->getRequest(), $exception);
     }
 
     /**

tests/Guzzle6HttpAdapterTest.php

@@ -19,11 +19,6 @@
  */
 abstract class Guzzle6HttpAdapterTest extends HttpAdapterTest
 {
-    public function testGetName()
-    {
-        $this->assertSame('guzzle6', $this->httpAdapter->getName());
-    }
-
     /**
      * {@inheritdoc}
      */