Passed
Pull Request — master (#7)
by Sandro
02:03
created

ArrayStreamHandler::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 5
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 4
CRAP Score 1

Importance

Changes 1
Bugs 0 Features 0
Metric Value
eloc 3
c 1
b 0
f 0
dl 0
loc 5
ccs 4
cts 4
cp 1
rs 10
cc 1
nc 1
nop 1
crap 1
1
<?php
2
/**
3
 * Sandro Keil (https://sandro-keil.de)
4
 *
5
 * @link      http://github.com/sandrokeil/arangodb-php-client for the canonical source repository
6
 * @copyright Copyright (c) 2018-2019 Sandro Keil
7
 * @license   http://github.com/sandrokeil/arangodb-php-client/blob/master/LICENSE.md New BSD License
8
 */
9
10
declare(strict_types=1);
11
12
namespace ArangoDb\Statement;
13
14
use ArangoDb\Util\Json;
15
use Psr\Http\Message\StreamInterface;
16
17
class ArrayStreamHandler implements StreamHandler
18
{
19
    use ArrayAccessStreamHandlerTrait;
20
21
    /**
22
     * @var mixed
23
     */
24
    private $data = [];
25
26 7
    public function __construct(StreamInterface $stream)
27
    {
28 7
        $this->data[$this->fetches] = Json::decode($stream->getContents());
29 7
        $this->length = count($this->data[$this->fetches]['result']);
30 7
        $this->batchSize = $this->length;
31 7
    }
32
33
    /**
34
     * Return the current result row
35
     *
36
     * @return array
37
     */
38 3
    public function current(): array
39
    {
40 3
        return $this->data[$this->fetches]['result'][$this->position - ($this->batchSize * $this->fetches)];
41
    }
42
43 2
    public function result(): array
44
    {
45 2
        return $this->data[$this->fetches]['result'];
46
    }
47
48
    public function raw(): array
49
    {
50
        return $this->data[$this->fetches];
51
    }
52
53 4
    public function completeResult()
54
    {
55 4
        $completeResult = [[]];
56
57 4
        foreach ($this->data as $result) {
58 4
            $completeResult[] = $result['result'];
59
        }
60 4
        return array_merge(...$completeResult);
61
    }
62
63 4
    public function appendStream(StreamInterface $stream): void
64
    {
65 4
        $this->data[++$this->fetches] = Json::decode($stream->getContents());
66 4
        $this->length += count($this->data[$this->fetches]['result']);
67 4
    }
68
}
69