silva
/
adrema
2
1
Fork 0
Code Issues 23 Pull Requests 1 Projects 1 Releases 106 Wiki Activity

Fetch mailman members
continuous-integration/drone/push Build is passing Details

This commit is contained in:
philipp lang 2022-10-18 17:55:53 +02:00
parent c4c59d1d28
commit f7e4f961a9
2 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
app/Mailman/Support/MailmanService.php
View File

@ -6,6 +6,7 @@ use App\Mailman\Exceptions\MailmanServiceException;
use Illuminate\Http\Client\PendingRequest; use Illuminate\Http\Client\PendingRequest;
use Illuminate\Support\Facades\Http; use Illuminate\Support\Facades\Http;
use Illuminate\Support\LazyCollection; use Illuminate\Support\LazyCollection;
use Zoomyboy\LaravelNami\Support\Paginator;
class MailmanService class MailmanService
{ {
@ -34,24 +35,20 @@ class MailmanService
*/ */
public function members(string $listId): LazyCollection public function members(string $listId): LazyCollection
{ {
$page = 1; return app(Paginator::class)->result(
fn ($page) => $this->http()->get("/lists/{$listId}/roster/member?page={$page}&count=10"),
return LazyCollection::make(function () use ($listId, $page) { function ($response) use ($listId) {
while (!isset($totalEntries) || ($page - 1) * 10 + 1 <= $totalEntries) {
$response = $this->http()->get('/lists/'.$listId.'/roster/member?page='.$page.'&count=10');
throw_unless($response->ok(), MailmanServiceException::class, 'Fetching members for listId '.$listId.' failed.'); throw_unless($response->ok(), MailmanServiceException::class, 'Fetching members for listId '.$listId.' failed.');
/** @var array<int, array{email: string}>|null */ /** @var array<int, array{email: string}>|null */
$entries = data_get($response->json(), 'entries'); $entries = data_get($response->json(), 'entries');
throw_if(is_null($entries), MailmanServiceException::class, 'Failed getting member list from response'); throw_if(is_null($entries), MailmanServiceException::class, 'Failed getting member list from response');
$totalEntries = data_get($response->json(), 'total_size');
foreach ($entries as $entry) { foreach ($entries as $entry) {
yield $entry['email']; yield $entry['email'];
} }
},
++$page; fn ($response) => data_get($response->json(), 'total_size')
} );
});
} }
private function http(): PendingRequest private function http(): PendingRequest

2
packages/laravel-nami

@ -1 +1 @@
Subproject commit 5ce86d632d3e228e08db314895aa9071e668f436 Subproject commit ba7786f1111a2ef08010f2ffbefb4041d676b53b