Linio\Component\Queue\QueueService

Complexity

Total Complexity

9

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

<?php
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

class QueueService
{
    protected AdapterInterface $adapter;

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

    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;
    }