src/Service/ListingRotationApi.php line 36

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use GuzzleHttp\ClientInterface;
  6. use Porpaginas\Arrays\ArrayPage;
  7. use Porpaginas\Page;
  9. class ListingRotationApi
  10. {
  11.     private ClientInterface $httpClient;
  12.     private int $onPageLimit;
  13.     private ProfileTopBoard $profileTopBoard;
  15.     public function __construct(ClientInterface $apiRotationClient, $onPageLimit, ProfileTopBoard $profileTopBoard)
  16.     {
  17.         $this->httpClient = $apiRotationClient;
  18.         $this->onPageLimit = (int)$onPageLimit;
  19.         $this->profileTopBoard = $profileTopBoard;
  20.     }
  22.     /**
  23.      * @param string $endpoint Listing API endpoint
  24.      * @param array $params Набор динамических параметров для замены в URL
  25.      * @param int $pageNumber Номер текущей страницы
  26.      * @return Page
  27.      *
  28.      * @throws \GuzzleHttp\Exception\GuzzleException
  29.      */
  30.     public function paginate(string $endpoint, array $params, int $pageNumber = 1): Page
  31.     {
  32.         if ($pageNumber < 1) {
  33.             $pageNumber = 1;
  34.         }
  36.         $topPlacement = $this->profileTopBoard->currentTopPlacement(false);
  38.         $limit = $apiLimit =  $this->onPageLimit;
  39.         $offset = $apiOffset = ($pageNumber - 1) * $limit;
  41.         if (null !== $topPlacement) {
  42.             if ($pageNumber === 1) {
  43.                 $apiLimit = $this->onPageLimit - 1;
  44.             } else {
  45.                 $apiOffset = ($pageNumber - 1) * $limit - 1;
  46.             }
  47.         }
  49.         $response = $this->httpClient->request('GET', $this->buildUrl($endpoint, $params), [
  50.             'query' => [
  51.                 'limit' => $apiLimit,
  52.                 'offset' => $apiOffset,
  53.             ],
  54.         ]);
  55.         $data = json_decode($response->getBody()->getContents(), true);
  57.         $items = $data['items'];
  58.         if (null !== $topPlacement && $pageNumber === 1) {
  59.             array_unshift($items, $topPlacement);
  60.         }
  62.         return new ArrayPage($items, $offset, $limit, $data['totalCount']);
  63.     }
  65.     private function buildUrl(string $endpoint, array $params): string
  66.     {
  67.         $url = '/listings';
  68.         if (!str_starts_with($endpoint, '/')) {
  69.             $url .= '/';
  70.         }
  71.         $url .= $endpoint;
  73.         $finalUrl = preg_replace_callback('#\{\s*([a-z0-9_]+)\s*}#', static function ($matches) use ($params) {
  74.             return $params[$matches[1]] ?? $matches[0];
  75.         }, $url);
  77.         return $finalUrl;
  78.     }
  79. }