LockingMiddleware::executeQueuedJobs() - Code Metrics - lamoda/tactician-locking-middleware - Measure and Improve Code Quality continuously with Scrutinizer

LockingMiddleware::executeQueuedJobs() A
last analyzed 2020-02-07 07:50 UTC

↳ Parent: LockingMiddleware

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	9
ccs	5
cts	5
cp	1
rs	9.9666
c	0
b	0
f	0
cc	2
nc	2
nop	0
crap	2

<?php

declare(strict_types=1);

namespace Lamoda\TacticianLockingMiddleware;

use League\Tactician\Middleware;

/**
 * If another command is already being executed, locks the command bus and
 * queues the new incoming commands until the first has completed.
 */
class LockingMiddleware implements Middleware
{
    /**
     * @var bool
     */
    private $isExecuting;

    /**
     * @var callable[]
     */
    private $queue = [];

    /**
     * This middleware differs from the original in a way it handles Throwable, not only Exception.
     *
     * @param object   $command
     * @param callable $next
     *
     * @throws \Throwable
     *
     * @return mixed|void
     */
    public function execute($command, callable $next)
    {
        $this->queue[] = static function () use ($command, $next) {
            return $next($command);
        };

        if ($this->isExecuting) {
            return;
        }
        $this->isExecuting = true;

        try {
            $returnValue = $this->executeQueuedJobs();
        } catch (\Throwable $e) {
            $this->isExecuting = false;
            $this->queue = [];
            throw $e;
        }

        $this->isExecuting = false;

        return $returnValue;
    }

    /**
     * Process any pending commands in the queue. If multiple, jobs are in the
     * queue, only the first return value is given back.
     *
     * @return mixed
     */
    protected function executeQueuedJobs()
    {
        $returnValues = [];
        while ($resumeCommand = array_shift($this->queue)) {
            $returnValues[] = $resumeCommand();
        }

        return array_shift($returnValues);
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Lamoda\TacticianLockingMiddleware;
6
7		use League\Tactician\Middleware;
8
9		/**
10		* If another command is already being executed, locks the command bus and
11		* queues the new incoming commands until the first has completed.
12		*/
13		class LockingMiddleware implements Middleware
14		{
15		/**
16		* @var bool
17		*/
18		private $isExecuting;
19
20		/**
21		* @var callable[]
22		*/
23		private $queue = [];
24
25		/**
26		* This middleware differs from the original in a way it handles Throwable, not only Exception.
27		*
28		* @param object $command
29		* @param callable $next
30		*
31		* @throws \Throwable
32		*
33		* @return mixed\|void
34		*/
35	3	public function execute($command, callable $next)
36		{
37		$this->queue[] = static function () use ($command, $next) {
38	3	return $next($command);
39		};
40
41	3	if ($this->isExecuting) {
42	1	return;
43		}
44	3	$this->isExecuting = true;
45
46		try {
47	3	$returnValue = $this->executeQueuedJobs();
48	1	} catch (\Throwable $e) {
49	1	$this->isExecuting = false;
50	1	$this->queue = [];
51	1	throw $e;
52		}
53
54	3	$this->isExecuting = false;
55
56	3	return $returnValue;
57		}
58
59		/**
60		* Process any pending commands in the queue. If multiple, jobs are in the
61		* queue, only the first return value is given back.
62		*
63		* @return mixed
64		*/
65	3	protected function executeQueuedJobs()
66		{
67	3	$returnValues = [];
68	3	while ($resumeCommand = array_shift($this->queue)) {
69	3	$returnValues[] = $resumeCommand();
70		}
71
72	3	return array_shift($returnValues);
73		}
74		}
75

lamoda / tactician-locking-middleware

LockingMiddleware::executeQueuedJobs() A last analyzed 2020-02-07 07:50 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

LockingMiddleware::executeQueuedJobs() A
last analyzed 2020-02-07 07:50 UTC