Tarantool\Client\Packer\PeclPacker

Complexity

Total Complexity

8

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	pack()	0	12	2
B	unpack()	0	26	5

<?php

namespace Tarantool\Client\Packer;

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

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

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

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

        if (null !== $body = $request->getBody()) {
            $content .= $this->packer->pack($body);
        }

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

    /**
     * {@inheritdoc}
     */
    public function unpack($data)
    {
        $this->unpacker->feed($data);

        if (!$this->unpacker->execute()) {
            throw new Exception('Unable to unpack data.');
        }

        $header = $this->unpacker->data();

        if (!$this->unpacker->execute()) {
            throw new Exception('Unable to unpack data.');
        }

        $body = (array) $this->unpacker->data();
        $code = $header[IProto::CODE];

        if ($code >= Request::TYPE_ERROR) {
            throw new Exception($body[IProto::ERROR], $code & (Request::TYPE_ERROR - 1));
        }

        return new Response(
            $header[IProto::SYNC],
            isset($body[IProto::DATA]) ? $body[IProto::DATA] : null
        );
    }
}