Merge pull request #84 from clue-labs/socket

 Replace deprecated SocketClient with new Socket component

Author: WyriHaximus

composer.json

@@ -6,7 +6,7 @@
     "require": {
         "php": ">=5.4.0",
         "guzzlehttp/psr7": "^1.0",
-        "react/socket-client": "^0.6",
+        "react/socket": "^0.7",
         "react/dns": "0.4.*",
         "react/event-loop": "0.4.*",
         "react/stream": "0.4.*",

src/Client.php

@@ -2,29 +2,21 @@
 
 namespace React\HttpClient;
 
-use React\SocketClient\ConnectorInterface;
+use React\Socket\ConnectorInterface;
 
 class Client
 {
     private $connector;
-    private $secureConnector;
 
-    public function __construct(ConnectorInterface $connector, ConnectorInterface $secureConnector)
+    public function __construct(ConnectorInterface $connector)
     {
         $this->connector = $connector;
-        $this->secureConnector = $secureConnector;
     }
 
     public function request($method, $url, array $headers = [], $protocolVersion = '1.0')
     {
         $requestData = new RequestData($method, $url, $headers, $protocolVersion);
-        $connector = $this->getConnectorForScheme($requestData->getScheme());
 
-        return new Request($connector, $requestData);
-    }
-
-    private function getConnectorForScheme($scheme)
-    {
-        return ('https' === $scheme) ? $this->secureConnector : $this->connector;
+        return new Request($this->connector, $requestData);
     }
 }

src/Factory.php

@@ -4,16 +4,16 @@
 
 use React\EventLoop\LoopInterface;
 use React\Dns\Resolver\Resolver;
-use React\SocketClient\Connector;
-use React\SocketClient\SecureConnector;
+use React\Socket\Connector;
 
 class Factory
 {
     public function create(LoopInterface $loop, Resolver $resolver)
     {
-        $connector = new Connector($loop, $resolver);
-        $secureConnector = new SecureConnector($connector, $loop);
+        $connector = new Connector($loop, array(
+            'dns' => $resolver
+        ));
 
-        return new Client($connector, $secureConnector);
+        return new Client($connector);
     }
 }

src/Request.php

@@ -4,7 +4,7 @@
 
 use Evenement\EventEmitterTrait;
 use GuzzleHttp\Psr7 as gPsr;
-use React\SocketClient\ConnectorInterface;
+use React\Socket\ConnectorInterface;
 use React\Stream\WritableStreamInterface;
 
 /**
@@ -230,6 +230,10 @@ protected function connect()
         $host = $this->requestData->getHost();
         $port = $this->requestData->getPort();
 
+        if ($this->requestData->getScheme() === 'https') {
+            $host = 'tls://' . $host;
+        }
+
         return $this->connector
             ->connect($host . ':' . $port);
     }

tests/RequestTest.php

@@ -5,9 +5,7 @@
 use React\HttpClient\Request;
 use React\HttpClient\RequestData;
 use React\Stream\Stream;
-use React\Promise\FulfilledPromise;
 use React\Promise\RejectedPromise;
-use React\Promise;
 use React\Promise\Deferred;
 
 class RequestTest extends TestCase
@@ -17,11 +15,11 @@ class RequestTest extends TestCase
 
     public function setUp()
     {
-        $this->stream = $this->getMockBuilder('React\Stream\Stream')
+        $this->stream = $this->getMockBuilder('React\Socket\Connection')
             ->disableOriginalConstructor()
             ->getMock();
 
-        $this->connector = $this->getMockBuilder('React\SocketClient\ConnectorInterface')
+        $this->connector = $this->getMockBuilder('React\Socket\ConnectorInterface')
             ->getMock();
 
         $this->response = $this->getMockBuilder('React\HttpClient\Response')