mirror of
https://github.com/ovh/php-ovh.git
synced 2023-11-05 03:20:26 +01:00
Update Guzzle to 6.0
Rewrite API for to support new Guzzle 6.0
This commit is contained in:
parent
3e0e7714d3
commit
47d3cd2ed7
@ -3,7 +3,7 @@
|
|||||||
"description": "Wrapper for OVH APIs",
|
"description": "Wrapper for OVH APIs",
|
||||||
"license": "BSD-3-Clause",
|
"license": "BSD-3-Clause",
|
||||||
"require": {
|
"require": {
|
||||||
"guzzlehttp/guzzle": ">=4.0,<6.0"
|
"guzzlehttp/guzzle": "^6.0"
|
||||||
},
|
},
|
||||||
"authors": [
|
"authors": [
|
||||||
{
|
{
|
||||||
|
166
src/Api.php
166
src/Api.php
@ -30,8 +30,9 @@
|
|||||||
|
|
||||||
namespace Ovh;
|
namespace Ovh;
|
||||||
|
|
||||||
use GuzzleHttp\Client as GClient;
|
use GuzzleHttp\Client;
|
||||||
use GuzzleHttp\Stream\Stream;
|
use GuzzleHttp\Psr7\Request;
|
||||||
|
use GuzzleHttp\Psr7\Response;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wrapper to manage login and exchanges with simpliest Ovh API
|
* Wrapper to manage login and exchanges with simpliest Ovh API
|
||||||
@ -44,71 +45,87 @@ use GuzzleHttp\Stream\Stream;
|
|||||||
* @package Ovh
|
* @package Ovh
|
||||||
* @category Ovh
|
* @category Ovh
|
||||||
* @author Vincent Cassé <vincent.casse@ovh.net>
|
* @author Vincent Cassé <vincent.casse@ovh.net>
|
||||||
|
* @author Thierry Goettelmann <thierry@byscripts.info>
|
||||||
*/
|
*/
|
||||||
class Api
|
class Api
|
||||||
{
|
{
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Url to communicate with Ovh API
|
* Url to communicate with Ovh API
|
||||||
|
*
|
||||||
|
* @var array
|
||||||
*/
|
*/
|
||||||
private $endpoints = array(
|
private $endpoints = [
|
||||||
'ovh-eu' => 'https://api.ovh.com/1.0',
|
'ovh-eu' => 'https://api.ovh.com/1.0',
|
||||||
'ovh-ca' => 'https://ca.api.ovh.com/1.0',
|
'ovh-ca' => 'https://ca.api.ovh.com/1.0',
|
||||||
'kimsufi-eu' => 'https://eu.api.kimsufi.com/1.0',
|
'kimsufi-eu' => 'https://eu.api.kimsufi.com/1.0',
|
||||||
'kimsufi-ca' => 'https://ca.api.kimsufi.com/1.0',
|
'kimsufi-ca' => 'https://ca.api.kimsufi.com/1.0',
|
||||||
'soyoustart-eu' => 'https://eu.api.soyoustart.com/1.0',
|
'soyoustart-eu' => 'https://eu.api.soyoustart.com/1.0',
|
||||||
'soyoustart-ca' => 'https://ca.api.soyoustart.com/1.0',
|
'soyoustart-ca' => 'https://ca.api.soyoustart.com/1.0',
|
||||||
'runabove-ca' => 'https://api.runabove.com/1.0');
|
'runabove-ca' => 'https://api.runabove.com/1.0',
|
||||||
|
];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Contain endpoint selected to choose API
|
* Contain endpoint selected to choose API
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
*/
|
*/
|
||||||
private $endpoint = null;
|
private $endpoint = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Contain key of the current application
|
* Contain key of the current application
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
*/
|
*/
|
||||||
private $application_key = null;
|
private $application_key = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Contain secret of the current application
|
* Contain secret of the current application
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
*/
|
*/
|
||||||
private $application_secret = null;
|
private $application_secret = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Contain consumer key of the current application
|
* Contain consumer key of the current application
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
*/
|
*/
|
||||||
private $consumer_key = null;
|
private $consumer_key = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Contain delta between local timestamp and api server timestamp
|
* Contain delta between local timestamp and api server timestamp
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
*/
|
*/
|
||||||
private $time_delta = null;
|
private $time_delta = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Contain http client connection
|
* Contain http client connection
|
||||||
|
*
|
||||||
|
* @var Client
|
||||||
*/
|
*/
|
||||||
private $http_client = null;
|
private $http_client = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Construct a new wrapper instance
|
* Construct a new wrapper instance
|
||||||
*
|
*
|
||||||
* @param $application_key key of your application.
|
* @param string $application_key key of your application.
|
||||||
* For OVH APIs, you can create a application's credentials on https://api.ovh.com/createApp/
|
* For OVH APIs, you can create a application's credentials on
|
||||||
* @param $application_secret secret of your application.
|
* https://api.ovh.com/createApp/
|
||||||
* @param $api_endpoint name of api selected
|
* @param string $application_secret secret of your application.
|
||||||
* @param $consumer_key If you have already a consumer key, this parameter prevent to do a
|
* @param string $api_endpoint name of api selected
|
||||||
|
* @param string $consumer_key If you have already a consumer key, this parameter prevent to do a
|
||||||
* new authentication
|
* new authentication
|
||||||
* @param $http_client instance of http client
|
* @param Client $http_client instance of http client
|
||||||
*
|
*
|
||||||
* @throws InvalidParameterException if one parameter is missing or with bad value
|
* @throws Exceptions\InvalidParameterException if one parameter is missing or with bad value
|
||||||
*/
|
*/
|
||||||
public function __construct(
|
public function __construct(
|
||||||
$application_key,
|
$application_key,
|
||||||
$application_secret,
|
$application_secret,
|
||||||
$api_endpoint,
|
$api_endpoint,
|
||||||
$consumer_key = null,
|
$consumer_key = null,
|
||||||
GClient $http_client = null
|
Client $http_client = null
|
||||||
) {
|
) {
|
||||||
if (!isset($application_key)) {
|
if (!isset($application_key)) {
|
||||||
throw new Exceptions\InvalidParameterException("Application key parameter is empty");
|
throw new Exceptions\InvalidParameterException("Application key parameter is empty");
|
||||||
@ -127,7 +144,7 @@ class Api
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (!isset($http_client)) {
|
if (!isset($http_client)) {
|
||||||
$http_client = new GClient();
|
$http_client = new Client();
|
||||||
}
|
}
|
||||||
|
|
||||||
$this->application_key = $application_key;
|
$this->application_key = $application_key;
|
||||||
@ -142,14 +159,16 @@ class Api
|
|||||||
* Calculate time delta between local machine and API's server
|
* Calculate time delta between local machine and API's server
|
||||||
*
|
*
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
|
* @return int
|
||||||
*/
|
*/
|
||||||
private function calculateTimeDelta()
|
private function calculateTimeDelta()
|
||||||
{
|
{
|
||||||
if (!isset($this->time_delta)) {
|
if (!isset($this->time_delta)) {
|
||||||
$response = $this->http_client->get($this->endpoint . "/auth/time");
|
$response = $this->http_client->get($this->endpoint . "/auth/time");
|
||||||
$serverTimestamp = (int) (String) $response->getBody();
|
$serverTimestamp = (int)(String)$response->getBody();
|
||||||
$this->time_delta = $serverTimestamp - (int) \time();
|
$this->time_delta = $serverTimestamp - (int)\time();
|
||||||
}
|
}
|
||||||
|
|
||||||
return $this->time_delta;
|
return $this->time_delta;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -157,13 +176,14 @@ class Api
|
|||||||
* Request a consumer key from the API and the validation link to
|
* Request a consumer key from the API and the validation link to
|
||||||
* authorize user to validate this consumer key
|
* authorize user to validate this consumer key
|
||||||
*
|
*
|
||||||
* @param $accessRules list of rules your application need.
|
* @param array $accessRules list of rules your application need.
|
||||||
* @param $redirection url to redirect on your website after authentication
|
* @param string $redirection url to redirect on your website after authentication
|
||||||
*
|
*
|
||||||
|
* @return mixed
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
*/
|
*/
|
||||||
public function requestCredentials(
|
public function requestCredentials(
|
||||||
$accessRules,
|
array $accessRules,
|
||||||
$redirection = null
|
$redirection = null
|
||||||
) {
|
) {
|
||||||
$parameters = new \StdClass();
|
$parameters = new \StdClass();
|
||||||
@ -179,6 +199,7 @@ class Api
|
|||||||
);
|
);
|
||||||
|
|
||||||
$this->consumer_key = $response["consumerKey"];
|
$this->consumer_key = $response["consumerKey"];
|
||||||
|
|
||||||
return $response;
|
return $response;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -186,42 +207,44 @@ class Api
|
|||||||
* This is the main method of this wrapper. It will
|
* This is the main method of this wrapper. It will
|
||||||
* sign a given query and return its result.
|
* sign a given query and return its result.
|
||||||
*
|
*
|
||||||
* @param $method HTTP method of request (GET,POST,PUT,DELETE)
|
* @param string $method HTTP method of request (GET,POST,PUT,DELETE)
|
||||||
* @param $path relative url of API request
|
* @param string $path relative url of API request
|
||||||
* @param $content body of the request
|
* @param \stdClass|array|null $content body of the request
|
||||||
* @param $is_authenticated if the request use authentication
|
* @param bool $is_authenticated if the request use authentication
|
||||||
*
|
*
|
||||||
|
* @return array
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
*/
|
*/
|
||||||
private function rawCall(
|
private function rawCall($method, $path, $content = null, $is_authenticated = true)
|
||||||
$method,
|
{
|
||||||
$path,
|
|
||||||
$content = null,
|
|
||||||
$is_authenticated = true
|
|
||||||
) {
|
|
||||||
$url = $this->endpoint . $path;
|
$url = $this->endpoint . $path;
|
||||||
|
$request = new Request($method, $url);
|
||||||
$request = $this->http_client->createRequest(
|
|
||||||
$method,
|
|
||||||
$url
|
|
||||||
);
|
|
||||||
|
|
||||||
if (isset($content) && $method == 'GET') {
|
if (isset($content) && $method == 'GET') {
|
||||||
$query = $request->getQuery();
|
|
||||||
foreach ($content as $key => $value) {
|
$queryString = $request->getUri()->getQuery();
|
||||||
$query->set($key, $value);
|
|
||||||
}
|
$query = false !== strpos($queryString, '&')
|
||||||
$url .= '?'.$query;
|
? explode('&', $queryString)
|
||||||
|
: [];
|
||||||
|
|
||||||
|
$query = array_merge($query, (array)$content);
|
||||||
|
$query = \GuzzleHttp\Psr7\build_query($query);
|
||||||
|
|
||||||
|
$request = $request->withUri($request->getUri()->withQuery($query));
|
||||||
$body = "";
|
$body = "";
|
||||||
} elseif (isset($content)) {
|
} elseif (isset($content)) {
|
||||||
$body = json_encode($content);
|
$body = json_encode($content);
|
||||||
$request->setBody(Stream::factory($body));
|
|
||||||
|
$request->getBody()->write($body);
|
||||||
} else {
|
} else {
|
||||||
$body = "";
|
$body = "";
|
||||||
}
|
}
|
||||||
|
|
||||||
$request->setHeader('Content-Type', 'application/json; charset=utf-8');
|
$headers = [
|
||||||
$request->setHeader('X-Ovh-Application', $this->application_key);
|
'Content-Type' => 'application/json; charset=utf-8',
|
||||||
|
'X-Ovh-Application' => $this->application_key,
|
||||||
|
];
|
||||||
|
|
||||||
if ($is_authenticated) {
|
if ($is_authenticated) {
|
||||||
if (!isset($this->time_delta)) {
|
if (!isset($this->time_delta)) {
|
||||||
@ -229,75 +252,76 @@ class Api
|
|||||||
}
|
}
|
||||||
$now = time() + $this->time_delta;
|
$now = time() + $this->time_delta;
|
||||||
|
|
||||||
$request->setHeader('X-Ovh-Timestamp', $now);
|
$headers['X-Ovh-Timestamp'] = $now;
|
||||||
|
|
||||||
if (isset($this->consumer_key)) {
|
if (isset($this->consumer_key)) {
|
||||||
$toSign = $this->application_secret.'+'.$this->consumer_key.'+'.$method.'+'.$url.'+'.$body.'+'.$now;
|
$toSign = $this->application_secret . '+' . $this->consumer_key . '+' . $method
|
||||||
|
. '+' . $url . '+' . $body . '+' . $now;
|
||||||
$signature = '$1$' . sha1($toSign);
|
$signature = '$1$' . sha1($toSign);
|
||||||
$request->setHeader('X-Ovh-Consumer', $this->consumer_key);
|
$headers['X-Ovh-Consumer'] = $this->consumer_key;
|
||||||
$request->setHeader('X-Ovh-Signature', $signature);
|
$headers['X-Ovh-Signature'] = $signature;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return $this->http_client->send($request)->json();
|
|
||||||
|
/** @var Response $response */
|
||||||
|
$response = $this->http_client->send($request, ['headers' => $headers]);
|
||||||
|
|
||||||
|
return json_decode($response->getBody(), true);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wrap call to Ovh APIs for GET requests
|
* Wrap call to Ovh APIs for GET requests
|
||||||
*
|
*
|
||||||
* @param $path path ask inside api
|
* @param string $path path ask inside api
|
||||||
* @param $content content to send inside body of request
|
* @param array $content content to send inside body of request
|
||||||
*
|
*
|
||||||
|
* @return array
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
*/
|
*/
|
||||||
public function get(
|
public function get($path, $content = null)
|
||||||
$path,
|
{
|
||||||
$content = null
|
|
||||||
) {
|
|
||||||
return $this->rawCall("GET", $path, $content);
|
return $this->rawCall("GET", $path, $content);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wrap call to Ovh APIs for POST requests
|
* Wrap call to Ovh APIs for POST requests
|
||||||
*
|
*
|
||||||
* @param $path path ask inside api
|
* @param string $path path ask inside api
|
||||||
* @param $content content to send inside body of request
|
* @param array $content content to send inside body of request
|
||||||
*
|
*
|
||||||
|
* @return array
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
*/
|
*/
|
||||||
public function post(
|
public function post($path, $content = null)
|
||||||
$path,
|
{
|
||||||
$content = null
|
|
||||||
) {
|
|
||||||
return $this->rawCall("POST", $path, $content);
|
return $this->rawCall("POST", $path, $content);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wrap call to Ovh APIs for PUT requests
|
* Wrap call to Ovh APIs for PUT requests
|
||||||
*
|
*
|
||||||
* @param $path path ask inside api
|
* @param string $path path ask inside api
|
||||||
* @param $content content to send inside body of request
|
* @param array $content content to send inside body of request
|
||||||
*
|
*
|
||||||
|
* @return array
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
*/
|
*/
|
||||||
public function put(
|
public function put($path, $content)
|
||||||
$path,
|
{
|
||||||
$content
|
|
||||||
) {
|
|
||||||
return $this->rawCall("PUT", $path, $content);
|
return $this->rawCall("PUT", $path, $content);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Wrap call to Ovh APIs for DELETE requests
|
* Wrap call to Ovh APIs for DELETE requests
|
||||||
*
|
*
|
||||||
* @param $path path ask inside api
|
* @param string $path path ask inside api
|
||||||
* @param $content content to send inside body of request
|
* @param array $content content to send inside body of request
|
||||||
*
|
*
|
||||||
|
* @return array
|
||||||
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
* @throws \GuzzleHttp\Exception\ClientException if http request is an error
|
||||||
*/
|
*/
|
||||||
public function delete(
|
public function delete($path, $content = null)
|
||||||
$path,
|
{
|
||||||
$content = null
|
|
||||||
) {
|
|
||||||
return $this->rawCall("DELETE", $path, $content);
|
return $this->rawCall("DELETE", $path, $content);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user