CommitsObjectManagerTransaction::handle() - Code Metrics - hmlb/ddd-bundle - Measure and Improve Code Quality continuously with Scrutinizer

CommitsObjectManagerTransaction::handle() A
last analyzed 2016-09-02 17:10 UTC

↳ Parent: CommitsObjectManagerTransaction

Complexity

Conditions	3
Paths	1

Size

Total Lines	20
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Importance

Changes	4
Bugs	1	Features	0

Metric	Value
dl	0
loc	20
rs	9.4285
c	4
b	1
f	0
cc	3
eloc	11
nc	1
nop	2

<?php

declare (strict_types = 1);

namespace HMLB\DDDBundle\MessageBus\Middleware;

use Doctrine\Common\Persistence\ObjectManager;
use HMLB\DDD\Message\Message;
use Psr\Log\LoggerInterface;
use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;
use SimpleBus\Message\Name\NamedMessage;

/**
 * Commits Object Manager transaction for persisted domain models.
 *
 * @author Hugues Maignol <[email protected]>
 */
class CommitsObjectManagerTransaction implements MessageBusMiddleware
{
    /**
     * @var ObjectManager
     */
    private $om;

    /**
     * @var LoggerInterface
     */
    private $logger;

    public function __construct(LoggerInterface $logger, ObjectManager $om)
    {
        $this->logger = $logger;
        $this->om = $om;
    }

    /**
     * @param Message  $message
     * @param callable $next
     */
    public function handle($message, callable $next)
    {
        $next($message);

        $this->logger->debug(
            sprintf(
                'CommitsObjectManagerTransaction flushes Object manager after handling command "%s"',
                $message instanceof NamedMessage ? $message::messageName() : get_class($message)
            )
        );

        $this->om->flush();

        $this->logger->debug(
            sprintf(
                'CommitsObjectManagerTransaction finished handling "%s"',
                $message instanceof NamedMessage ? $message::messageName() : get_class($message)
            )
        );
    }
}


1			<?php
2
3			declare (strict_types = 1);
4
5			namespace HMLB\DDDBundle\MessageBus\Middleware;
6
7			use Doctrine\Common\Persistence\ObjectManager;
8			use HMLB\DDD\Message\Message;
9			use Psr\Log\LoggerInterface;
10			use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;
11			use SimpleBus\Message\Name\NamedMessage;
12
13			/**
14			* Commits Object Manager transaction for persisted domain models.
15			*
16			* @author Hugues Maignol <[email protected]>
17			*/
18			class CommitsObjectManagerTransaction implements MessageBusMiddleware
19			{
20			/**
21			* @var ObjectManager
22			*/
23			private $om;
24
25			/**
26			* @var LoggerInterface
27			*/
28			private $logger;
29
30			public function __construct(LoggerInterface $logger, ObjectManager $om)
31			{
32			$this->logger = $logger;
33			$this->om = $om;
34			}
35
36			/**
37			* @param Message $message
38			* @param callable $next
39			*/
40			public function handle($message, callable $next)
41			{
42			$next($message);
43
44			$this->logger->debug(
45			sprintf(
46			'CommitsObjectManagerTransaction flushes Object manager after handling command "%s"',
47			$message instanceof NamedMessage ? $message::messageName() : get_class($message)
48			)
49			);
50
51			$this->om->flush();
52
53			$this->logger->debug(
54			sprintf(
55			'CommitsObjectManagerTransaction finished handling "%s"',
56			$message instanceof NamedMessage ? $message::messageName() : get_class($message)
57			)
58			);
59			}
60			}
61

hmlb / ddd-bundle

CommitsObjectManagerTransaction::handle() A last analyzed 2016-09-02 17:10 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

CommitsObjectManagerTransaction::handle() A
last analyzed 2016-09-02 17:10 UTC