TransactionalCommandBus::dispatch() - Code Metrics - Inspection of "feat: add transactionnal command bus" - remi-san/broadway-tools - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#2)

by Pol-Valentin

created 2019-07-10 13:20 UTC

TransactionalCommandBus::dispatch() A

↳ Parent: TransactionalCommandBus

Complexity

Conditions	2
Paths	3

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	2

Importance

Changes

Metric	Value
dl	0
loc	12
ccs	8
cts	8
cp	1
rs	9.8666
c	0
b	0
f	0
cc	2
nc	3
nop	1
crap	2

<?php


namespace Broadway\Tools\Command;


use Broadway\CommandHandling\CommandBus;
use Broadway\CommandHandling\CommandHandler;
use Exception;
use Psr\Log\LoggerInterface;
use RemiSan\TransactionManager\TransactionManager;
use Throwable;

class TransactionalCommandBus
{
    /** @var CommandBus */
    private $decorated;
    /** @var TransactionManager */
    private $transactionManager;
    /** @var LoggerInterface */
    private $logger;

    public function __construct(CommandBus $bus, TransactionManager $transactionManager, LoggerInterface $logger)
    {
        $this->decorated = $bus;
        $this->transactionManager = $transactionManager;
        $this->logger = $logger;
    }

    /**
     * @param mixed $command
     *
     * @throws Throwable
     */
    public function dispatch($command)
    {
        $this->transactionManager->beginTransaction();

        try {
            $this->decorated->dispatch($command);
            $this->transactionManager->commit();
        } catch (Exception $exception) {
            $this->rollback($exception);
            throw $exception;
        }
    }

    /**
     * @param CommandHandler $handler
     */
    public function subscribe(CommandHandler $handler)
    {
        $this->decorated->subscribe($handler);
    }

    /**
     * @param $exception
     *
     * @throws Exception
     */
    private function rollback($exception)
    {
        try {
            $this->transactionManager->rollback();
        } catch (Exception $rollbackException) {
            $this->logger->critical($exception);
            throw $rollbackException;
        }
    }
}

1		<?php
2
3
4		namespace Broadway\Tools\Command;
5
6
7		use Broadway\CommandHandling\CommandBus;
8		use Broadway\CommandHandling\CommandHandler;
9		use Exception;
10		use Psr\Log\LoggerInterface;
11		use RemiSan\TransactionManager\TransactionManager;
12		use Throwable;
13
14		class TransactionalCommandBus
15		{
16		/** @var CommandBus */
17		private $decorated;
18		/** @var TransactionManager */
19		private $transactionManager;
20		/** @var LoggerInterface */
21		private $logger;
22
23	12	public function __construct(CommandBus $bus, TransactionManager $transactionManager, LoggerInterface $logger)
24		{
25	12	$this->decorated = $bus;
26	12	$this->transactionManager = $transactionManager;
27	12	$this->logger = $logger;
28	12	}
29
30		/**
31		* @param mixed $command
32		*
33		* @throws Throwable
34		*/
35	9	public function dispatch($command)
36		{
37	9	$this->transactionManager->beginTransaction();
38
39		try {
40	9	$this->decorated->dispatch($command);
41	3	$this->transactionManager->commit();
42	8	} catch (Exception $exception) {
43	6	$this->rollback($exception);
44	3	throw $exception;
45		}
46	3	}
47
48		/**
49		* @param CommandHandler $handler
50		*/
51	3	public function subscribe(CommandHandler $handler)
52		{
53	3	$this->decorated->subscribe($handler);
54	3	}
55
56		/**
57		* @param $exception
58		*
59		* @throws Exception
60		*/
61	6	private function rollback($exception)
62		{
63		try {
64	6	$this->transactionManager->rollback();
65	5	} catch (Exception $rollbackException) {
66	3	$this->logger->critical($exception);
67	3	throw $rollbackException;
68		}
69		}
70		}

remi-san / broadway-tools

GitHub Access Token became invalid

Pull Request — master (#2)

TransactionalCommandBus::dispatch() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like