Beanstalk::putJob() - Code Metrics - JC-IT/yii2-job-queue - Measure and Improve Code Quality continuously with Scrutinizer

Beanstalk::putJob() A
last analyzed 2021-04-20 08:54 UTC

↳ Parent: Beanstalk

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
eloc	7
nc	2
nop	4
dl	0
loc	15
ccs	5
cts	5
cp	1
crap	2
rs	10
c	0
b	0
f	0

<?php
declare(strict_types=1);

namespace JCIT\jobqueue\components\jobQueues;

use Closure;
use JCIT\jobqueue\interfaces\JobFactoryInterface;
use JCIT\jobqueue\interfaces\JobInterface;
use JCIT\jobqueue\interfaces\JobQueueInterface;
use Pheanstalk\Connection;
use Pheanstalk\Contract\PheanstalkInterface;
use Pheanstalk\Pheanstalk;

class Beanstalk extends Pheanstalk implements JobQueueInterface
{
    public function __construct(
        Connection $connection,
        private JobFactoryInterface $jobFactory,
        private ?Closure $beforePut = null
    ) {
        parent::__construct($connection);
    }

    public function putJob(
        JobInterface $job,
        int $priority = PheanstalkInterface::DEFAULT_PRIORITY,
        int $delay = PheanstalkInterface::DEFAULT_DELAY,
        int $ttr = PheanstalkInterface::DEFAULT_TTR
    ): void {
        if (isset($this->beforePut)) {
            ($this->beforePut)($job);
        }

        $this->put(
            $this->jobFactory->saveToJson($job),
            $priority,
            $delay,
            $ttr
        );
    }
}


1		<?php
2		declare(strict_types=1);
3
4		namespace JCIT\jobqueue\components\jobQueues;
5
6		use Closure;
7		use JCIT\jobqueue\interfaces\JobFactoryInterface;
8		use JCIT\jobqueue\interfaces\JobInterface;
9		use JCIT\jobqueue\interfaces\JobQueueInterface;
10		use Pheanstalk\Connection;
11		use Pheanstalk\Contract\PheanstalkInterface;
12		use Pheanstalk\Pheanstalk;
13
14		class Beanstalk extends Pheanstalk implements JobQueueInterface
15		{
16	1	public function __construct(
17		Connection $connection,
18		private JobFactoryInterface $jobFactory,
19		private ?Closure $beforePut = null
20		) {
21	1	parent::__construct($connection);
22	1	}
23
24	1	public function putJob(
25		JobInterface $job,
26		int $priority = PheanstalkInterface::DEFAULT_PRIORITY,
27		int $delay = PheanstalkInterface::DEFAULT_DELAY,
28		int $ttr = PheanstalkInterface::DEFAULT_TTR
29		): void {
30	1	if (isset($this->beforePut)) {
31	1	($this->beforePut)($job);
32		}
33
34	1	$this->put(
35	1	$this->jobFactory->saveToJson($job),
36		$priority,
37		$delay,
38		$ttr
39		);
40	1	}
41		}
42

JC-IT / yii2-job-queue

Beanstalk::putJob() A last analyzed 2021-04-20 08:54 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Beanstalk::putJob() A
last analyzed 2021-04-20 08:54 UTC