QueueService::prepare() - Code Metrics - Inspection of "fix: migrate to 7.4" - LinioIT/queue - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#7)

by Klaus

created 2020-01-02 17:49 UTC

QueueService::prepare() A

↳ Parent: Project

Complexity

Conditions	3
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php

declare(strict_types=1);

namespace Linio\Component\Queue;

use Exception;
use Linio\Component\Queue\Adapter\NullAdapter;
use Linio\Component\Util\Json;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

class QueueService
{
    protected AdapterInterface $adapter;

    protected LoggerInterface $logger;

    public function __construct()
    {
        $this->adapter = new NullAdapter();
        $this->logger = new NullLogger();
    }

    public function add(Job $job): bool
    {
        try {
            $this->prepare($job);
            $this->adapter->add($job);
        } catch (Exception $e) {
            $this->logger->error('[Queue] An error has occurred when adding job: ' . $e->getMessage(), (array) $e);

            return false;
        }

        return true;
    }

    public function perform(Job $job): bool
    {
        try {
            $this->adapter->perform($job);
        } catch (Exception $e) {
            $message = sprintf('[Queue] An error has occurred while performing "%s": %s', get_class($job), $e->getMessage());
            $this->logger->error($message, (array) $e);

            return false;
        }

        return true;
    }

    protected function prepare(Job $job): void
    {
        $payload = $job->getPayload();

        if ($payload && !is_scalar($payload)) {
            $job->setPayload(Json::encode($payload));
        }
    }

    public function setAdapter(AdapterInterface $adapter): void
    {
        $this->adapter = $adapter;
    }

    public function setLogger(LoggerInterface $logger): void
    {
        $this->logger = $logger;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Linio\Component\Queue;
6
7			use Exception;
8			use Linio\Component\Queue\Adapter\NullAdapter;
9			use Linio\Component\Util\Json;
10			use Psr\Log\LoggerInterface;
11			use Psr\Log\NullLogger;
12
13			class QueueService
14			{
15			protected AdapterInterface $adapter;
			0 ignored issues – show Bug introduced 2020-01-02 17:51 UTC by Report Bug Copy Issue Report This code did not parse for me. Apparently, there is an error somewhere around this line: Syntax error, unexpected T_STRING, expecting T_FUNCTION or T_CONST Loading history...
16			protected LoggerInterface $logger;
17
18			public function __construct()
19			{
20			$this->adapter = new NullAdapter();
21			$this->logger = new NullLogger();
22			}
23
24			public function add(Job $job): bool
25			{
26			try {
27			$this->prepare($job);
28			$this->adapter->add($job);
29			} catch (Exception $e) {
30			$this->logger->error('[Queue] An error has occurred when adding job: ' . $e->getMessage(), (array) $e);
31
32			return false;
33			}
34
35			return true;
36			}
37
38			public function perform(Job $job): bool
39			{
40			try {
41			$this->adapter->perform($job);
42			} catch (Exception $e) {
43			$message = sprintf('[Queue] An error has occurred while performing "%s": %s', get_class($job), $e->getMessage());
44			$this->logger->error($message, (array) $e);
45
46			return false;
47			}
48
49			return true;
50			}
51
52			protected function prepare(Job $job): void
53			{
54			$payload = $job->getPayload();
55
56			if ($payload && !is_scalar($payload)) {
57			$job->setPayload(Json::encode($payload));
58			}
59			}
60
61			public function setAdapter(AdapterInterface $adapter): void
62			{
63			$this->adapter = $adapter;
64			}
65
66			public function setLogger(LoggerInterface $logger): void
67			{
68			$this->logger = $logger;
69			}
70			}
71

LinioIT / queue

Pull Request — master (#7)

QueueService::prepare() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like