FondBot\Toolbelt\Commands\QueueWorker

Complexity

Total Complexity

3

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	6	1
A	handle()	0	19	2

<?php

declare(strict_types=1);

namespace FondBot\Toolbelt\Commands;

use FondBot\Contracts\Queue;
use FondBot\Toolbelt\Command;

class QueueWorker extends Command
{
    protected function configure(): void
    {
        $this
            ->setName('queue:worker')
            ->setDescription('Run queue worker');
    }

    /**
     * Handle command.
     *
     * @throws \Psr\Container\ContainerExceptionInterface
     */
    public function handle(): void
    {
        /** @var Queue $queue */
        $queue = $this->kernel->resolve(Queue::class);
        $queue->connect();

        $this->info('Worker started...');

        while (true) {
            $job = $queue->next();

            $this->line('Job: '.get_class($job));

            $driver = $job->driver;
            $command = $job->command;

            $driver->handle($command);
        }
    }
}