ParsesPages   A
last analyzed

Complexity

Total Complexity 5

Size/Duplication

Total Lines 45
Duplicated Lines 0 %

Test Coverage

Coverage 100%

Importance

Changes 0
Metric Value
eloc 15
dl 0
loc 45
ccs 14
cts 14
cp 1
rs 10
c 0
b 0
f 0
wmc 5

2 Methods

Rating   Name   Duplication   Size   Complexity  
A yieldItemsAndGetKey() 0 22 4
A yieldItemsFrom() 0 4 1
1
<?php
2
3
declare(strict_types=1);
4
5
namespace Cerbero\LazyJsonPages\Concerns;
6
7
use Cerbero\JsonParser\JsonParser;
8
use Cerbero\LazyJsonPages\Data\Dot;
9
use Generator;
10
use Psr\Http\Message\ResponseInterface;
11
12
/**
13
 * The trait to parse pages.
14
 */
15
trait ParsesPages
16
{
17
    /**
18
     * The number of items per page.
19
     */
20
    protected int $itemsPerPage;
21
22
    /**
23
     * Yield paginated items and the given key from the provided response.
24
     *
25
     * @return Generator<int, mixed>
26
     */
27 39
    protected function yieldItemsAndGetKey(ResponseInterface $response, string $key): Generator
28
    {
29 39
        $itemsPerPage = 0;
30 39
        $pointers = [$this->config->itemsPointer];
31
32 39
        if (($value = $response->getHeaderLine($key)) === '') {
33 31
            $pointers[(new Dot($key))->toPointer()] = fn(mixed $value) => (object) compact('value');
34
        }
35
36 39
        foreach (JsonParser::parse($response)->pointers($pointers) as $item) {
37 39
            if (is_object($item)) {
38
                /** @var object{value: mixed} $item */
39 30
                $value = $item->value;
40
            } else {
41 39
                yield $item;
42 39
                ++$itemsPerPage;
43
            }
44
        }
45
46 39
        $this->itemsPerPage ??= $itemsPerPage;
47
48 39
        return $value;
49
    }
50
51
    /**
52
     * Yield paginated items from the given source.
53
     *
54
     * @return Generator<int, mixed>
55
     */
56 40
    protected function yieldItemsFrom(mixed $source): Generator
57
    {
58
        /** @phpstan-ignore-next-line */
59 40
        yield from JsonParser::parse($source)->pointer($this->config->itemsPointer);
60
    }
61
}
62