MySQLReplication\Gtid\Gtid

Complexity

Total Complexity

7

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getEncodedLength()	0	3	1
A	__construct()	0	11	3
A	getEncoded()	0	16	3

<?php
declare(strict_types=1);

namespace MySQLReplication\Gtid;

use MySQLReplication\BinaryDataReader\BinaryDataReader;

class Gtid
{
    private $intervals = [];
    private $sid;

    /**
     * @throws GtidException
     */
    public function __construct(string $gtid)
    {
        if (false === (bool)preg_match('/^([0-9a-fA-F]{8}(?:-[0-9a-fA-F]{4}){3}-[0-9a-fA-F]{12})((?::[0-9-]+)+)$/', $gtid, $matches)) {
            throw new GtidException(GtidException::INCORRECT_GTID_MESSAGE, GtidException::INCORRECT_GTID_CODE);
        }

        $this->sid = $matches[1];
        foreach (array_filter(explode(':', $matches[2])) as $k) {
            $this->intervals[] = explode('-', $k);
        }
        $this->sid = str_replace('-', '', $this->sid);
    }

    public function getEncoded(): string
    {
        $buffer = pack('H*', $this->sid);
        $buffer .= BinaryDataReader::pack64bit(count($this->intervals));

        foreach ($this->intervals as $interval) {
            if (count($interval) !== 1) {
                $buffer .= BinaryDataReader::pack64bit((int)$interval[0]);
                $buffer .= BinaryDataReader::pack64bit((int)$interval[1]);
            } else {
                $buffer .= BinaryDataReader::pack64bit((int)$interval[0]);
                $buffer .= BinaryDataReader::pack64bit($interval[0] + 1);
            }
        }

        return $buffer;
    }

    public function getEncodedLength(): int
    {
        return (40 * count($this->intervals));
    }
}