Code Duplication - CMProductions/queues - Measure and Improve Code Quality continuously with Scrutinizer

Code Duplication Length = 50-52 lines in 2 locations

src/Domain/Event/Publisher.php 1 location


use Domain\Event\Exception\DomainEventException;
use Domain\Queue\QueueWriter;

class Publisher
{
    /**
     * @var QueueWriter
     */
    protected $queueWriter;

    /**
     * @var DomainEvent[]
     */
    protected $events = [];

    /**
     * Publisher constructor.
     * @param QueueWriter $queueWriter
     */
    public function __construct(QueueWriter $queueWriter)
    {
        $this->queueWriter = $queueWriter;
    }

    /**
     * Add Domain Events to buffer
     * @param DomainEvent $event
     * @return $this
     */
    public function add(DomainEvent $event)
    {
        $this->events[] = $event;
        return $this;
    }
    
    /**
     * @throws DomainEventException
     */
    public function publish()
    {
        if(!isset($this->events[0])) {
            throw new DomainEventException('You must add at least 1 DomainEvent in order to publish to queue.');
        }
        $this->queueWriter->write($this->events);
        $this->events = [];
    }

    /**
     * @return DomainEvent[]
     */
    public function getEvents()
    {
        return $this->events;
    }
}

src/Domain/Task/Producer.php 1 location


use Domain\Queue\QueueWriter;
use Domain\Task\Exception\TaskException;

class Producer
{
    /**
     * @var QueueWriter
     */
    protected $queueWriter;

    /**
     * @var Task[]
     */
    protected $tasks = [];

    /**
     * Producer constructor.
     * @param QueueWriter $queueWriter
     */
    public function __construct(QueueWriter $queueWriter)
    {
        $this->queueWriter = $queueWriter;
    }

    /**
     * @param Task $task
     * @return $this
     */
    public function add(Task $task)
    {
        $this->tasks[] = $task;
        return $this;
    }

    /**
     * @throws TaskException
     */
    public function produce()
    {
        if(!isset($this->tasks[0])) {
            throw new TaskException('You must add at least 1 Task before producing.');
        }
        $this->queueWriter->write($this->tasks);
    }

    /**
     * @return Task[]
     */
    public function getTasks()
    {
        return $this->tasks;
    }
}

		@@ 7-58 (lines=52) @@
4		use Domain\Event\Exception\DomainEventException;
5		use Domain\Queue\QueueWriter;
6
7		class Publisher
8		{
9		/**
10		* @var QueueWriter
11		*/
12		protected $queueWriter;
13
14		/**
15		* @var DomainEvent[]
16		*/
17		protected $events = [];
18
19		/**
20		* Publisher constructor.
21		* @param QueueWriter $queueWriter
22		*/
23		public function __construct(QueueWriter $queueWriter)
24		{
25		$this->queueWriter = $queueWriter;
26		}
27
28		/**
29		* Add Domain Events to buffer
30		* @param DomainEvent $event
31		* @return $this
32		*/
33		public function add(DomainEvent $event)
34		{
35		$this->events[] = $event;
36		return $this;
37		}
38
39		/**
40		* @throws DomainEventException
41		*/
42		public function publish()
43		{
44		if(!isset($this->events[0])) {
45		throw new DomainEventException('You must add at least 1 DomainEvent in order to publish to queue.');
46		}
47		$this->queueWriter->write($this->events);
48		$this->events = [];
49		}
50
51		/**
52		* @return DomainEvent[]
53		*/
54		public function getEvents()
55		{
56		return $this->events;
57		}
58		}

		@@ 7-56 (lines=50) @@
4		use Domain\Queue\QueueWriter;
5		use Domain\Task\Exception\TaskException;
6
7		class Producer
8		{
9		/**
10		* @var QueueWriter
11		*/
12		protected $queueWriter;
13
14		/**
15		* @var Task[]
16		*/
17		protected $tasks = [];
18
19		/**
20		* Producer constructor.
21		* @param QueueWriter $queueWriter
22		*/
23		public function __construct(QueueWriter $queueWriter)
24		{
25		$this->queueWriter = $queueWriter;
26		}
27
28		/**
29		* @param Task $task
30		* @return $this
31		*/
32		public function add(Task $task)
33		{
34		$this->tasks[] = $task;
35		return $this;
36		}
37
38		/**
39		* @throws TaskException
40		*/
41		public function produce()
42		{
43		if(!isset($this->tasks[0])) {
44		throw new TaskException('You must add at least 1 Task before producing.');
45		}
46		$this->queueWriter->write($this->tasks);
47		}
48
49		/**
50		* @return Task[]
51		*/
52		public function getTasks()
53		{
54		return $this->tasks;
55		}
56		}

CMProductions / queues

Code Duplication Length = 50-52 lines in 2 locations

src/Domain/Event/Publisher.php 1 location

src/Domain/Task/Producer.php 1 location