diff --git a/composer.json b/composer.json index 231ff30..6d6b591 100644 --- a/composer.json +++ b/composer.json @@ -26,7 +26,7 @@ "psr/log": "^1.0", "sanmai/json-serializer": "^0.2.2", "sanmai/pipeline": "^5", - "sanmai/sdk-common": "^0.3.1", + "sanmai/sdk-common": "^0.4", "sanmai/version-info": "^0.2.0", "symfony/http-foundation": "^4.4.7 || ^5.0.7" }, diff --git a/src/Requests/Shortcuts.php b/src/Requests/Shortcuts.php index 8ecffd7..70cceb6 100644 --- a/src/Requests/Shortcuts.php +++ b/src/Requests/Shortcuts.php @@ -29,10 +29,8 @@ namespace YDeliverySDK\Requests; use CommonSDK\Contracts; -use IteratorAggregate; -use function Pipeline\map; -use YDeliverySDK\Client; use YDeliverySDK\Responses; +use YDeliverySDK\Responses\OrdersSearchResponseIterator; /** * @method Responses\DeliveryServicesResponse|Responses\Types\DeliveryService[] sendDeliveryServicesRequest(DeliveryServicesRequest $request) @@ -85,53 +83,6 @@ public function makeDeleteOrderRequest(int $orderId) */ public function searchOrders(OrdersSearchRequest $request) { - return new class($this, $request) implements Contracts\Response, IteratorAggregate { - private $client; - private $request; - - /** @var Contracts\Response|null */ - private $response; - - public function __construct(Client $client, OrdersSearchRequest $request) - { - $this->client = $client; - $this->request = $request; - } - - private function makeRequest(): void - { - $this->response = $this->client->sendOrdersSearchRequest($this->request); - $this->request->addPage(); - } - - private function getLastResponse(): Contracts\Response - { - if ($this->response === null) { - $this->makeRequest(); - } - - return $this->response; - } - - public function hasErrors(): bool - { - return $this->getLastResponse()->hasErrors(); - } - - public function getMessages() - { - return $this->getLastResponse()->getMessages(); - } - - public function getIterator() - { - return map(function () { - do { - yield from $this->getLastResponse(); - $this->makeRequest(); - } while (\count($this->getLastResponse()) > 0); - }); - } - }; + return new OrdersSearchResponseIterator($this, $request); } } diff --git a/src/Responses/OrdersSearchResponse.php b/src/Responses/OrdersSearchResponse.php index b97d5d1..490eb6d 100644 --- a/src/Responses/OrdersSearchResponse.php +++ b/src/Responses/OrdersSearchResponse.php @@ -43,6 +43,7 @@ * @property-read int $totalPages Количество страниц в ответе. * @property-read int $size Количество объектов на странице. * @property-read int $pageNumber Номер текущей страницы (начиная с 0). + * @property-read int $lastPageNumber Номер последней страницы. */ final class OrdersSearchResponse implements Response, Countable, IteratorAggregate { @@ -93,4 +94,9 @@ public function getIterator() { return new ArrayIterator($this->data); } + + protected function getLastPageNumber(): int + { + return $this->totalPages - 1; + } } diff --git a/src/Responses/OrdersSearchResponseIterator.php b/src/Responses/OrdersSearchResponseIterator.php new file mode 100644 index 0000000..b6a02d6 --- /dev/null +++ b/src/Responses/OrdersSearchResponseIterator.php @@ -0,0 +1,107 @@ + and contributors + * Copyright (c) 2018 Appwilio (http://appwilio.com), greabock (https://github.com/greabock), JhaoDa (https://github.com/jhaoda) + * + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN + * THE SOFTWARE. + */ + +declare(strict_types=1); + +namespace YDeliverySDK\Responses; + +use CommonSDK\Contracts\Response; +use Countable; +use IteratorAggregate; +use function Pipeline\map; +use YDeliverySDK\Client; +use YDeliverySDK\Requests\OrdersSearchRequest; + +/** + * @property-read int $totalElements Количество объектов в ответе. + * @property-read int $totalPages Количество страниц в ответе. + * @property-read int $size Количество объектов на странице. + * @property-read int $pageNumber Номер текущей страницы (начиная с 0). + */ +final class OrdersSearchResponseIterator implements Response, Countable, IteratorAggregate +{ + private $client; + private $request; + + /** @var Response|null */ + private $response; + + public function __construct(Client $client, OrdersSearchRequest $request) + { + $this->client = $client; + $this->request = $request; + } + + private function makeRequest(): void + { + $this->response = $this->client->sendOrdersSearchRequest($this->request); + $this->request->addPage(); + } + + /** + * @return OrdersSearchResponse + */ + private function getLastResponse() + { + if ($this->response === null) { + $this->makeRequest(); + } + + return $this->response; + } + + public function getIterator() + { + return map(function () { + do { + yield from $this->getLastResponse(); + $this->makeRequest(); + } while ($this->getLastResponse()->pageNumber < $this->getLastResponse()->lastPageNumber); + + yield from $this->getLastResponse(); + }); + } + + public function hasErrors(): bool + { + return $this->getLastResponse()->hasErrors(); + } + + public function getMessages() + { + return $this->getLastResponse()->getMessages(); + } + + public function count() + { + return $this->getLastResponse()->totalElements; + } + + public function __get(string $property) + { + return $this->getLastResponse()->{$property}; + } +}