MessagePack\BufferUnpacker

Complexity

Total Complexity

81

Size/Duplication

Total Lines	412
Duplicated Lines	9.71 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes	18
Bugs	1	Features	4

25 Methods

Rating	Name	Duplication	Size	Complexity
A	setTransformers()	0	4	1
A	getIntOverflowMode()	0	4	1
A	__construct()	0	6	2
A	append()	0	6	1
A	getTransformers()	0	4	1
A	setIntOverflowMode()	0	12	2
A	reset()	0	7	1
B	tryUnpack()	0	21	5
A	unpackStr()	0	13	2
A	unpackArray()	9	9	2
A	unpackMap()	9	9	2
A	unpackExt()	0	15	3
A	ensureLength()	0	6	2
A	handleIntOverflow()	0	11	3
D	unpack()	0	80	40
A	unpackUint8()	0	9	1
A	unpackUint16()	0	10	1
A	unpackUint32()	11	11	1
A	unpackUint64()	0	18	2
A	unpackInt8()	0	13	2
A	unpackInt16()	0	14	2
A	unpackInt32()	0	11	1
A	unpackInt64()	11	11	1
A	unpackFloat32()	0	11	1
A	unpackFloat64()	0	11	1

<?php

/*
 * This file is part of the rybakit/msgpack.php 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 MessagePack;

use MessagePack\Exception\InsufficientDataException;
use MessagePack\Exception\IntegerOverflowException;
use MessagePack\Exception\UnpackingFailedException;
use MessagePack\TypeTransformer\Collection;

class BufferUnpacker
{
    const INT_AS_EXCEPTION = 0;
    const INT_AS_STR = 1;
    const INT_AS_GMP = 2;

    /**
     * @var int
     */
    private $intOverflowMode = self::INT_AS_EXCEPTION;

    /**
     * @var string
     */
    private $buffer = '';

    /**
     * @var int
     */
    private $offset = 0;

    /**
     * @var Collection
     */
    private $transformers;

    /**
     * @param int|null $intOverflowMode
     */
    public function __construct($intOverflowMode = null)
    {
        if (null !== $intOverflowMode) {
            $this->intOverflowMode = $intOverflowMode;
        }
    }

    /**
     * @param Collection|null $transformers
     */
    public function setTransformers(Collection $transformers = null)
    {
        $this->transformers = $transformers;
    }

    /**
     * @return Collection|null
     */
    public function getTransformers()
    {
        return $this->transformers;
    }

    /**
     * @param int $intOverflowMode
     *
     * @throws \InvalidArgumentException
     */
    public function setIntOverflowMode($intOverflowMode)
    {
        if (!\in_array($intOverflowMode, [
            self::INT_AS_EXCEPTION,
            self::INT_AS_STR,
            self::INT_AS_GMP,
        ], true)) {
            throw new \InvalidArgumentException(\sprintf('Invalid integer overflow mode: %s.', $intOverflowMode));
        }

        $this->intOverflowMode = $intOverflowMode;
    }

    /**
     * @return int
     */
    public function getIntOverflowMode()
    {
        return $this->intOverflowMode;
    }

    /**
     * @param string $data
     *
     * @return $this
     */
    public function append($data)
    {
        $this->buffer .= $data;

        return $this;
    }

    /**
     * @param string $buffer
     *
     * @return $this
     */
    public function reset($buffer = '')
    {
        $this->buffer = $buffer;
        $this->offset = 0;

        return $this;
    }

    /**
     * @return array
     */
    public function tryUnpack()
    {
        $data = [];
        $offset = $this->offset;

        try {
            do {
                $data[] = $this->unpack();
                $offset = $this->offset;
            } while (isset($this->buffer[$this->offset]));
        } catch (InsufficientDataException $e) {
            $this->offset = $offset;
        }

        if ($this->offset) {
            $this->buffer = isset($this->buffer[$this->offset]) ? \substr($this->buffer, $this->offset) : '';
            $this->offset = 0;
        }

        return $data;
    }

    /**
     * @return mixed
     *
     * @throws UnpackingFailedException
     */
    public function unpack()
    {
        $this->ensureLength(1);

        $c = \ord($this->buffer[$this->offset]);
        ++$this->offset;

        // fixint
        if ($c <= 0x7f) {
            return $c;
        }
        // fixstr
        if ($c >= 0xa0 && $c <= 0xbf) {
            return $this->unpackStr($c & 0x1f);
        }
        // fixarray
        if ($c >= 0x90 && $c <= 0x9f) {
            return $this->unpackArray($c & 0xf);
        }
        // fixmap
        if ($c >= 0x80 && $c <= 0x8f) {
            return $this->unpackMap($c & 0xf);
        }
        // negfixint
        if ($c >= 0xe0) {
            return $c - 256;
        }

        switch ($c) {
            case 0xc0: return null;

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc2: return false;

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc3: return true;

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_BIN
            case 0xc4: return $this->unpackStr($this->unpackUint8());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc5: return $this->unpackStr($this->unpackUint16());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc6: return $this->unpackStr($this->unpackUint32());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_FLOAT
            case 0xca: return $this->unpackFloat32();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xcb: return $this->unpackFloat64();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_UINT
            case 0xcc: return $this->unpackUint8();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xcd: return $this->unpackUint16();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xce: return $this->unpackUint32();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xcf: return $this->unpackUint64();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_INT
            case 0xd0: return $this->unpackInt8();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd1: return $this->unpackInt16();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd2: return $this->unpackInt32();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd3: return $this->unpackInt64();

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_STR
            case 0xd9: return $this->unpackStr($this->unpackUint8());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xda: return $this->unpackStr($this->unpackUint16());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xdb: return $this->unpackStr($this->unpackUint32());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_ARRAY
            case 0xdc: return $this->unpackArray($this->unpackUint16());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xdd: return $this->unpackArray($this->unpackUint32());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_MAP
            case 0xde: return $this->unpackMap($this->unpackUint16());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xdf: return $this->unpackMap($this->unpackUint32());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            // MP_EXT
            case 0xd4: return $this->unpackExt(1);

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd5: return $this->unpackExt(2);

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd6: return $this->unpackExt(4);

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd7: return $this->unpackExt(8);

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xd8: return $this->unpackExt(16);

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc7: return $this->unpackExt($this->unpackUint8());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc8: return $this->unpackExt($this->unpackUint16());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

            case 0xc9: return $this->unpackExt($this->unpackUint32());

The case body in a switch statement must start on the line following the statement.

Terminating statement must be on a line by itself

        }

        throw new UnpackingFailedException(\sprintf('Unknown code: 0x%x.', $c));
    }

    private function unpackUint8()
    {
        $this->ensureLength(1);

        $num = $this->buffer[$this->offset];
        ++$this->offset;

        return \ord($num);
    }

    private function unpackUint16()
    {
        $this->ensureLength(2);

        $hi = \ord($this->buffer[$this->offset]);
        $lo = \ord($this->buffer[$this->offset + 1]);
        $this->offset += 2;

        return $hi << 8 | $lo;
    }

    private function unpackUint32()

This method seems to be duplicated in your project.

    {
        $this->ensureLength(4);

        $num = \substr($this->buffer, $this->offset, 4);
        $this->offset += 4;

        $num = \unpack('N', $num);

        return $num[1];
    }

    private function unpackUint64()
    {
        $this->ensureLength(8);

        $num = \substr($this->buffer, $this->offset, 8);
        $this->offset += 8;

        //$num = \unpack('J', $num);

59% of this comment could be valid code. Did you maybe forget this after debugging?

        $set = \unpack('N2', $num);
        $value = $set[1] << 32 | $set[2];

        // PHP does not support unsigned integers.
        // If a number is bigger than 2^63, it will be interpreted as a float.
        // @link http://php.net/manual/en/language.types.integer.php#language.types.integer.overflow

        return ($value < 0) ? $this->handleIntOverflow($value) : $value;
    }

    private function unpackInt8()
    {
        $this->ensureLength(1);

        $num = \ord($this->buffer[$this->offset]);
        ++$this->offset;

        if ($num > 0x7f) {
            return $num - 256;
        }

        return $num;
    }

    private function unpackInt16()
    {
        $this->ensureLength(2);

        $hi = \ord($this->buffer[$this->offset]);
        $lo = \ord($this->buffer[$this->offset + 1]);
        $this->offset += 2;

        if ($hi > 0x7f) {
            return -(0x010000 - ($hi << 8 | $lo));
        }

        return $hi << 8 | $lo;
    }

    private function unpackInt32()
    {
        $this->ensureLength(4);

        $num = \substr($this->buffer, $this->offset, 4);
        $this->offset += 4;

        $num = \unpack('i', \strrev($num));

        return $num[1];
    }

    private function unpackInt64()

This method seems to be duplicated in your project.

    {
        $this->ensureLength(8);

        $num = \substr($this->buffer, $this->offset, 8);
        $this->offset += 8;

        $set = \unpack('N2', $num);

        return $set[1] << 32 | $set[2];
    }

    private function unpackFloat32()
    {
        $this->ensureLength(4);

        $num = \substr($this->buffer, $this->offset, 4);
        $this->offset += 4;

        $num = \unpack('f', \strrev($num));

        return $num[1];
    }

    private function unpackFloat64()
    {
        $this->ensureLength(8);

        $num = \substr($this->buffer, $this->offset, 8);
        $this->offset += 8;

        $num = \unpack('d', \strrev($num));

        return $num[1];
    }

    private function unpackStr($length)
    {
        if (!$length) {
            return '';
        }

        $this->ensureLength($length);

        $str = \substr($this->buffer, $this->offset, $length);
        $this->offset += $length;

        return $str;
    }

    private function unpackArray($size)

This method seems to be duplicated in your project.

    {
        $array = [];
        for ($i = $size; $i; --$i) {
            $array[] = $this->unpack();
        }

        return $array;
    }

    private function unpackMap($size)

This method seems to be duplicated in your project.

    {
        $map = [];
        for ($i = $size; $i; --$i) {
            $map[$this->unpack()] = $this->unpack();
        }

        return $map;
    }

    private function unpackExt($length)
    {
        $this->ensureLength($length);

        $type = $this->unpackInt8();

        if ($this->transformers && $transformer = $this->transformers->find($type)) {
            return $transformer->reverseTransform($this->unpack());
        }

        $data = \substr($this->buffer, $this->offset, $length);
        $this->offset += $length;

        return new Ext($type, $data);
    }

    private function ensureLength($length)
    {
        if (!isset($this->buffer[$this->offset + $length - 1])) {
            throw new InsufficientDataException($length, \strlen($this->buffer) - $this->offset);
        }
    }

    private function handleIntOverflow($value)
    {
        if (self::INT_AS_STR === $this->intOverflowMode) {
            return \sprintf('%u', $value);
        }
        if (self::INT_AS_GMP === $this->intOverflowMode) {
            return \gmp_init(\sprintf('%u', $value));
        }

        throw new IntegerOverflowException($value);
    }
}