Refactoring base functions

Fetch functions, curl and it's parameters now are all in the FetchApi file, while other Classes will receive them by Dependence Injection
2025-12-13 04:40:42 -03:00 · 2019-06-21 21:12:00 -03:00
parent 7664bf67a4
commit 460812852e
4 changed files with 160 additions and 77 deletions
--- a/src/FetchApi.php
+++ b/src/FetchApi.php
@@ -0,0 +1,109 @@
+<?php
+/**
+ * A very compact and simple Memsource API library
+ * 
+ * @author Bruno Fontes <developer@brunofontes.net>
+ * @link   https://github.com/brunofontes
+ */
+namespace BrunoFontes\Memsource;
+
+class FetchApi
+{
+    protected $base_url;
+    protected $token;
+    
+    /**
+     * BaseAPI needs at least the Memsource Token to use it's API
+     *
+     * @param string $token
+     * @param string $memsourceBaseUrl [Optional] A non-standard Memsource URL base for the API to work
+     */
+    public function __construct(string $token = null, string $memsourceBaseUrl = 'https://cloud.memsource.com/web')
+    {
+        $this->base_url = $memsourceBaseUrl;
+        $this->token = $token;
+    }
+
+    /**
+     * Fetch API data using curl
+     *
+     * @param string $method     Should be 'get', 'post', 'jsonPost' or 'download'
+     * @param string $url        The api url
+     * @param array  $parameters Array ['key' => 'value'] of get or post fields or structured array for json requests
+     * @param string $filename   [optional] Specified file in which the download request will be saved
+     *
+     * @return void
+     */
+    public function fetch(string $method, string $url, array $parameters, $filename = '') : string
+    {
+        $setopt = [];
+        switch ($method) {
+        case 'get':
+            $parameters = http_build_query($parameters);
+            $url = $url . ($parameters ? '?'.$parameters : '');
+            break;
+        case 'post':
+            $parameters = http_build_query($parameters);
+            $setopt = $this->getPostParam($parameters);
+            break;
+        case 'jsonPost':
+            $setopt = $this->getJsonPostParam($parameters);
+            break;
+        case 'download':
+            if (empty($filename)) {
+                throw new Exception('You need to specify a filename to download a file.', 1);
+            }
+            $setopt = $this->getDownloadFileParam($filename)
+                    + $this->getJsonPostParam($parameters);
+            break;
+        }
+        return $this->curl($url, $setopt);
+    }
+
+    private function getDownloadFileParam(string $filename)
+    {
+        return [
+            CURLOPT_FILE => $file,
+        ];
+    }
+
+    private function getJsonPostParam(array $postFields)
+    {
+        return [
+            CURLOPT_HTTPHEADER => ['Content-type: application/json'],
+            CURLOPT_POST => true,
+            CURLOPT_POSTFIELDS => json_encode($postFields)
+        ];
+    }
+
+    private function getPostParam(string $postFields)
+    {
+        return [
+            CURLOPT_POST => true,
+            CURLOPT_POSTFIELDS => $postFields
+        ];
+    }
+
+    protected function curl(string $url, array $curl_extra_setopt = [])
+    {
+        if (empty($url)) {
+            throw new Exception('URL not defined', 1);
+        }
+
+        $header = $this->token ? ["Authorization: Bearer {$this->token}"] : [];
+        $header = array_merge($header, $curl_extra_setopt[CURLOPT_HTTPHEADER]??[]);
+        $curl_setopt = [
+            CURLOPT_URL => $this->base_url . $url,
+            CURLOPT_HTTPHEADER => $header,
+            CURLOPT_SSL_VERIFYPEER => false,
+            CURLOPT_TIMEOUT => 500,
+            CURLOPT_FOLLOWLOCATION => true,
+            CURLOPT_RETURNTRANSFER => true
+        ];
+        $curl = curl_init();
+        curl_setopt_array($curl, ($curl_setopt + $curl_extra_setopt));
+        $response = curl_exec($curl);
+        curl_close($curl);
+        return $response;
+    }
+}