Yiisoft\Yii\Debug\Collector\QueueCollector

Complexity

Total Complexity

9

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Test Coverage

Coverage

87.5%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	reset()	0	5	1
A	getIndexData()	0	11	1
A	collectWorkerProcessing()	0	6	2
A	getCollected()	0	6	1
A	collectStatus()	0	7	2
A	collectPush()	0	6	2

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\Collector;

use Yiisoft\Yii\Queue\Message\MessageInterface;
use Yiisoft\Yii\Queue\QueueInterface;

final class QueueCollector implements CollectorInterface, IndexCollectorInterface
{
    use CollectorTrait;

    private array $pushes = [];
    private array $statuses = [];
    private array $processingMessages = [];

    public function getCollected(): array
    {
        return [
            'pushes' => $this->pushes,
            'statuses' => $this->statuses,
            'processingMessages' => $this->processingMessages,
        ];
    }

    public function collectStatus(string $id): void
    {
        if (!$this->isActive()) {
            return;
        }

        $this->statuses[] = $id;
    }

    public function collectPush(string $channel, MessageInterface $message): void
    {
        if (!$this->isActive()) {
            return;
        }
        $this->pushes[$channel][] = $message;
    }

    public function collectWorkerProcessing(MessageInterface $message, QueueInterface $queue)
    {
        if (!$this->isActive()) {
            return;
        }
        $this->processingMessages[$queue->getChannelName()][] = $message;
    }

    private function reset(): void

The method reset() is not used, and could be removed.

    {
        $this->pushes = [];
        $this->statuses = [];
        $this->processingMessages = [];
    }

    public function getIndexData(): array
    {
        $countPushes = array_sum(array_map(fn ($messages) => count($messages), $this->pushes));
        $countStatuses = count($this->statuses);
        $countProcessingMessages = array_sum(array_map(fn ($messages) => count($messages), $this->processingMessages));

        return [
            'queue' => [
                'countPushes' => $countPushes,
                'countStatuses' => $countStatuses,
                'countProcessingMessages' => $countProcessingMessages,
            ],
        ];
    }
}