refactor: allow dependency injection of httpClient

src/Heap/Client.php

@@ -2,22 +2,43 @@
 
 namespace Heap;
 
+use GuzzleHttp\ClientInterface;
+use GuzzleHttp\Exception\GuzzleException;
+use GuzzleHttp\Exception\ServerException;
 use Heap\Exception\HeapException;
-use Heap\Helper\Request;
+use Psr\Http\Message\ResponseInterface;
 
 class Client
 {
+    /**
+     * @var string
+     */
+    private $apiUri = 'https://heapanalytics.com/api';
+
+    /**
+     * @var string
+     */
     private $appId;
 
+    /**
+     * @var ClientInterface
+     */
+    private $httpClient;
+
     /**
      * Client constructor.
      *
-     * @param null $appId
+     * @param null                 $appId
+     * @param ClientInterface|null $httpClient
      */
-    public function __construct($appId)
+    public function __construct($appId, ClientInterface $httpClient = null)
     {
+        if (! $httpClient) {
+            $httpClient = new \GuzzleHttp\Client();
+        }
+
         $this->appId = $appId;
-        $this->request = new Request();
+        $this->httpClient = $httpClient;
     }
 
     /**
@@ -35,20 +56,21 @@ public function setAppId($appId)
     }
 
     /**
-     * @param $event
-     * @param $identity
+     * @param       $event
+     * @param       $identity
      * @param array $properties
      *
-     * @return mixed|\Psr\Http\Message\ResponseInterface
+     * @return ResponseInterface
      * @throws HeapException
+     * @throws GuzzleException
      */
     public function track($event, $identity, $properties = array())
     {
-        if(!$event || empty($event)) {
+        if (!$event || empty($event)) {
             throw new HeapException('You need to set the event name.');
         }
 
-        if(!$identity || empty($identity)) {
+        if (!$identity || empty($identity)) {
             throw new HeapException('You need to set the identity. More info: https://heapanalytics.com/docs/server-side');
         }
 
@@ -59,19 +81,20 @@ public function track($event, $identity, $properties = array())
             'identity' => $identity,
         );
 
-        return $this->request->call('POST', '/track', $data);
+        return $this->call('POST', '/track', $data);
     }
 
     /**
-     * @param $identity
+     * @param       $identity
      * @param array $properties
      *
-     * @return mixed|\Psr\Http\Message\ResponseInterface
+     * @return ResponseInterface
      * @throws HeapException
+     * @throws GuzzleException
      */
     public function addUserProperties($identity, $properties = array())
     {
-        if(!$identity || empty($identity)) {
+        if (!$identity || empty($identity)) {
             throw new HeapException('You need to set the identity. More info: https://heapanalytics.com/docs/server-side');
         }
 
@@ -81,6 +104,43 @@ public function addUserProperties($identity, $properties = array())
             'identity' => $identity,
         );
 
-        return $this->request->call('POST', '/add_user_properties', $data);
+        return $this->call('POST', '/add_user_properties', $data);
+    }
+
+    /**
+     * @param $endpoint
+     *
+     * @return string
+     */
+    public function generateUri($endpoint)
+    {
+        return $this->apiUri.$endpoint;
+    }
+
+    /**
+     * @param string $method
+     * @param string $endpoint
+     * @param array  $data
+     *
+     * @return ResponseInterface
+     * @throws HeapException
+     * @throws GuzzleException
+     */
+    public function call($method, $endpoint, $data)
+    {
+        $fullUri = $this->generateUri($endpoint);
+
+        try {
+            $response = $this->httpClient->request($method, $fullUri, array(
+                'headers' => array(
+                    'Content-Type' => 'application/json',
+                ),
+                'body' => \GuzzleHttp\json_encode($data),
+            ));
+        } catch (ServerException $e) {
+            throw new HeapException($e->getMessage());
+        }
+
+        return $response;
     }
-}
+}