Seasx\SeasLogger\Kafka\ProtocolTool

Complexity

Total Complexity

6

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	encode()	0	7	2
A	init()	0	9	2
A	decode()	0	7	2

<?php
declare(strict_types=1);

namespace Seasx\SeasLogger\Kafka;

use Exception;
use Seasx\SeasLogger\Exceptions\NotSupportedException;

class ProtocolTool
{
    /**
     * protocol request code
     */
    public const PRODUCE_REQUEST = 0;
    public const METADATA_REQUEST = 3;

    /**
     * @var Protocol[]
     */
    protected static $objects = [];

    /**
     * @param string $version
     */
    public static function init(string $version): void
    {
        $class = [
            Protocol::PRODUCE_REQUEST => Produce::class,
            Protocol::METADATA_REQUEST => Metadata::class,
        ];

        foreach ($class as $key => $className) {
            self::$objects[$key] = new $className($version);
        }
    }

    /**
     * @param int $key
     * @param array $payloads
     * @return string
     * @throws Exception
     */
    public static function encode(int $key, array $payloads): string
    {
        if (!isset(self::$objects[$key])) {
            throw new NotSupportedException('Not support api key, key:' . $key);
        }

        return self::$objects[$key]->encode($payloads);
    }

    /**
     * @param int $key
     * @param string $data
     * @return array
     * @throws Exception
     */
    public static function decode(int $key, string $data): array
    {
        if (!isset(self::$objects[$key])) {
            throw new NotSupportedException('Not support api key, key:' . $key);
        }

        return self::$objects[$key]->decode($data);
    }
}