TransactionalCommandLockingDecorator::execute() - Code Metrics - adamnicholson/Chief - Measure and Improve Code Quality continuously with Scrutinizer

TransactionalCommandLockingDecorator::execute() A
last analyzed 2017-01-26 10:20 UTC

↳ Parent: TransactionalCommandLockingDecorator

Complexity

Conditions	2
Paths	2

Size

Total Lines	17
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	17
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	9
nc	2
nop	1

<?php

namespace Chief\Decorators;

use Chief\Busses\SynchronousCommandBus;
use Chief\Command;
use Chief\CommandBus;
use Chief\Decorator;

/**
 * TransactionalCommandLockingDecorator treats commands as transactions. Meaning that any
 * subsequent Commands passed to the bus from inside the relevant CommandHandler
 * will not be executed until the initial command is completed.
 */
class TransactionalCommandLockingDecorator implements Decorator
{
    use InnerBusTrait;

    /**
     * Whether or not a Command is in progress and the bus is locked
     * @var bool
     */
    protected $locked = false;

    /**
     * Queued Commands to be executed when the current command finishes
     * @var array
     */
    protected $queue = [];

    public function __construct(CommandBus $innerCommandBus = null)
    {
        $this->setInnerBus($innerCommandBus ?: new SynchronousCommandBus());
    }

    /**
     * Execute a command
     *
     * @param Command $command
     * @return mixed
     */
    public function execute(Command $command)
    {
        if ($this->locked === true) {
            $this->queue[] = $command;
            return null;
        }

        $this->locked = true;

        $response = $this->executeIgnoringLock($command);

        $this->executeQueue();

        $this->locked = false;

        return $response;
    }

    /**
     * Execute a command, regardless of the lock
     *
     * @param Command $command
     * @return mixed
     */
    protected function executeIgnoringLock(Command $command)
    {
        return $this->innerCommandBus->execute($command);
    }

    /**
     * Execute all queued commands
     */
    protected function executeQueue()
    {
        foreach ($this->queue as $command) {
            $this->executeIgnoringLock($command);
        }
    }
}


1			<?php
2
3			namespace Chief\Decorators;
4
5			use Chief\Busses\SynchronousCommandBus;
6			use Chief\Command;
7			use Chief\CommandBus;
8			use Chief\Decorator;
9
10			/**
11			* TransactionalCommandLockingDecorator treats commands as transactions. Meaning that any
12			* subsequent Commands passed to the bus from inside the relevant CommandHandler
13			* will not be executed until the initial command is completed.
14			*/
15			class TransactionalCommandLockingDecorator implements Decorator
16			{
17			use InnerBusTrait;
18
19			/**
20			* Whether or not a Command is in progress and the bus is locked
21			* @var bool
22			*/
23			protected $locked = false;
24
25			/**
26			* Queued Commands to be executed when the current command finishes
27			* @var array
28			*/
29			protected $queue = [];
30
31			public function __construct(CommandBus $innerCommandBus = null)
32			{
33			$this->setInnerBus($innerCommandBus ?: new SynchronousCommandBus());
34			}
35
36			/**
37			* Execute a command
38			*
39			* @param Command $command
40			* @return mixed
41			*/
42			public function execute(Command $command)
43			{
44			if ($this->locked === true) {
45			$this->queue[] = $command;
46			return null;
47			}
48
49			$this->locked = true;
50
51			$response = $this->executeIgnoringLock($command);
52
53			$this->executeQueue();
54
55			$this->locked = false;
56
57			return $response;
58			}
59
60			/**
61			* Execute a command, regardless of the lock
62			*
63			* @param Command $command
64			* @return mixed
65			*/
66			protected function executeIgnoringLock(Command $command)
67			{
68			return $this->innerCommandBus->execute($command);
69			}
70
71			/**
72			* Execute all queued commands
73			*/
74			protected function executeQueue()
75			{
76			foreach ($this->queue as $command) {
77			$this->executeIgnoringLock($command);
78			}
79			}
80			}
81

adamnicholson / Chief

GitHub Access Token became invalid

TransactionalCommandLockingDecorator::execute() A last analyzed 2017-01-26 10:20 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

TransactionalCommandLockingDecorator::execute() A
last analyzed 2017-01-26 10:20 UTC