Chief\Decorators\LoggingDecorator

Complexity

Total Complexity

7

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	execute()	0	17	2
A	log()	0	5	2
A	createExceptionString()	0	5	1

<?php

namespace Chief\Decorators;

use Chief\Busses\SynchronousCommandBus;
use Chief\Command;
use Chief\CommandBus;
use Chief\Decorator;
use Psr\Log\LoggerInterface;

class LoggingDecorator implements Decorator
{
    use InnerBusTrait;
    /**
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * @var mixed|null
     */
    protected $context;

    /**
     * @param LoggerInterface $logger
     * @param mixed $context Something which is serializable that will be logged with
     * the command execution, such as the request/session information.
     * @param CommandBus $innerCommandBus
     */
    public function __construct(LoggerInterface $logger, $context = null, CommandBus $innerCommandBus = null)
    {
        $this->logger = $logger;
        $this->context = $context;
        $this->setInnerBus($innerCommandBus ?: new SynchronousCommandBus());
    }

    /**
     * Execute a command
     *
     * @param Command $command
     * @throws \Exception
     * @return mixed
     */
    public function execute(Command $command)
    {
        $this->log('Executing command [' . get_class($command) . ']', $command);

        try {
            $response = $this->innerCommandBus->execute($command);
        } catch (\Exception $e) {

            $message = 'Failed executing command [' . get_class($command) . ']. ' . $this->createExceptionString($e);
            $this->log($message, $command);
            throw $e;
        }

        $this->log('Successfully executed command [' . get_class($command) . ']', $command);

        return $response;
    }

    protected function log($message, $command)
    {
        $context = $this->context ? serialize($this->context) : null;
        $this->logger->debug($message, ['Command' => serialize($command), 'Context' => $context]);
    }

    protected function createExceptionString(\Exception $e)
    {
        return 'Uncaught ' . get_class($e) . '[' . $e->getMessage() . '] throw in ' . $e->getFile() .
        ' on line ' . $e->getLine() . '. Stack trace: ' . $e->getTraceAsString();
    }
}