Tarantool\Client\Packer\PeclLitePacker

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	pack()	0	12	2
B	unpack()	0	24	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 PeclLitePacker implements Packer
{
    /**
     * {@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 .= msgpack_pack((int) $sync);

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

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

    /**
     * {@inheritdoc}
     */
    public function unpack($data)
    {
        $headerSize = PackUtils::getHeaderSize($data);

        if (!$header = substr($data, 0, $headerSize)) {
            throw new Exception('Unable to unpack data.');
        }

        $header = msgpack_unpack($header);
        if (!is_array($header)) {
            throw new Exception('Unable to unpack data.');
        }

        $code = $header[IProto::CODE];

        $body = substr($data, $headerSize);
        $body = msgpack_unpack($body);

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

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