OXO/Memsource-API
5
0
Fork 0
mirror of https://github.com/brunofontes/Memsource-API.git synced 2024-11-23 19:00:50 +00:00
Code Issues Projects Releases Wiki Activity

Refactoring curl functions

Browse Source
This commit is contained in:
Bruno F. Fontes 2019-06-19 20:50:28 -03:00
parent d772ee5d47
commit 362afc1dfd
Signed by: brunofontes
GPG Key ID: EE3447CE80048495
2 changed files with 53 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

69
src/Memsource.php
View File

@ -23,49 +23,72 @@ class Memsource
return $this->_oauth ?? $this->_oauth = new \BrunoFontes\Memsource\oauth(); return $this->_oauth ?? $this->_oauth = new \BrunoFontes\Memsource\oauth();
} }
public function get(string $url) /**
* 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
*/
protected function fetch(string $method, string $url, array $parameters, $filename = '')
{ {
$response = $this->curl($url); switch ($method) {
return json_decode($response, true); case 'get':
$parameters = http_build_query($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);
} }
protected function apiDownloadFile(string $url, array $postFields, string $filename) private function getDownloadFileParam(string $filename)
{ {
$file = fopen($filename, 'w+'); $file = fopen($filename, 'w+');
$extraSetopt = [ return [
CURLOPT_FILE => $file, CURLOPT_FILE => $file,
CURLOPT_FOLLOWLOCATION => true, CURLOPT_FOLLOWLOCATION => true,
]; ];
return $this->jsonPost($url, $postFields, $extraSetopt);
} }
protected function jsonPost(string $url, array $postFields, array $extraSetopt = [], array $extraHeader = []) private function getJsonPostParam(array $postFields)
{ {
$extraHeader = (['Content-type: application/json'] + $extraHeader); return [
$postFields = json_encode($postFields); CURLOPT_HTTPHEADER => ['Content-type: application/json'],
$response = $this->post($url, $postFields, [], $extraHeader); CURLOPT_POST => true,
return json_decode($response, true); CURLOPT_POSTFIELDS => json_encode($postFields)
];
} }
protected function post(string $url, string $postFields, array $extraSetopt = [], array $extraHeader = []) private function getPostParam(string $postFields)
{ {
$extraSetopt = ( return [
$extraSetopt + CURLOPT_POST => true,
[ CURLOPT_POSTFIELDS => $postFields
CURLOPT_POST => true, ];
CURLOPT_POSTFIELDS => $postFields
]
);
$response = $this->curl($url, $extraSetopt, $extraHeader);
return json_decode($response, true);
} }
protected function curl(string $url, array $curl_extra_setopt=[], array $extraHeader=[]) protected function curl(string $url, array $curl_extra_setopt=[])
{ {
$header = $this->token ? ["Authorization: Bearer {$this->token}"] : []; $header = $this->token ? ["Authorization: Bearer {$this->token}"] : [];
$curl_setopt = [ $curl_setopt = [
CURLOPT_URL => $this->base_url . $url, CURLOPT_URL => $this->base_url . $url,
CURLOPT_HTTPHEADER => ($header + $extraHeader), CURLOPT_HTTPHEADER => ($header + $curl_extra_setopt[CURLOPT_HTTPHEADER]),
CURLOPT_SSL_VERIFYPEER => false, CURLOPT_SSL_VERIFYPEER => false,
CURLOPT_TIMEOUT => 500, CURLOPT_TIMEOUT => 500,
CURLOPT_FOLLOWLOCATION => true, CURLOPT_FOLLOWLOCATION => true,

9
src/oauth.php
View File

@ -22,7 +22,7 @@ class Oauth extends \BrunoFontes\Memsource
*/ */
public function getAuthorizationCodeUrl(string $client_id, string $callback_uri) public function getAuthorizationCodeUrl(string $client_id, string $callback_uri)
{ {
$authorize_url = $this->_url . '/authorize'; $authorize_url = $this->base_url . $this->_url . '/authorize';
return $authorize_url . '?response_type=code&client_id=' . $client_id . '&redirect_uri=' . $callback_uri . '&scope=openid'; return $authorize_url . '?response_type=code&client_id=' . $client_id . '&redirect_uri=' . $callback_uri . '&scope=openid';
} }
@ -32,7 +32,12 @@ class Oauth extends \BrunoFontes\Memsource
$authorization = base64_encode("$client_id:$client_secret"); $authorization = base64_encode("$client_id:$client_secret");
$header = ["Authorization: Basic {$authorization}", 'Content-Type: application/x-www-form-urlencoded']; $header = ["Authorization: Basic {$authorization}", 'Content-Type: application/x-www-form-urlencoded'];
$content = "grant_type=authorization_code&code=$authorization_code&redirect_uri=$callback_uri"; $content = "grant_type=authorization_code&code=$authorization_code&redirect_uri=$callback_uri";
$response = $this->post($token_url, $content, [], $header); $params = [
CURLOPT_HTTPHEADER => $header,
CURLOPT_POST => true,
CURLOPT_POSTFIELDS => $content
];
$response = $this->curl($token_url, $params);
if ($respose['error']) { if ($respose['error']) {
throw new Exception("Error getting access token", 1); throw new Exception("Error getting access token", 1);
} }