Equip\RedisQueue\Daemon

Complexity

Total Complexity

5

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	setListener()	0	4	1
A	run()	0	13	3

<?php

namespace Equip\RedisQueue;

use Aura\Cli\Stdio;
use Aura\Cli\Context;
use Aura\Cli\Status;

class Daemon
{
    /**
     * @var Consumer
     */
    private $consumer;

    /**
     * @var Stdio
     */
    private $stdio;

    /**
     * @var Context
     */
    private $context;

    /**
     * @var callable
     */
    private $listener;

    /**
     * @param Consumer $consumer
     * @param Stdio $stdio
     * @param Context $context
     */
    public function __construct(
        Consumer $consumer,
        Stdio $stdio,
        Context $context
    )
    {
        $this->consumer = $consumer;
        $this->stdio = $stdio;
        $this->context = $context;

        $this->setListener(function () { return true; });

It is generally recommended to place each PHP statement on a line by itself.

    }

    /**
     * @param callable $listener
     */
    public function setListener(callable $listener)
    {
        $this->listener = $listener;
    }

    /**
     * @return int Status code to exit with
     */
    public function run()
    {
        $queue = $this->context->argv->get(1);
        if (!$queue) {
            $this->stdio->outln('<<red>>No queue specified<<reset>>');
            return Status::USAGE;
        }

        while (call_user_func($this->listener)) {
            $this->consumer->consume($queue);
        }
        return Status::SUCCESS;
    }
}