Throw a CurlException if we have a cURL error number.

Author: seanmcn

src/Kobas/Client.php

@@ -3,6 +3,7 @@
 namespace Kobas;
 
 
+use Kobas\Exception\CurlException;
 use Kobas\Exception\HttpException;
 use Kobas\Auth\Signer;
 use Kobas\Request\Curl;
@@ -100,6 +101,7 @@ public function disableSSLVerification()
      * @param array $headers
      * @return mixed
      * @throws HttpException
+     * @throws CurlException
      */
     public function get($route, array $params = array(), array $headers = array())
     {
@@ -113,6 +115,7 @@ public function get($route, array $params = array(), array $headers = array())
      * @param array $headers
      * @return mixed
      * @throws HttpException
+     * @throws CurlException
      */
     public function post($route, array $params = array(), array $headers = array())
     {
@@ -126,6 +129,7 @@ public function post($route, array $params = array(), array $headers = array())
      * @param array $headers
      * @return mixed
      * @throws HttpException
+     * @throws CurlException
      */
     public function put($route, array $params = array(), array $headers = array())
     {
@@ -139,6 +143,7 @@ public function put($route, array $params = array(), array $headers = array())
      * @param array $headers
      * @return mixed
      * @throws HttpException
+     * @throws CurlException
      */
     public function delete($route, array $params = array(), array $headers = array())
     {
@@ -152,6 +157,7 @@ public function delete($route, array $params = array(), array $headers = array()
      * @param array $headers
      * @return mixed
      * @throws HttpException
+     * @throws CurlException
      */
     protected function call($http_method, $route, array $params = array(), array $headers = array())
     {
@@ -169,7 +175,7 @@ protected function call($http_method, $route, array $params = array(), array $he
             ->setOption(CURLOPT_FOLLOWLOCATION, true)
             ->setOption(CURLOPT_ENCODING, '');
 
-        foreach($this->curl_options as $option => $value) {
+        foreach ($this->curl_options as $option => $value) {
             $this->request->setOption($option, $value);
         }
 
@@ -203,7 +209,13 @@ protected function call($http_method, $route, array $params = array(), array $he
 
         $this->request->setOption(CURLOPT_HTTPHEADER, $headers);
 
+
         $result = $this->request->execute();
+
+        if ($this->request->getErrorNumber()) {
+            throw new CurlException($this->request->getErrorMessage(), $this->request->getErrorNumber());
+        }
+
         $last_response = $this->request->getInfo(CURLINFO_HTTP_CODE);
 
         $this->request->close();

src/Kobas/Exception/CurlException.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Kobas\Exception;
+
+
+/**
+ * Class CurlException
+ * @package Kobas\Exception
+ */
+class CurlException extends \Exception
+{
+
+    public function __construct($message, $code)
+    {
+        parent::__construct($message, $code);
+    }
+}

src/Kobas/Request/Curl.php

@@ -2,6 +2,7 @@
 
 namespace Kobas\Request;
 
+
 /**
  * Class Curl
  * @package Kobas\Request
@@ -62,6 +63,20 @@ public function getInfo($name)
         return curl_getinfo($this->handle, $name);
     }
 
+    /**
+     * @return int|mixed
+     */
+    public function getErrorNumber() {
+        return curl_errno($this->handle);
+    }
+
+    /**
+     * @return mixed|string
+     */
+    public function getErrorMessage() {
+        return curl_error($this->handle);
+    }
+
     /**
      * @return $this
      */

src/Kobas/Request/HttpRequest.php

@@ -2,6 +2,10 @@
 
 namespace Kobas\Request;
 
+/**
+ * Interface HttpRequest
+ * @package Kobas\Request
+ */
 interface HttpRequest
 {
     /**
@@ -27,8 +31,24 @@ public function setOption($name, $value);
      */
     public function execute();
 
+    /**
+     * @param $name
+     * @return mixed
+     */
     public function getInfo($name);
 
+
+    /**
+     * @return mixed
+     */
+    public function getErrorNumber();
+
+    /**
+     * @return mixed
+     */
+    public function getErrorMessage();
+
+
     /**
      * @return $this
      */