Burrow\Daemon\QueueHandlingDaemon

Complexity

Total Complexity

6

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	16

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	15	2
A	start()	0	30	1
A	stop()	0	6	1
A	setMonitor()	0	4	1
A	setClock()	0	4	1

<?php

namespace Burrow\Daemon;

use Burrow\Clock;
use Burrow\ConsumeOptions;
use Burrow\Event\DaemonStarted;
use Burrow\Event\DaemonStopped;
use Burrow\Event\MessageConsumed;
use Burrow\Event\MessageReceived;
use Burrow\Event\NullEmitter;
use Burrow\RealClock;
use Evaneos\Daemon\Daemon;
use Evaneos\Daemon\DaemonMonitor;
use Burrow\Driver;
use Burrow\Message;
use Evaneos\Daemon\Monitor\NullMonitor;
use Burrow\QueueHandler;
use League\Event\Emitter;
use League\Event\EmitterInterface;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\NullLogger;

class QueueHandlingDaemon implements Daemon, LoggerAwareInterface
{
    use LoggerAwareTrait;
    
    /** @var Driver */
    private $driver;

    /** @var QueueHandler */
    private $handler;

    /** @var string */
    private $queueName;

    /** @var DaemonMonitor */
    private $monitor;

    /** @var Emitter */
    private $eventEmitter;

    /** @var Clock */
    private $clock;

    /**
     * Handler constructor.
     *
     * @param Driver                $driver
     * @param QueueHandler          $handler
     * @param string                $queueName
     * @param EmitterInterface|null $eventEmitter
     */
    public function __construct(
        Driver $driver,
        QueueHandler $handler,
        $queueName,
        EmitterInterface $eventEmitter = null
    ) {
        $this->driver = $driver;
        $this->handler = $handler;
        $this->queueName = $queueName;

        $this->monitor = new NullMonitor();
        $this->logger = new NullLogger();
        $this->eventEmitter = $eventEmitter ?: new NullEmitter();

$eventEmitter ?: new \Burrow\Event\NullEmitter() is of type object<League\Event\EmitterInterface>, but the property $eventEmitter was declared to be of type object<League\Event\Emitter>. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

        $this->clock = new RealClock();
    }

    /**
     * Run the daemon
     *
     * @return void
     */
    public function start()
    {
        $startTime = $this->clock->timestampInMs();

        $this->eventEmitter->emit(new DaemonStarted());

        $this->logger->info('Starting daemon...');

        $options = $this->handler->options(new ConsumeOptions());

        $this->driver->consume(
            $this->queueName,
            function (Message $message) use ($startTime) {
                $this->eventEmitter->emit(new MessageReceived());
                $this->monitor->monitor($this, $message);

                $result = $this->handler->handle($message);

                $this->eventEmitter->emit(new MessageConsumed($this->clock->timestampInMs() - $startTime));
                pcntl_signal_dispatch();

                return $result;
            },
            $options->getTimeout(),
            $options->isAutoAck()
        );

        $this->stop();
        $this->eventEmitter->emit(new DaemonStopped());
    }

    /**
     * Stop the daemon
     *
     * @return void
     */
    public function stop()
    {
        $this->logger->info('Closing daemon...');

        $this->driver->close();
    }

    /**
     * Set a monitor.
     *
     * @param DaemonMonitor $monitor
     */
    public function setMonitor(DaemonMonitor $monitor)
    {
        $this->monitor = $monitor;
    }

    /**
     * @param Clock $clock
     */
    public function setClock(Clock $clock)
    {
        $this->clock = $clock;
    }
}