ArangoDb\Statement\VpackStreamHandler

Complexity

Total Complexity

17

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	toType()	0	12	5
A	appendStream()	0	4	1
A	__construct()	0	6	1
A	current()	0	4	1
A	result()	0	3	1
A	raw()	0	3	1
B	completeResult()	0	33	7

<?php
/**
 * Sandro Keil (https://sandro-keil.de)
 *
 * @link      http://github.com/sandrokeil/arangodb-php-client for the canonical source repository
 * @copyright Copyright (c) 2018-2019 Sandro Keil
 * @license   http://github.com/sandrokeil/arangodb-php-client/blob/master/LICENSE.md New BSD License
 */

declare(strict_types=1);

namespace ArangoDb\Statement;

use Psr\Http\Message\StreamInterface;
use Velocypack\Vpack;

The type Velocypack\Vpack was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * ArangoDB Velocypack stream handler
 *
 * @see https://github.com/martin-schilling/php-velocypack
 */
class VpackStreamHandler implements StreamHandler
{
    use ArrayAccessStreamHandlerTrait;

    public const RESULT_TYPE_ARRAY = 0;
    public const RESULT_TYPE_JSON = 1;
    public const RESULT_TYPE_BINARY = 2;
    public const RESULT_TYPE_OBJECT = 3;

    /**
     * @var Vpack[]
     */
    private $data = [];

    /**
     * @var int
     */
    private $resultType;


    public function __construct(StreamInterface $stream, int $resultType)
    {
        $this->data[$this->fetches] = Vpack::fromBinary($stream->getContents());
        $this->length = count($this->data[$this->fetches]['result']);
        $this->batchSize = $this->length;
        $this->resultType = $resultType;
    }

    public function current()
    {
        return $this->toType(
            $this->data[$this->fetches]['result'][$this->position - ($this->batchSize * $this->fetches)]
        );
    }

    public function result()
    {
        return $this->toType($this->data[$this->fetches]['result']);
    }

    public function raw(): array
    {
        return $this->toType($this->data[$this->fetches]);

The expression return $this->toType($this->data[$this->fetches]) could return the type object which is incompatible with the type-hinted return array. Consider adding an additional type-check to rule them out.

    }

    public function completeResult()
    {
        $data = $this->resultType === self::RESULT_TYPE_ARRAY ? [[]] : [];

        $i = 0;

        foreach ($this->data as $vpack) {
            switch ($this->resultType) {
                case self::RESULT_TYPE_ARRAY:
                    $data[] = $vpack['result']->toArray();
                    break;
                case self::RESULT_TYPE_JSON:
                default:
//                    $data .= $i === 0 ? '' : ',';
//                    $data .= $vpack['result']->toJson();
                    $value = $vpack['result']->toJson();
                    $value = rtrim($value, ']');
                    $value = ltrim($value, '[');
                    $data[] = $value;
                    break;
            }
            $i++;
        }
        if ($this->resultType === self::RESULT_TYPE_JSON) {
            $data = implode(',', $data);

            if ($i > 0) {
                return '[' . $data . ']';
            }
            return $data;
        }

        return  array_merge(...$data);

        // TODO needs append method
//        $vpack = new Vpack();
//        foreach ($this->data as $result) {
//            $vpack->append($result['result']);
//        }
//        return $this->toType($vpack);
    }

    public function appendStream(StreamInterface $stream): void
    {
        $this->data[++$this->fetches] = Vpack::fromBinary($stream->getContents());
        $this->length += count($this->data[$this->fetches]['result']);
    }

    private function toType(Vpack $vpack)
    {
        switch ($this->resultType) {
            case self::RESULT_TYPE_OBJECT:
                return (object)$vpack->toArray();
            case self::RESULT_TYPE_ARRAY:
                return $vpack->toArray();
            case self::RESULT_TYPE_BINARY:
                return $vpack->toBinary();
            case self::RESULT_TYPE_JSON:
            default:
                return $vpack->toJson();
        }
    }
}