Tarantool\Client\Connection\Greeting

Complexity

Total Complexity

16

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Test Coverage

Coverage

87.88%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	unknown()	0	6	1
A	getSalt()	0	21	5
A	__construct()	0	3	1
A	getServerVersion()	0	11	3
A	equals()	0	11	4
A	parse()	0	7	2

<?php

/**
 * 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.
 */

declare(strict_types=1);

namespace Tarantool\Client\Connection;

use Tarantool\Client\Exception\UnexpectedResponse;

final class Greeting
{
    public const SIZE_BYTES = 128;

    /** @var string */
    private $greeting;

    /** @var string|null */
    private $salt;

    /** @var string|null */
    private $serverVersion;

    /** @var bool */
    private $unknown = false;

    /**
     * @param string $greeting
     */
    private function __construct($greeting)
    {
        $this->greeting = $greeting;
    }

    public static function parse(string $greeting) : self
    {
        if (0 === \strpos($greeting, 'Tarantool')) {
            return new self($greeting);
        }

        throw new UnexpectedResponse('Unable to recognize Tarantool server');
    }

    public static function unknown() : self
    {
        $self = new self('');
        $self->unknown = true;

        return $self;
    }

    public function getSalt() : string
    {
        if (null !== $this->salt) {
            return $this->salt;
        }

        if ($this->unknown) {
            throw new \BadMethodCallException('Salt is unknown for persistent connections');
        }

        if (false === $salt = \base64_decode(\substr($this->greeting, 64, 44), true)) {
            throw new UnexpectedResponse('Unable to decode salt');
        }

        $salt = \substr($salt, 0, 20);

        if (isset($salt[19])) {
            return $this->salt = $salt;
        }

        throw new UnexpectedResponse('Salt is too short');
    }

    public function getServerVersion() : string
    {
        if (null !== $this->serverVersion) {
            return $this->serverVersion;
        }

        if ($this->unknown) {
            throw new \BadMethodCallException('Server version is unknown for persistent connections');
        }

        return $this->serverVersion = \substr($this->greeting, 10, \strspn($this->greeting, '0123456789.', 10));
    }

    public function equals(?self $greeting) : bool
    {
        if (!$greeting || $greeting->unknown) {
            return $this->unknown;
        }

        if ($this->unknown) {
            return true;
        }

        return $greeting->getSalt() === $this->getSalt();
    }
}