src/Client/Tapfiliate/Service/ClientAbstract.php line 38

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Client\Tapfiliate\Service;
  7. use GuzzleHttp\Client;
  8. use GuzzleHttp\Exception\GuzzleException;
  9. use Psr\Http\Message\ResponseInterface;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\Serializer\SerializerInterface;
  13. abstract class ClientAbstract
  14. {
  15.     private const BASE_URI = 'https://api.tapfiliate.com';
  17.     private string $baseUri;
  19.     private string $token;
  21.     private Client $client;
  23.     private SerializerInterface $serializer;
  25.     private LoggerInterface $logger;
  27.     public function __construct(string $token, SerializerInterface $serializer, LoggerInterface $logger)
  28.     {
  29.         $this->baseUri = self::BASE_URI;
  30.         $this->token = $token;
  32.         $this->client = new Client(
  33.             [
  34.                 'headers' => [
  35.                     'X-Api-Key' => $this->token,
  36.                 ],
  37.                 'connect_timeout' => 10,
  38.                 'base_uri' => $this->baseUri,
  39.             ]
  40.         );
  41.         $this->serializer = $serializer;
  42.         $this->logger = $logger;
  43.     }
  45.     /**
  46.      * @throws GuzzleException|\Throwable
  47.      */
  48.     protected function get(string $endpoint, array $requestData = []): ResponseInterface
  49.     {
  50.         return $this->client->request('GET', $endpoint, $requestData);
  51.     }
  53.     /**
  54.      * @throws GuzzleException
  55.      */
  56.     protected function post(string $endpoint, array $bodyRequestData = []): ResponseInterface
  57.     {
  58.         $bodyRequestContents = $this->serializer->serialize($bodyRequestData, 'json');
  60.         return $this->client->request('POST', $endpoint, ['body' => $bodyRequestContents]);
  61.     }
  63.     /**
  64.      * @throws GuzzleException
  65.      */
  66.     protected function patch(string $endpoint, array $bodyRequestData = []): ResponseInterface
  67.     {
  68.         $bodyRequestContents = $this->serializer->serialize($bodyRequestData, 'json');
  70.         return $this->client->request('PATCH', $endpoint, ['body' => $bodyRequestContents]);
  71.     }
  73.     public function getSerializer(): SerializerInterface
  74.     {
  75.         return $this->serializer;
  76.     }
  78.     public function getLogger(): LoggerInterface
  79.     {
  80.         return $this->logger;
  81.     }
  82. }