Seasx\SeasLogger\Kafka\Broker

Complexity

Total Complexity

15

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getGroupBrokerId()	0	3	1
A	clear()	0	3	1
A	__construct()	0	5	3
A	getTopics()	0	3	1
A	setGroupBrokerId()	0	3	1
B	setData()	0	38	7
A	getBrokers()	0	3	1

<?php
declare(strict_types=1);

namespace Seasx\SeasLogger\Kafka;

class Broker
{
    /**
     * @var int
     */
    private $groupBrokerId;
    /**
     * @var mixed[][]
     */
    private $topics = [];
    /**
     * @var string[]
     */
    private $brokers = [];

    /**
     * Broker constructor.
     * @param array $configs
     */
    public function __construct(array $configs)
    {
        foreach ($configs as $name => $value) {
            if (property_exists($this, $name)) {
                $this->$name = $value;
            }
        }
    }

    /**
     * @return int
     */
    public function getGroupBrokerId(): int
    {
        return $this->groupBrokerId;
    }

    /**
     * @param int $brokerId
     */
    public function setGroupBrokerId(int $brokerId): void
    {
        $this->groupBrokerId = $brokerId;
    }

    /**
     * @param array $topics
     * @param array $brokersResult
     * @return bool
     */
    public function setData(array $topics, array $brokersResult): bool
    {
        $brokers = [];

        foreach ($brokersResult as $value) {
            $brokers[$value['nodeId']] = $value['host'] . ':' . $value['port'];
        }

        $changed = false;

        if (serialize($this->brokers) !== serialize($brokers)) {
            $this->brokers = $brokers;

            $changed = true;
        }

        $newTopics = [];
        foreach ($topics as $topic) {
            if ((int)$topic['errorCode'] !== Protocol::NO_ERROR) {
                continue;
            }

            $item = [];

            foreach ($topic['partitions'] as $part) {
                $item[$part['partitionId']] = $part['leader'];
            }

            $newTopics[$topic['topicName']] = $item;
        }

        if (serialize($this->topics) !== serialize($newTopics)) {
            $this->topics = $newTopics;

            $changed = true;
        }

        return $changed;
    }

    /**
     * @return array
     */
    public function getTopics(): array
    {
        return $this->topics;
    }

    /**
     * @return string[]
     */
    public function getBrokers(): array
    {
        return $this->brokers;
    }

    public function clear(): void
    {
        $this->brokers = [];
    }
}