husail/http-iterator 问题修复 & 功能扩展

解决BUG、新增功能、兼容多环境部署,快速响应你的开发需求

邮箱:yvsm@zunyunkeji.com | QQ:316430983 | 微信:yvsm316

husail/http-iterator

最新稳定版本:v1.1.0

Composer 安装命令:

composer require husail/http-iterator

包简介

Http Iterator

README 文档

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.

统计信息

  • 总下载量: 1.65k
  • 月度下载量: 0
  • 日度下载量: 0
  • 收藏数: 0
  • 点击次数: 1
  • 依赖项目数: 0
  • 推荐数: 0

GitHub 信息

  • Stars: 0
  • Watchers: 1
  • Forks: 0
  • 开发语言: PHP

其他信息

  • 授权协议: MIT
  • 更新时间: 2024-05-16