Moves exceptions back to the adapter package

Author: sagikazarmark

src/Exception/HttpAdapterException.php

@@ -18,47 +18,94 @@
 /**
  * @author GeLo <[email protected]>
  */
-interface HttpAdapterException extends Exception
+class HttpAdapterException extends \Exception implements Exception
 {
+    /**
+     * @var RequestInterface|null
+     */
+    private $request;
+
+    /**
+     * @var ResponseInterface|null
+     */
+    private $response;
+
     /**
      * Returns the request
      *
      * @return RequestInterface|null
      */
-    public function getRequest();
+    public function getRequest()
+    {
+        return $this->request;
+    }
 
     /**
      * Checks if there is a request
      *
      * @return boolean
      */
-    public function hasRequest();
+    public function hasRequest()
+    {
+        return isset($this->request);
+    }
 
     /**
      * Sets the request
      *
      * @param RequestInterface|null $request
      */
-    public function setRequest(RequestInterface $request = null);
+    public function setRequest(RequestInterface $request = null)
+    {
+        $this->request = $request;
+    }
 
     /**
      * Returns the response
      *
      * @return ResponseInterface|null
      */
-    public function getResponse();
+    public function getResponse()
+    {
+        return $this->response;
+    }
 
     /**
      * Checks if there is a response
      *
      * @return boolean
      */
-    public function hasResponse();
+    public function hasResponse()
+    {
+        return isset($this->response);
+    }
 
     /**
      * Sets the response
      *
      * @param ResponseInterface|null $response
      */
-    public function setResponse(ResponseInterface $response = null);
+    public function setResponse(ResponseInterface $response = null)
+    {
+        $this->response = $response;
+    }
+
+    /**
+     * @param string          $uri
+     * @param string          $adapterName
+     * @param \Exception|null $previous
+     */
+    public static function cannotFetchUri($uri, $adapterName, \Exception $previous = null)
+    {
+        $message = sprintf(
+            'An error occurred when fetching the URI "%s" with the adapter "%s" ("%s").',
+            $uri,
+            $adapterName,
+            isset($previous) ? $previous->getMessage() : ''
+        );
+
+        $code = isset($previous) ? $previous->getCode() : 0;
+
+        return new self($message, $code, $previous);
+    }
 }

src/Exception/MultiHttpAdapterException.php

@@ -17,14 +17,39 @@
 /**
  * @author GeLo <[email protected]>
  */
-interface MultiHttpAdapterException extends Exception
+class MultiHttpAdapterException extends \Exception implements Exception
 {
+    /**
+     * @var HttpAdapterException[]
+     */
+    private $exceptions;
+
+    /**
+     * @var ResponseInterface[]
+     */
+    private $responses;
+
+    /**
+     * @param HttpAdapterException[] $exceptions
+     * @param ResponseInterface[]    $responses
+     */
+    public function __construct(array $exceptions = [], array $responses = [])
+    {
+        parent::__construct('An error occurred when sending multiple requests.');
+
+        $this->setExceptions($exceptions);
+        $this->setResponses($responses);
+    }
+
     /**
      * Returns all exceptions
      *
      * @return HttpAdapterException[]
      */
-    public function getExceptions();
+    public function getExceptions()
+    {
+        return $this->exceptions;
+    }
 
     /**
      * Checks if a specific exception exists
@@ -33,61 +58,94 @@ public function getExceptions();
      *
      * @return boolean TRUE if there is the exception else FALSE.
      */
-    public function hasException(HttpAdapterException $exception);
+    public function hasException(HttpAdapterException $exception)
+    {
+        return array_search($exception, $this->exceptions, true) !== false;
+    }
 
     /**
      * Checks if any exception exists
      *
      * @return boolean
      */
-    public function hasExceptions();
+    public function hasExceptions()
+    {
+        return !empty($this->exceptions);
+    }
 
     /**
      * Sets the exceptions
      *
      * @param HttpAdapterException[] $exceptions
      */
-    public function setExceptions(array $exceptions);
+    public function setExceptions(array $exceptions)
+    {
+        $this->clearExceptions();
+        $this->addExceptions($exceptions);
+    }
 
     /**
      * Adds an exception
      *
      * @param HttpAdapterException $exception
      */
-    public function addException(HttpAdapterException $exception);
+    public function addException(HttpAdapterException $exception)
+    {
+        $this->exceptions[] = $exception;
+    }
 
     /**
      * Adds some exceptions
      *
      * @param HttpAdapterException[] $exceptions
      */
-    public function addExceptions(array $exceptions);
+    public function addExceptions(array $exceptions)
+    {
+        foreach ($exceptions as $exception) {
+            $this->addException($exception);
+        }
+    }
 
     /**
      * Removes an exception
      *
      * @param HttpAdapterException $exception
      */
-    public function removeException(HttpAdapterException $exception);
+    public function removeException(HttpAdapterException $exception)
+    {
+        unset($this->exceptions[array_search($exception, $this->exceptions, true)]);
+        $this->exceptions = array_values($this->exceptions);
+    }
 
     /**
      * Removes some exceptions
      *
      * @param HttpAdapterException[] $exceptions
      */
-    public function removeExceptions(array $exceptions);
+    public function removeExceptions(array $exceptions)
+    {
+        foreach ($exceptions as $exception) {
+            $this->removeException($exception);
+        }
+    }
 
     /**
      * Clears all exceptions
      */
-    public function clearExceptions();
+    public function clearExceptions()
+    {
+        $this->exceptions = [];
+    }
 
     /**
      * Returns all responses
      *
      * @return ResponseInterface[]
      */
-    public function getResponses();
+    public function getResponses()
+    {
+        return $this->responses;
+    }
 
     /**
      * Checks if a specific response exists
@@ -96,52 +154,82 @@ public function getResponses();
      *
      * @return boolean
      */
-    public function hasResponse(ResponseInterface $response);
+    public function hasResponse(ResponseInterface $response)
+    {
+        return array_search($response, $this->responses, true) !== false;
+    }
 
     /**
      * Checks if any response exists
      *
      * @return boolean
      */
-    public function hasResponses();
+    public function hasResponses()
+    {
+        return !empty($this->responses);
+    }
 
     /**
      * Sets the responses
      *
      * @param ResponseInterface[] $responses
      */
-    public function setResponses(array $responses);
+    public function setResponses(array $responses)
+    {
+        $this->clearResponses();
+        $this->addResponses($responses);
+    }
 
     /**
      * Adds a response
      *
      * @param ResponseInterface $response
      */
-    public function addResponse(ResponseInterface $response);
+    public function addResponse(ResponseInterface $response)
+    {
+        $this->responses[] = $response;
+    }
 
     /**
      * Adds some responses
      *
      * @param ResponseInterface[] $responses
      */
-    public function addResponses(array $responses);
+    public function addResponses(array $responses)
+    {
+        foreach ($responses as $response) {
+            $this->addResponse($response);
+        }
+    }
 
     /**
      * Removes a response
      *
      * @param ResponseInterface $response
      */
-    public function removeResponse(ResponseInterface $response);
+    public function removeResponse(ResponseInterface $response)
+    {
+        unset($this->responses[array_search($response, $this->responses, true)]);
+        $this->responses = array_values($this->responses);
+    }
 
     /**
      * Removes some responses
      *
      * @param ResponseInterface[] $responses
      */
-    public function removeResponses(array $responses);
+    public function removeResponses(array $responses)
+    {
+        foreach ($responses as $response) {
+            $this->removeResponse($response);
+        }
+    }
 
     /**
      * Clears all responses
      */
-    public function clearResponses();
+    public function clearResponses()
+    {
+        $this->responses = [];
+    }
 }