QueueDecorator::push() - Code Metrics - Inspection of "Create basic db collector" - yiisoft/yii-debug - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#160)

by Dmitriy

created 2023-02-13 11:31 UTC

QueueDecorator::push() A

↳ Parent: QueueDecorator

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	3
dl	0
loc	7
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	2

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\Collector\Queue;

use Yiisoft\Yii\Queue\Adapter\AdapterInterface;
use Yiisoft\Yii\Queue\Enum\JobStatus;
use Yiisoft\Yii\Queue\Message\MessageInterface;
use Yiisoft\Yii\Queue\Middleware\Push\MiddlewarePushInterface;
use Yiisoft\Yii\Queue\QueueInterface;

final class QueueDecorator implements QueueInterface
{
    public function __construct(
        private QueueInterface $queue,
        private QueueCollector $collector,
    ) {
    }

    public function status(string $id): JobStatus
    {
        $result = $this->queue->status($id);
        $this->collector->collectStatus($id, $result);

        return $result;
    }

    public function push(
        MessageInterface $message,
        string|array|callable|MiddlewarePushInterface ...$middlewareDefinitions
    ): MessageInterface {
        $message = $this->queue->push($message, ...$middlewareDefinitions);
        $this->collector->collectPush($this->queue->getChannelName(), $message, ...$middlewareDefinitions);
        return $message;
    }

    public function run(int $max = 0): void
    {
        $this->queue->run($max);
    }

    public function listen(): void
    {
        $this->queue->listen();
    }

    public function withAdapter(AdapterInterface $adapter): QueueInterface
    {
        return new self($this->queue->withAdapter($adapter), $this->collector);
    }

    public function getChannelName(): string
    {
        return $this->queue->getChannelName();
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Yiisoft\Yii\Debug\Collector\Queue;
6
7			use Yiisoft\Yii\Queue\Adapter\AdapterInterface;
8			use Yiisoft\Yii\Queue\Enum\JobStatus;
9			use Yiisoft\Yii\Queue\Message\MessageInterface;
10			use Yiisoft\Yii\Queue\Middleware\Push\MiddlewarePushInterface;
11			use Yiisoft\Yii\Queue\QueueInterface;
12
13			final class QueueDecorator implements QueueInterface
14			{
15			public function __construct(
16			private QueueInterface $queue,
17			private QueueCollector $collector,
18			) {
19			}
20
21			public function status(string $id): JobStatus
22			{
23			$result = $this->queue->status($id);
24			$this->collector->collectStatus($id, $result);
25
26			return $result;
27			}
28
29			public function push(
30			MessageInterface $message,
31			string\|array\|callable\|MiddlewarePushInterface ...$middlewareDefinitions
32			): MessageInterface {
33			$message = $this->queue->push($message, ...$middlewareDefinitions);
34			$this->collector->collectPush($this->queue->getChannelName(), $message, ...$middlewareDefinitions);
35			return $message;
36			}
37
38			public function run(int $max = 0): void
39			{
40			$this->queue->run($max);
41			}
42
43			public function listen(): void
44			{
45			$this->queue->listen();
46			}
47
48			public function withAdapter(AdapterInterface $adapter): QueueInterface
49			{
50			return new self($this->queue->withAdapter($adapter), $this->collector);
51			}
52
53			public function getChannelName(): string
54			{
55			return $this->queue->getChannelName();
56			}
57			}
58

yiisoft / yii-debug

Pull Request — master (#160)

QueueDecorator::push() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like