Create specific exception for each error

Author: joelwurtz

src/Client.php

@@ -4,6 +4,9 @@
 
 use Http\Client\Exception\NetworkException;
 use Http\Client\HttpClient;
+use Http\Client\Socket\Exception\ConnectionException;
+use Http\Client\Socket\Exception\InvalidRequestException;
+use Http\Client\Socket\Exception\SSLConnectionException;
 use Http\Discovery\MessageFactoryDiscovery;
 use Http\Message\ResponseFactory;
 use Psr\Http\Message\RequestInterface;
@@ -98,7 +101,7 @@ public function sendRequest(RequestInterface $request)
      * @param string           $remote  Entrypoint for the connection
      * @param bool             $useSsl  Whether to use ssl or not
      *
-     * @throws NetworkException When the connection fail
+     * @throws ConnectionException|SSLConnectionException When the connection fail
      *
      * @return resource Socket resource
      */
@@ -109,15 +112,13 @@ protected function createSocket(RequestInterface $request, $remote, $useSsl)
         $socket = @stream_socket_client($remote, $errNo, $errMsg, floor($this->config['timeout'] / 1000), STREAM_CLIENT_CONNECT, $this->config['stream_context']);
 
         if (false === $socket) {
-            throw new NetworkException($errMsg, $request);
+            throw new ConnectionException($errMsg, $request);
         }
 
         stream_set_timeout($socket, floor($this->config['timeout'] / 1000), $this->config['timeout'] % 1000);
 
-        if ($useSsl) {
-            if (false === @stream_socket_enable_crypto($socket, true, $this->config['ssl_method'])) {
-                throw new NetworkException(sprintf('Cannot enable tls: %s', error_get_last()['message']), $request);
-            }
+        if ($useSsl && false === @stream_socket_enable_crypto($socket, true, $this->config['ssl_method'])) {
+            throw new SSLConnectionException(sprintf('Cannot enable tls: %s', error_get_last()['message']), $request);
         }
 
         return $socket;
@@ -163,18 +164,18 @@ protected function configure(array $config = [])
      *
      * @param RequestInterface $request
      *
-     * @throws NetworkException When no remote can be determined from the request
+     * @throws InvalidRequestException When no remote can be determined from the request
      *
      * @return string
      */
     private function determineRemoteFromRequest(RequestInterface $request)
     {
-        if ($request->getUri()->getHost() == '' && !$request->hasHeader('Host')) {
-            throw new NetworkException('Cannot find connection endpoint for this request', $request);
+        if (!$request->hasHeader('Host') && $request->getUri()->getHost() === '') {
+            throw new InvalidRequestException('Remote is not defined and we cannot determine a connection endpoint for this request (no Host header)', $request);
         }
 
         $host = $request->getUri()->getHost();
-        $port = $request->getUri()->getPort() ?: ($request->getUri()->getScheme() == 'https' ? 443 : 80);
+        $port = $request->getUri()->getPort() ?: ($request->getUri()->getScheme() === 'https' ? 443 : 80);
         $endpoint = sprintf('%s:%s', $host, $port);
 
         // If use the host header if present for the endpoint

src/Exception/BrokenPipeException.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace Http\Client\Socket\Exception;
+
+use Http\Client\Exception\NetworkException;
+
+class BrokenPipeException extends NetworkException
+{
+}

src/Exception/ConnectionException.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace Http\Client\Socket\Exception;
+
+use Http\Client\Exception\NetworkException;
+
+class ConnectionException extends NetworkException
+{
+}

src/Exception/InvalidRequestException.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace Http\Client\Socket\Exception;
+
+use Http\Client\Exception\NetworkException;
+
+class InvalidRequestException extends NetworkException
+{
+}

src/Exception/SSLConnectionException.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace Http\Client\Socket\Exception;
+
+use Http\Client\Exception\NetworkException;
+
+class SSLConnectionException extends NetworkException
+{
+}

src/RequestWriter.php

@@ -3,6 +3,7 @@
 namespace Http\Client\Socket;
 
 use Http\Client\Exception\NetworkException;
+use Http\Client\Socket\Exception\BrokenPipeException;
 use Psr\Http\Message\RequestInterface;
 
 /**
@@ -21,12 +22,12 @@ trait RequestWriter
      * @param RequestInterface $request
      * @param int              $bufferSize
      *
-     * @throws \Http\Client\Exception\NetworkException
+     * @throws BrokenPipeException
      */
     protected function writeRequest($socket, RequestInterface $request, $bufferSize = 8192)
     {
         if (false === $this->fwrite($socket, $this->transformRequestHeadersToString($request))) {
-            throw new NetworkException('Failed to send request, underlying socket not accessible, (BROKEN EPIPE)', $request);
+            throw new BrokenPipeException('Failed to send request, underlying socket not accessible, (BROKEN EPIPE)', $request);
         }
 
         if ($request->getBody()->isReadable()) {
@@ -41,8 +42,7 @@ protected function writeRequest($socket, RequestInterface $request, $bufferSize
      * @param RequestInterface $request
      * @param int              $bufferSize
      *
-     * @throws \Http\Client\Exception\NetworkException
-     * @throws \Http\Client\Exception\RequestException
+     * @throws BrokenPipeException
      */
     protected function writeBody($socket, RequestInterface $request, $bufferSize = 8192)
     {
@@ -56,7 +56,7 @@ protected function writeBody($socket, RequestInterface $request, $bufferSize = 8
             $buffer = $body->read($bufferSize);
 
             if (false === $this->fwrite($socket, $buffer)) {
-                throw new NetworkException('An error occur when writing request to client (BROKEN EPIPE)', $request);
+                throw new BrokenPipeException('An error occur when writing request to client (BROKEN EPIPE)', $request);
             }
         }
     }

src/ResponseReader.php

@@ -3,6 +3,8 @@
 namespace Http\Client\Socket;
 
 use Http\Client\Exception\NetworkException;
+use Http\Client\Socket\Exception\BrokenPipeException;
+use Http\Client\Socket\Exception\TimeoutException;
 use Http\Message\ResponseFactory;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\ResponseInterface;
@@ -27,7 +29,8 @@ trait ResponseReader
      * @param RequestInterface $request
      * @param resource         $socket
      *
-     * @throws NetworkException When the response cannot be read
+     * @throws TimeoutException    When the socket timed out
+     * @throws BrokenPipeException When the response cannot be read
      *
      * @return ResponseInterface
      */
@@ -46,13 +49,13 @@ protected function readResponse(RequestInterface $request, $socket)
         $metadatas = stream_get_meta_data($socket);
 
         if (array_key_exists('timed_out', $metadatas) && true === $metadatas['timed_out']) {
-            throw new NetworkException('Error while reading response, stream timed out', $request);
+            throw new TimeoutException('Error while reading response, stream timed out', $request);
         }
 
         $parts = explode(' ', array_shift($headers), 3);
 
         if (count($parts) <= 1) {
-            throw new NetworkException('Cannot read the response', $request);
+            throw new BrokenPipeException('Cannot read the response', $request);
         }
 
         $protocol = substr($parts[0], -3);