husail / http-iterator
Http Iterator
Requires
- php: ^8.1
Requires (Dev)
- friendsofphp/php-cs-fixer: ^3.64
- pestphp/pest: ^2.0
- phpstan/phpstan: ^2.1
README
The HttpIterator
package provides a PHP iterator that simplifies the processing of large volumes of paginated data from HTTP requests. It's particularly useful for APIs with page-based results, supporting retries in case of transient failures.
📦 Installation
composer require husail/http-iterator
🔧 Usage Example
Basic Usage
use Husail\HttpIterator\HttpIterator; use Illuminate\Support\Facades\Http; $perPage = 10; $startPage = 1; HttpIterator::run($perPage, $startPage, function ($iterator) { $response = Http::get('https://example.com/api/transactions', [ 'page' => $iterator->currentPage(), 'per_page' => $iterator->perPage(), ]); if (!$iterator->hasInitialized()) { $iterator->setTotalResult($response->json('total_elements')); } TransactionRepository::sync($response->json('data')) //... $iterator->nextPage(); });
Handling Retries
You can use the retry()
method to explicitly repeat the current iteration without advancing to the next page. This is useful for handling transient errors such as API throttling (HTTP 429) or temporary network issues.
Retries are limited by the maxRetries
parameter (default: 3
).
After reaching this limit, the iterator will automatically stop, unless the retry counter is reset by a successful interaction (e.g., calling nextPage()
, toPage()
, or lastPage()
), or by a manual call to resetRetries()
.
use Husail\HttpIterator\HttpIterator; use Illuminate\Support\Facades\Http; const THROTTLE_DELAY_SECONDS = 60; $perPage = 10; $startPage = 1; HttpIterator::run($perPage, $startPage, function ($iterator) { $response = Http::get('https://example.com/api/transactions', [ 'page' => $iterator->currentPage(), 'per_page' => $iterator->perPage(), ]); if ($response->status() === 429) { sleep(THROTTLE_DELAY_SECONDS); $iterator->retry(); } if (!$iterator->hasInitialized()) { $iterator->setTotalResult($response->json('total_elements')); } TransactionRepository::sync($response->json('data')) //... $iterator->nextPage(); });
🧰 API Reference
HttpIterator::run(int $perPage, int $currentPage, callable $callableRun, ?callable $callableException = null, int $maxRetries = 3)
: Execute the iterator with the provided callables.nextPage()
: Move to the next page and reset retry count.lastPage()
: Jump to the last page.toPage(int $page)
: Jump to a specific page.setPerPage(int $length)
: Set the page size.setTotalResult(int $length)
: Set the total number of results.currentPage()
: Get the current page number.perPage()
: Get the per-page count.totalResult()
: Get the total number of results.totalPages()
: Get the total number of pages.finish()
: Mark the iteration as finished.hasInitialized()
: Returns whether total result count has been set.hasFinished()
: Returns whether the iteration was manually finished.hasNextPage()
: Returns whether more pages are available.retry()
: Retry the current iteration (increments retry count and throws).
🤝 Contributing
We welcome contributions! Feel free to submit issues or pull requests to help improve the package.
📜 License
This package is open-source software licensed under the MIT License. See the LICENSE file for details.