Report proxy connection issues

Author: clue

src/Client.php

@@ -160,6 +160,9 @@ public function connect($uri)
         return $this->connector->connect($socksUri)->then(
             function (ConnectionInterface $stream) use ($that, $host, $port) {
                 return $that->handleConnectedSocks($stream, $host, $port);
+            },
+            function (Exception $e) {
+                throw new RuntimeException('Unable to connect to proxy (ECONNREFUSED)', defined('SOCKET_ECONNREFUSED') ? SOCKET_ECONNREFUSED : 111, $e);
             }
         );
     }

tests/ClientTest.php

@@ -120,6 +120,17 @@ public function testCreateWithInvalidPortDoesNotConnect()
         $this->assertInstanceOf('\React\Promise\PromiseInterface', $promise);
     }
 
+    public function testConnectorRejectsWillRejectConnection()
+    {
+        $promise = \React\Promise\Reject(new RuntimeException());
+
+        $this->connector->expects($this->once())->method('connect')->with('127.0.0.1:1080?hostname=google.com')->willReturn($promise);
+
+        $promise = $this->client->connect('google.com:80');
+
+        $promise->then(null, $this->expectCallableOnceWithExceptionCode(SOCKET_ECONNREFUSED));
+    }
+
     public function testCancelConnectionDuringConnectionWillCancelConnection()
     {
         $promise = new Promise(function () { }, function () {

tests/bootstrap.php

@@ -33,6 +33,19 @@ protected function expectCallableNever()
         return $mock;
     }
 
+    protected function expectCallableOnceWithExceptionCode($code)
+    {
+        $mock = $this->createCallableMock();
+        $mock
+            ->expects($this->once())
+            ->method('__invoke')
+            ->with($this->callback(function ($e) use ($code) {
+                return $e->getCode() === $code;
+            }));
+
+        return $mock;
+    }
+
     protected function expectCallableOnceParameter($type)
     {
         $mock = $this->createCallableMock();