Fix composer version conflict with react/http v0.8

composer.json

@@ -13,14 +13,16 @@
     "require": {
         "php": "^5.5 || ^7.0",
         "php-http/httplug": "^1.0",
-        "react/http-client": "^0.4.8",
+        "react/http-client": "^0.4.8 || ^0.5",
         "react/dns": "^0.4.1",
-        "react/stream": "^0.4.3",
+        "react/stream": "^0.4.3 || ^0.7",
+        "react/socket": "^0.8",
         "php-http/discovery": "^1.0"
     },
     "require-dev": {
         "php-http/client-integration-tests": "^0.6",
-        "php-http/message": "^1.0"
+        "php-http/message": "^1.0",
+        "phpunit/phpunit": "^4.8.36 || ^5.4"
     },
     "provide": {
         "php-http/client-implementation": "1.0",

src/ReactFactory.php

@@ -6,8 +6,10 @@
 use React\EventLoop\Factory as EventLoopFactory;
 use React\Dns\Resolver\Resolver as DnsResolver;
 use React\Dns\Resolver\Factory as DnsResolverFactory;
-use React\HttpClient\Factory as HttpClientFactory;
 use React\HttpClient\Client as HttpClient;
+use React\HttpClient\Factory as HttpClientFactory;
+use React\Socket\Connector;
+use React\Socket\ConnectorInterface;
 
 /**
  * Factory wrapper for React instances.
@@ -43,24 +45,93 @@ public static function buildDnsResolver(
         return $factory->createCached($dns, $loop);
     }
 
+    /**
+     * @param LoopInterface    $loop
+     * @param DnsResolver|null $dns
+     *
+     * @return ConnectorInterface
+     */
+    public static function buildConnector(
+        LoopInterface $loop,
+        DnsResolver $dns = null
+    ) {
+        return null !== $dns
+            ? new Connector($loop, ['dns' => $dns])
+            : new Connector($loop);
+    }
+
     /**
      * Build a React Http Client.
      *
-     * @param LoopInterface $loop
-     * @param DnsResolver   $dns
+     * @param LoopInterface                       $loop
+     * @param ConnectorInterface|DnsResolver|null $connector Passing a DnsResolver instance is deprecated. Should pass a
+     *                                                       ConnectorInterface instance.
      *
      * @return HttpClient
      */
     public static function buildHttpClient(
         LoopInterface $loop,
-        DnsResolver $dns = null
+        $connector = null
     ) {
+        if (class_exists(HttpClientFactory::class)) {
+            // if HttpClientFactory class exists, use old behavior for backwards compatibility
+            return static::buildHttpClient04($loop, $connector);
+        } else {
+            return static::buildHttpClient05($loop, $connector);
+        }
+    }
+
+    /**
+     * Builds a React Http client v0.4 style.
+     *
+     * @param LoopInterface    $loop
+     * @param DnsResolver|null $dns
+     *
+     * @return HttpClient
+     */
+    private static function buildHttpClient04(
+        LoopInterface $loop,
+        $dns = null
+    ) {
+        // create dns resolver if one isn't provided
         if (null === $dns) {
-            $dns = self::buildDnsResolver($loop);
+            $dns = static::buildDnsResolver($loop);
+        }
+
+        // validate connector instance for proper error reporting
+        if (!$dns instanceof DnsResolver) {
+            throw new \InvalidArgumentException('$connector must be an instance of DnsResolver');
         }
 
         $factory = new HttpClientFactory();
 
         return $factory->create($loop, $dns);
     }
+
+    /**
+     * Builds a React Http client v0.5 style.
+     *
+     * @param LoopInterface                       $loop
+     * @param DnsResolver|ConnectorInterface|null $connector
+     *
+     * @return HttpClient
+     */
+    private static function buildHttpClient05(
+        LoopInterface $loop,
+        $connector = null
+    ) {
+        // build a connector with given DnsResolver if provided (old deprecated behavior)
+        if ($connector instanceof DnsResolver) {
+            $connector = static::buildConnector($loop, $connector);
+        }
+
+        // validate connector instance for proper error reporting
+        if (null !== $connector && !$connector instanceof ConnectorInterface) {
+            throw new \InvalidArgumentException(
+                '$connector must be an instance of DnsResolver or ConnectorInterface'
+            );
+        }
+
+        return new HttpClient($loop, $connector);
+    }
 }

tests/ReactFactoryTest.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace Http\Adapter\React\Tests;
+
+use Http\Adapter\React\ReactFactory;
+use PHPUnit\Framework\TestCase;
+use React\Dns\Resolver\Resolver;
+use React\EventLoop\LoopInterface;
+use React\HttpClient\Client;
+use React\HttpClient\Factory;
+use React\Socket\ConnectorInterface;
+
+/**
+ * These tests don't really ensure the correct instances are baked into the returned http client, instead, they are
+ * just testing the code against the expected use cases.
+ *
+ * @author  Samuel Nogueira <[email protected]>
+ */
+class ReactFactoryTest extends TestCase
+{
+    /**
+     * @var \React\EventLoop\LoopInterface
+     */
+    private $loop;
+
+    protected function setUp()
+    {
+        $this->loop = $this->getMockBuilder(LoopInterface::class)->getMock();
+    }
+
+    public function testBuildHttpClientWithConnector()
+    {
+        if (class_exists(Factory::class)) {
+            $this->markTestSkipped('This test only runs with react http client v0.5 and above');
+        }
+
+        $connector = $this->getMockBuilder(ConnectorInterface::class)->getMock();
+        $client = ReactFactory::buildHttpClient($this->loop, $connector);
+        $this->assertInstanceOf(Client::class, $client);
+    }
+
+    /**
+     * @deprecated Building HTTP client passing a DnsResolver instance is deprecated. Should pass a ConnectorInterface
+     *             instance instead.
+     */
+    public function testBuildHttpClientWithDnsResolver()
+    {
+        $connector = $this->getMockBuilder(Resolver::class)->disableOriginalConstructor()->getMock();
+        $client = ReactFactory::buildHttpClient($this->loop, $connector);
+        $this->assertInstanceOf(Client::class, $client);
+    }
+
+    public function testBuildHttpClientWithoutConnector()
+    {
+        $client = ReactFactory::buildHttpClient($this->loop);
+        $this->assertInstanceOf(Client::class, $client);
+    }
+
+    /**
+     * @expectedException \InvalidArgumentException
+     */
+    public function testBuildHttpClientWithInvalidConnectorThrowsException()
+    {
+        $connector = $this->getMockBuilder(LoopInterface::class)->getMock();
+        ReactFactory::buildHttpClient($this->loop, $connector);
+    }
+}