oficial/app/src/Service/Queue.php

<?php
namespace Incoviba\Service;

use Exception;
use Psr\Http\Message\RequestInterface;
use Psr\Log\LoggerInterface;
use Incoviba\Common\Ideal;
use Incoviba\Exception\ServiceAction\{Create, Read};
use Incoviba\Service;

class Queue extends Ideal\Service
{
    public function __construct(LoggerInterface $logger, protected Service\Job $jobService, Worker $defaultWorker)
    {
        parent::__construct($logger);
        $this->register('default', $defaultWorker);
    }

    protected array $workers;
    public function register(string $name, Worker $worker): self
    {
        $this->workers[strtolower($name)] = $worker;
        return $this;
    }

    public function enqueue(array $configuration): bool
    {
        try {
            $this->jobService->add($configuration);
            return true;
        } catch (Create $exception) {
            $final = new Exception("Could not enqueue job", 0, $exception);
            $this->logger->warning($final);
            return false;
        }
    }

    public function run(?RequestInterface $request): bool
    {
        try {
            $jobs = $this->jobService->getPending();
        } catch (Read $exception) {
            $final = new Exception("Could not get pending jobs", 0, $exception);
            $this->logger->warning($final);
            return false;
        }

        $errors = [];
        foreach ($jobs as $job) {
            $type = 'default';
            if (isset($job->configuration['type'])) {
                $type = strtolower($job->configuration['type']);
            }
            if (!isset($this->workers[$type])) {
                $type = 'default';
            }

            $worker = $this->workers[$type];
            if (is_a($worker, Service\Worker\Request::class)) {
                $worker->setRequest($request);
            }

            try {
                if (!$worker->execute($job)) {
                    $errors []= $job->id;
                    continue;
                }
                if (!$this->jobService->execute($job)) {
                    $errors []= $job->id;
                }
            } catch (Exception $exception) {
                $final = new Exception("Could not run job", 0, $exception);
                $this->logger->warning($final);
                $errors []= $job->id;
            }
            break;
        }
        return count($errors) === 0;
    }
}