abstracted http request

PaystackHQ · May 21, 2020 · abc3f69 · abc3f69
1 parent 9079b9d
commit abc3f69
Show file tree

Hide file tree

Showing 3 changed files with 22 additions and 17 deletions.
diff --git a/src/Message/AbstractRequest.php b/src/Message/AbstractRequest.php
@@ -37,4 +37,20 @@ public function setSecretKey($value)
     {
         $this->setParameter('secret_key', $value);
     }
+
+    protected function sendRequest($method, $endpoint, array $data = null)
+    {
+
+            $headers = [
+                'Authorization' => 'Bearer ' . $this->getSecretKey(),
+                'Content-Type' => 'application/json',
+                'Cache-Control' => 'no-cache'
+            ];
+
+            $response = $this->httpClient->request($method, $this->baseApiEndpoint. $endpoint, $headers, json_encode($data));
+            $responseData = json_decode((string)$response->getBody(), true);
+
+            return $responseData;
+
+    }
 }
diff --git a/src/Message/CompletePurchaseRequest.php b/src/Message/CompletePurchaseRequest.php
@@ -28,15 +28,11 @@ public function getData()
     public function sendData($data)
     {
         try {
-            $headers = [
-                'Authorization' => 'Bearer ' . $this->getSecretKey(),
-                'Content-Type' => 'application/json',
-                'Cache-Control' => 'no-cache'
-            ];
-
-            $response = $this->httpClient->request('GET', $this->getApiEndpoint(), $headers, json_encode($data));
-            $responseData = json_decode((string)$response->getBody(), true);
+
+            $response = $this->sendRequest('GET', $this->getApiEndpoint(), json_encode($data));
+
         } catch (\Exception $e) {
+
             throw new InvalidRequestException($e->getMessage(), $e->getCode(), $e);
         }
 

diff --git a/src/Message/PurchaseRequest.php b/src/Message/PurchaseRequest.php
@@ -39,19 +39,12 @@ public function getData()
     public function sendData($data)
     {
         try {
-            $headers = [
-                'Authorization' => 'Bearer ' . $this->getSecretKey(),
-                'Content-Type' => 'application/json',
-                'Cache-Control' => 'no-cache'
-            ];
-
-            $response = $this->httpClient->request('POST', $this->getApiEndpoint(), $headers, json_encode($data));
-            $responseData = json_decode((string)$response->getBody(), true);
+            $response = $this->sendRequest('POST', $this->getApiEndpoint(), $data);
         } catch (\Exception $e) {
             throw new InvalidRequestException($e->getMessage(), $e->getCode(), $e);
         }
 
-        return $this->response = new PurchaseResponse($this, $responseData);
+        return $this->response = new PurchaseResponse($this, $response);
     }
 
     /**