* @copyright 2015 - 2017 Timothy J. Warren * @license http://www.opensource.org/licenses/mit-license.html MIT License * @version 4.0 * @link https://github.com/timw4mail/HummingBirdAnimeClient */ namespace Aviat\AnimeClient\API\MAL; use Amp\Artax\{Client, FormBody, Request}; use Aviat\AnimeClient\API\{ MAL as M, APIRequestBuilder, XML }; use Aviat\AnimeClient\API\MALRequestBuilder; use Aviat\Ion\Json; use InvalidArgumentException; trait MALTrait { /** * The request builder for the MAL API * @var MALRequestBuilder */ protected $requestBuilder; /** * The base url for api requests * @var string $base_url */ protected $baseUrl = M::BASE_URL; /** * HTTP headers to send with every request * * @var array */ protected $defaultHeaders = [ 'Accept' => 'text/xml', 'Accept-Encoding' => 'gzip', 'Content-type' => 'application/x-www-form-urlencoded', 'User-Agent' => "Tim's Anime Client/4.0" ]; /** * Set the request builder object * * @param MALRequestBuilder $requestBuilder * @return self */ public function setRequestBuilder($requestBuilder): self { $this->requestBuilder = $requestBuilder; return $this; } /** * Unencode the dual-encoded ampersands in the body * * This is a dirty hack until I can fully track down where * the dual-encoding happens * * @param FormBody $formBody The form builder object to fix * @return string */ private function fixBody(FormBody $formBody): string { $rawBody = \Amp\wait($formBody->getBody()); return html_entity_decode($rawBody, \ENT_HTML5, 'UTF-8'); } /** * Create a request object * * @param string $type * @param string $url * @param array $options * @return \Amp\Artax\Response */ public function setUpRequest(string $type, string $url, array $options = []) { $config = $this->container->get('config'); $request = $this->requestBuilder ->newRequest($type, $url) ->setBasicAuth($config->get(['mal','username']), $config->get(['mal','password'])); if (array_key_exists('query', $options)) { $request->setQuery($options['query']); } if (array_key_exists('body', $options)) { $request->setBody($options['body']); } return $request->getFullRequest(); } /** * Make a request * * @param string $type * @param string $url * @param array $options * @return \Amp\Artax\Response */ private function getResponse(string $type, string $url, array $options = []) { $logger = null; if ($this->getContainer()) { $logger = $this->container->getLogger('mal-request'); } $request = $this->setUpRequest($type, $url, $options); $response = \Amp\wait((new Client)->request($request)); $logger->debug('MAL api response', [ 'status' => $response->getStatus(), 'reason' => $response->getReason(), 'body' => $response->getBody(), 'headers' => $response->getAllHeaders(), 'requestHeaders' => $request->getAllHeaders(), ]); return $response; } /** * Make a request * * @param string $type * @param string $url * @param array $options * @return array */ private function request(string $type, string $url, array $options = []): array { $logger = null; if ($this->getContainer()) { $logger = $this->container->getLogger('mal-request'); } $response = $this->getResponse($type, $url, $options); if ((int) $response->getStatus() > 299 || (int) $response->getStatus() < 200) { if ($logger) { $logger->warning('Non 200 response for api call', $response->getBody()); } } return XML::toArray((string) $response->getBody()); } /** * Remove some boilerplate for get requests * * @param array $args * @return array */ protected function getRequest(...$args): array { return $this->request('GET', ...$args); } /** * Remove some boilerplate for post requests * * @param array $args * @return array */ protected function postRequest(...$args): array { $logger = null; if ($this->getContainer()) { $logger = $this->container->getLogger('mal-request'); } $response = $this->getResponse('POST', ...$args); $validResponseCodes = [200, 201]; if ( ! in_array((int) $response->getStatus(), $validResponseCodes)) { if ($logger) { $logger->warning('Non 201 response for POST api call', $response->getBody()); } } return XML::toArray($response->getBody()); } }