MySQLReplication\BinLog\BinLogServerInfo

Complexity

Total Complexity

16

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Test Coverage

Coverage

88.89%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	isMariaDb()	0	3	1
A	getVersion()	0	3	1
A	getSalt()	0	3	1
A	parseVersion()	0	12	4
A	isGeneric()	0	3	1
B	parsePackage()	0	68	7
A	isPercona()	0	3	1

<?php
declare(strict_types=1);

namespace MySQLReplication\BinLog;

class BinLogServerInfo
{
    private const MYSQL_VERSION_MARIADB = 'MariaDB';
    private const MYSQL_VERSION_PERCONA = 'Percona';
    private const MYSQL_VERSION_GENERIC = 'MySQL';
    private static $serverInfo = [];

    public static function parsePackage(string $data, string $version): void
    {
        $i = 0;
        $length = strlen($data);
        self::$serverInfo['protocol_version'] = ord($data[$i]);
        ++$i;

        //version
        self::$serverInfo['server_version'] = '';
        $start = $i;
        for ($i = $start; $i < $length; ++$i) {
            if ($data[$i] === chr(0)) {
                ++$i;
                break;
            }
            self::$serverInfo['server_version'] .= $data[$i];
        }

        //connection_id 4 bytes
        self::$serverInfo['connection_id'] = unpack('I', $data[$i] . $data[++$i] . $data[++$i] . $data[++$i])[1];
        ++$i;

        //auth_plugin_data_part_1
        //[len=8] first 8 bytes of the auth-plugin data
        self::$serverInfo['salt'] = '';
        for ($j = $i; $j < $i + 8; ++$j) {
            self::$serverInfo['salt'] .= $data[$j];
        }
        $i += 8;

        //filler_1 (1) -- 0x00
        ++$i;

        //capability_flag_1 (2) -- lower 2 bytes of the Protocol::CapabilityFlags (optional)
        $i += 2;

        //character_set (1) -- default server character-set, only the lower 8-bits Protocol::CharacterSet (optional)
        self::$serverInfo['character_set'] = $data[$i];
        ++$i;

        //status_flags (2) -- Protocol::StatusFlags (optional)

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

        $i += 2;

        //capability_flags_2 (2) -- upper 2 bytes of the Protocol::CapabilityFlags
        $i += 2;

        //auth_plugin_data_len (1) -- length of the combined auth_plugin_data, if auth_plugin_data_len is > 0
        $salt_len = ord($data[$i]);
        ++$i;

        $salt_len = max(12, $salt_len - 9);

        $i += 10;

        //next salt
        if ($length >= $i + $salt_len) {
            for ($j = $i; $j < $i + $salt_len; ++$j) {
                self::$serverInfo['salt'] .= $data[$j];
            }

        }
        self::$serverInfo['auth_plugin_name'] = '';
        $i += $salt_len + 1;
        for ($j = $i; $j < $length - 1; ++$j) {
            self::$serverInfo['auth_plugin_name'] .= $data[$j];
        }

        self::$serverInfo['version_name'] = self::parseVersion($version);
    }

    public static function getSalt(): string
    {
        return self::$serverInfo['salt'];
    }

    /**
     * @see http://stackoverflow.com/questions/37317869/determine-if-mysql-or-percona-or-mariadb
     */
    private static function parseVersion(string $version): string
    {
        if ('' !== $version) {
            if (false !== strpos($version, self::MYSQL_VERSION_MARIADB)) {
                return self::MYSQL_VERSION_MARIADB;
            }
            if (false !== strpos($version, self::MYSQL_VERSION_PERCONA)) {
                return self::MYSQL_VERSION_PERCONA;
            }
        }

        return self::MYSQL_VERSION_GENERIC;
    }

    public static function getVersion(): string
    {
        return self::$serverInfo['version_name'];
    }

    public static function isMariaDb(): bool
    {
        return self::MYSQL_VERSION_MARIADB === self::getVersion();
    }

    public static function isPercona(): bool
    {
        return self::MYSQL_VERSION_PERCONA === self::getVersion();
    }

    public static function isGeneric(): bool
    {
        return self::MYSQL_VERSION_GENERIC === self::getVersion();
    }
}