Viewing file:  APIResource.php (11.09 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
/**
* Vonage Client Library for PHP
*
* @copyright Copyright (c) 2016-2020 Vonage, Inc. (http://vonage.com)
* @license https://github.com/Vonage/vonage-php-sdk-core/blob/master/LICENSE.txt Apache License 2.0
*/
declare(strict_types=1);
namespace Vonage\Client;
use function is_null;
use function json_decode;
use function json_encode;
use function http_build_query;
use Laminas\Diactoros\Request;
use Vonage\Entity\Filter\EmptyFilter;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use Vonage\Entity\IterableAPICollection;
use Vonage\Entity\Filter\FilterInterface;
use Psr\Http\Client\ClientExceptionInterface;
use Vonage\Client\Credentials\Handler\HandlerInterface;
class APIResource implements ClientAwareInterface
{
use ClientAwareTrait;
/**
* @var HandlerInterface
*/
protected $authHandler;
/**
* Base URL that we will hit. This can be overridden from the underlying
* client or directly on this class.
*
* @var string
*/
protected $baseUrl = '';
/**
* @var string
*/
protected $baseUri;
/**
* @var string
*/
protected $collectionName = '';
/**
* @var IterableAPICollection
*/
protected $collectionPrototype;
/**
* Sets flag that says to check for errors even on 200 Success
*
* @var bool
*/
protected $errorsOn200 = false;
/**
* Error handler to use when reviewing API responses
*
* @var callable
*/
protected $exceptionErrorHandler;
/**
* @var bool
*/
protected $isHAL = true;
/**
* @var RequestInterface
*/
protected $lastRequest;
/**
* @var ResponseInterface
*/
protected $lastResponse;
/**
* Adds authentication to a request
* @todo Use this method when Vonage\Client no longer adds authentication
*/
public function addAuth(RequestInterface $request)
{
$creds = $this->getClient()->getCredentials();
return $this->getAuthHandler()($request, $creds);
}
/**
* @throws ClientExceptionInterface
* @throws Exception\Exception
*/
public function create(array $body, string $uri = '', array $headers = []): ?array
{
if (empty($headers)) {
$headers = ['content-type' => 'application/json'];
}
$request = new Request(
$this->getBaseUrl() . $this->getBaseUri() . $uri,
'POST',
'php://temp',
$headers
);
if ($this->getAuthHandler()) {
$request = $this->addAuth($request);
}
$request->getBody()->write(json_encode($body));
$this->lastRequest = $request;
$response = $this->getClient()->send($request);
$status = (int)$response->getStatusCode();
$this->setLastResponse($response);
if (($status < 200 || $status > 299) || $this->errorsOn200()) {
$e = $this->getException($response, $request);
if ($e) {
$e->setEntity($body);
throw $e;
}
}
$response->getBody()->rewind();
return json_decode($response->getBody()->getContents(), true);
}
/**
* @throws ClientExceptionInterface
* @throws Exception\Exception
*/
public function delete(string $id, array $headers = []): ?array
{
$uri = $this->getBaseUrl() . $this->baseUri . '/' . $id;
if (empty($headers)) {
$headers = [
'accept' => 'application/json',
'content-type' => 'application/json'
];
}
$request = new Request(
$uri,
'DELETE',
'php://temp',
$headers
);
if ($this->getAuthHandler()) {
$request = $this->addAuth($request);
}
$response = $this->getClient()->send($request);
$status = (int)$response->getStatusCode();
$this->lastRequest = $request;
$this->setLastResponse($response);
if ($status < 200 || $status > 299) {
$e = $this->getException($response, $request);
$e->setEntity($id);
throw $e;
}
$response->getBody()->rewind();
return json_decode($response->getBody()->getContents(), true);
}
/**
* @throws ClientExceptionInterface
* @throws Exception\Exception
*/
public function get($id, array $query = [], array $headers = [])
{
$uri = $this->getBaseUrl() . $this->baseUri . '/' . $id;
if (!empty($query)) {
$uri .= '?' . http_build_query($query);
}
if (empty($headers)) {
$headers = [
'accept' => 'application/json',
'content-type' => 'application/json'
];
}
$request = new Request(
$uri,
'GET',
'php://temp',
$headers
);
if ($this->getAuthHandler()) {
$request = $this->addAuth($request);
}
$response = $this->getClient()->send($request);
$status = (int)$response->getStatusCode();
$this->lastRequest = $request;
$this->setLastResponse($response);
if ($status < 200 || $status > 299) {
$e = $this->getException($response, $request);
$e->setEntity($id);
throw $e;
}
return json_decode($response->getBody()->getContents(), true);
}
public function getAuthHandler(): ?HandlerInterface
{
return $this->authHandler;
}
public function getBaseUrl(): ?string
{
if (!$this->baseUrl && $this->client) {
$this->baseUrl = $this->client->getApiUrl();
}
return $this->baseUrl;
}
public function getBaseUri(): ?string
{
return $this->baseUri;
}
public function getCollectionName(): string
{
return $this->collectionName;
}
public function getCollectionPrototype(): IterableAPICollection
{
if (is_null($this->collectionPrototype)) {
$this->collectionPrototype = new IterableAPICollection();
}
return clone $this->collectionPrototype;
}
public function getExceptionErrorHandler(): callable
{
if (is_null($this->exceptionErrorHandler)) {
return new APIExceptionHandler();
}
return $this->exceptionErrorHandler;
}
/**
* Sets the error handler to use when reviewing API responses.
*/
public function setExceptionErrorHandler(callable $handler): self
{
$this->exceptionErrorHandler = $handler;
return $this;
}
protected function getException(ResponseInterface $response, RequestInterface $request)
{
return $this->getExceptionErrorHandler()($response, $request);
}
public function getLastRequest(): ?RequestInterface
{
$this->lastRequest->getBody()->rewind();
return $this->lastRequest;
}
public function getLastResponse(): ?ResponseInterface
{
$this->lastResponse->getBody()->rewind();
return $this->lastResponse;
}
public function isHAL(): bool
{
return $this->isHAL;
}
public function search(?FilterInterface $filter = null, string $uri = ''): IterableAPICollection
{
if (is_null($filter)) {
$filter = new EmptyFilter();
}
$api = clone $this;
if ($uri) {
$api->setBaseUri($uri);
}
$collection = $this->getCollectionPrototype();
$collection
->setApiResource($api)
->setFilter($filter);
$collection->setClient($this->client);
return $collection;
}
public function setAuthHandler($handler): self
{
$this->authHandler = $handler;
return $this;
}
public function setBaseUrl(string $url): self
{
$this->baseUrl = $url;
return $this;
}
public function setBaseUri(string $uri): self
{
$this->baseUri = $uri;
return $this;
}
public function setCollectionName(string $name): self
{
$this->collectionName = $name;
return $this;
}
public function setCollectionPrototype(IterableAPICollection $prototype): self
{
$this->collectionPrototype = $prototype;
return $this;
}
public function setIsHAL(bool $state): self
{
$this->isHAL = $state;
return $this;
}
public function setLastResponse(ResponseInterface $response): self
{
$this->lastResponse = $response;
return $this;
}
public function setLastRequest(RequestInterface $request): self
{
$this->lastRequest = $request;
return $this;
}
/**
* Allows form URL-encoded POST requests.
*
* @throws ClientExceptionInterface
* @throws Exception\Exception
*/
public function submit(array $formData = [], string $uri = '', array $headers = []): string
{
if (empty($headers)) {
$headers = ['content-type' => 'application/x-www-form-urlencoded'];
}
$request = new Request(
$this->baseUrl . $this->baseUri . $uri,
'POST',
'php://temp',
$headers
);
if ($this->getAuthHandler()) {
$request = $this->addAuth($request);
}
$request->getBody()->write(http_build_query($formData));
$response = $this->getClient()->send($request);
$status = $response->getStatusCode();
$this->lastRequest = $request;
$this->setLastResponse($response);
if ($status < 200 || $status > 299) {
$e = $this->getException($response, $request);
$e->setEntity($formData);
throw $e;
}
return $response->getBody()->getContents();
}
/**
* @throws ClientExceptionInterface
* @throws Exception\Exception
*/
public function update(string $id, array $body, array $headers = []): ?array
{
if (empty($headers)) {
$headers = ['content-type' => 'application/json'];
}
$request = new Request(
$this->getBaseUrl() . $this->baseUri . '/' . $id,
'PUT',
'php://temp',
$headers
);
if ($this->getAuthHandler()) {
$request = $this->addAuth($request);
}
$request->getBody()->write(json_encode($body));
$response = $this->getClient()->send($request);
$this->lastRequest = $request;
$this->setLastResponse($response);
$status = $response->getStatusCode();
if (($status < 200 || $status > 299) || $this->errorsOn200()) {
$e = $this->getException($response, $request);
$e->setEntity(['id' => $id, 'body' => $body]);
throw $e;
}
return json_decode($response->getBody()->getContents(), true);
}
public function errorsOn200(): bool
{
return $this->errorsOn200;
}
public function setErrorsOn200(bool $value): self
{
$this->errorsOn200 = $value;
return $this;
}
}
|