Tarantool\Client\Packer\PurePacker

Complexity

Total Complexity

7

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	pack()	0	13	2
A	unpack()	0	18	4

<?php

namespace Tarantool\Client\Packer;

use MessagePack\BufferUnpacker;
use MessagePack\Packer as MessagePackPacker;
use Tarantool\Client\Exception\Exception;
use Tarantool\Client\IProto;
use Tarantool\Client\Request\Request;
use Tarantool\Client\Response;

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

    public function __construct()
    {
        $this->packer = new MessagePackPacker();
        $this->unpacker = new BufferUnpacker();
    }

    public function pack(Request $request, $sync = null)
    {
        $content = $this->packer->packMap([
            IProto::CODE => $request->getType(),
            IProto::SYNC => (int) $sync,
        ]);

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

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

    public function unpack($data)
    {
        $message = $this->unpacker->reset($data)->tryUnpack();

        if (2 !== count($message)) {
            throw new Exception('Unable to unpack data.');
        }

        list($header, $body) = $message;

        $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], $body ? $body[IProto::DATA] : null);
    }
}