Fix composer version conflict with react/http v0.8

composer.json

@@ -13,9 +13,10 @@
     "require": {
         "php": "^5.5 || ^7.0",
         "php-http/httplug": "^1.0",
-        "react/http-client": "^0.4.8",
+        "react/http-client": "^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": {

src/ReactFactory.php

@@ -6,8 +6,9 @@
 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\Socket\Connector;
+use React\Socket\ConnectorInterface;
 
 /**
  * Factory wrapper for React instances.
@@ -43,24 +44,45 @@ 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
+    ) {
+        if (null === $dns) {
+            $dns = self::buildDnsResolver($loop);
+        }
+
+        return new Connector($loop, ['dns' => $dns]);
+    }
+
     /**
      * Build a React Http Client.
      *
-     * @param LoopInterface $loop
-     * @param DnsResolver   $dns
+     * @param LoopInterface                  $loop
+     * @param ConnectorInterface|DnsResolver $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 (null === $dns) {
-            $dns = self::buildDnsResolver($loop);
+        // build a connector if none is given, or create one attaching given DnsResolver (old deprecated behavior)
+        if (null === $connector || $connector instanceof DnsResolver) {
+            $connector = static::buildConnector($loop, $connector);
         }
 
-        $factory = new HttpClientFactory();
+        if (!$connector instanceof ConnectorInterface) {
+            throw new \InvalidArgumentException('$connector must be an instance of ConnectorInterface or DnsResolver');
+        }
 
-        return $factory->create($loop, $dns);
+        return new HttpClient($loop, $connector);
     }
 }

tests/ReactFactoryTest.php

@@ -0,0 +1,57 @@
+<?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\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->createMock(LoopInterface::class);
+    }
+
+    public function testBuildHttpClientWithConnector()
+    {
+        $client = ReactFactory::buildHttpClient($this->loop, $this->createMock(ConnectorInterface::class));
+        $this->assertInstanceOf(Client::class, $client);
+    }
+
+    /**
+     * @deprecated Building HTTP client passing a DnsResolver instance is deprecated. Should pass a ConnectorInterface
+     *             instance instead.
+     */
+    public function testBuildHttpClientWithDnsResolver()
+    {
+        $client = ReactFactory::buildHttpClient($this->loop, $this->createMock(Resolver::class));
+        $this->assertInstanceOf(Client::class, $client);
+    }
+
+    public function testBuildHttpClientWithoutConnector()
+    {
+        $client = ReactFactory::buildHttpClient($this->loop);
+        $this->assertInstanceOf(Client::class, $client);
+    }
+
+    public function testBuildHttpClientWithInvalidConnectorThrowsException()
+    {
+        $this->expectException(\InvalidArgumentException::class);
+        ReactFactory::buildHttpClient($this->loop, $this->createMock(LoopInterface::class));
+    }
+}