Tarantool\Client\Packer\PeclPacker

Complexity

Total Complexity

9

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Test Coverage

Coverage

63.64%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	pack()	0	8	2
A	__construct()	0	4	1
A	unpack()	0	26	6

<?php

declare(strict_types=1);

/*
 * This file is part of the Tarantool Client package.
 *
 * (c) Eugene Leonovich <gen.work@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Tarantool\Client\Packer;

use Tarantool\Client\Exception\UnpackingFailed;
use Tarantool\Client\IProto;
use Tarantool\Client\Request\Request;
use Tarantool\Client\Response;

final class PeclPacker implements Packer
{
    private $packer;
    private $unpacker;

    public function __construct(bool $phpOnly = true)
    {
        $this->packer = new \MessagePack($phpOnly);
        $this->unpacker = new \MessagePackUnpacker($phpOnly);

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

    }

    public function pack(Request $request, ?int $sync = null) : string
    {
        // @see https://github.com/msgpack/msgpack-php/issues/45
        $content = \pack('C*', 0x82, IProto::CODE, $request->getType(), IProto::SYNC).
            $this->packer->pack($sync ?: 0).
            $this->packer->pack($request->getBody());

        return PackUtils::packLength(\strlen($content)).$content;
    }

    public function unpack(string $data) : Response
    {
        $this->unpacker->feed($data);

        if (!$this->unpacker->execute()) {
            throw UnpackingFailed::invalidResponse();
        }

        $header = $this->unpacker->data();
        if (!\is_array($header)) {
            throw UnpackingFailed::invalidResponse();
        }

        if (!$this->unpacker->execute()) {
            throw UnpackingFailed::invalidResponse();
        }

        $body = $this->unpacker->data();
        if (\is_array($body)) {
            return new Response($header, $body);
        }
        if ($body instanceof \stdClass) {
            return new Response($header, (array) $body);
        }

        throw UnpackingFailed::invalidResponse();
    }
}