Equip\Queue\Event

Complexity

Total Complexity

4

Size/Duplication

Total Lines	65
Duplicated Lines	41.54 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

16.66%

Importance

Changes	5
Bugs	0	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	acknowledge()	9	9	1
A	finish()	9	9	1
A	reject()	9	9	1

<?php

namespace Equip\Queue;

use Exception;
use League\Event\EmitterInterface;

class Event
{
    const MESSAGE_ACKNOWLEDGE = 'message.acknowledge';
    const MESSAGE_FINISH = 'message.finish';
    const MESSAGE_REJECT = 'message.reject';

    /**
     * @var EmitterInterface
     */
    private $emitter;

    /**
     * @param EmitterInterface $emitter
     */
    public function __construct(EmitterInterface $emitter)
    {
        $this->emitter = $emitter;
    }

    /**
     * Emits message acknowledgement events
     *
     * @param AbstractOptions $options
     */
    public function acknowledge(AbstractOptions $options)

This method seems to be duplicated in your project.

    {
        array_map(function ($name) use ($options) {
            $this->emitter->emit($name, $options);

The call to EmitterInterface::emit() has too many arguments starting with $options.

        }, [
            static::MESSAGE_ACKNOWLEDGE,
            sprintf('%s.%s', static::MESSAGE_ACKNOWLEDGE, $options->command())
        ]);
    }

    /**
     * Emits message finished events
     *
     * @param AbstractOptions $options
     */
    public function finish(AbstractOptions $options)

This method seems to be duplicated in your project.

    {
        array_map(function ($name) use ($options) {
           $this->emitter->emit($name, $options) ;

The call to EmitterInterface::emit() has too many arguments starting with $options.

        }, [
            static::MESSAGE_FINISH,
            sprintf('%s.%s', static::MESSAGE_FINISH, $options->command())
        ]);
    }

    /**
     * Emits message rejection events
     *
     * @param AbstractOptions $options
     * @param Exception $exception
     */
    public function reject(AbstractOptions $options, Exception $exception)

This method seems to be duplicated in your project.

    {
        array_map(function ($name) use ($options, $exception) {
            $this->emitter->emit($name, $options, $exception);

The call to EmitterInterface::emit() has too many arguments starting with $options.

        }, [
            static::MESSAGE_REJECT,
            sprintf('%s.%s', static::MESSAGE_REJECT, $options->command())
        ]);
    }
}