Flow2Lab/EventSourcing

<?php
namespace Flow2Lab\EventSourcing\Auditing;

use Flow2Lab\EventSourcing\Command\Command;
use Flow2Lab\EventSourcing\Command\Handler\CommandHandlerInterface;
use Flow2Lab\EventSourcing\Domain\Model\ObjectName;
use Flow2Lab\EventSourcing\Serializer\ArraySerializer;
use TYPO3\Flow\Annotations as Flow;

/**
 * Command Auditing
 */
class CommandLogger
{

    /**
     * @var LoggerInterface
     * @Flow\Inject
     */
    protected $logger;

    /**
     * @var ArraySerializer
     * @Flow\Inject
     */
    protected $commandSerializer;

    /**
     * @param Command $command
     * @param CommandHandlerInterface $commandHandler
     * @return void
     */
    public function onCommandHandlingSuccess(Command $command, CommandHandlerInterface $commandHandler)
    {
        $commandHandlerType = new ObjectName($commandHandler);
        $additionalData = [
            'status' => 'success',
            'type' => 'command',
            'handlerType' => $commandHandlerType->getName(),
            'command' => $this->getCommandData($command)
        ];

        $this->logger->log(sprintf('%s handling success', $command), LOG_INFO, $additionalData, 'ES.Command');
    }

    /**
     * @param Command $command
     * @param CommandHandlerInterface $commandHandler
     * @param \Exception $exception
     * @return void
     */
    public function onCommandHandlingFailure(Command $command, CommandHandlerInterface $commandHandler, \Exception $exception)
    {
        $commandHandlerType = new ObjectName($commandHandler);
        $additionalData = [
            'status' => 'failure',
            'type' => 'command',
            'handlerType' => $commandHandlerType->getName(),
            'command' => $this->getCommandData($command),
            'exception' => [
                'message' => $exception->getMessage(),
                'file' => $exception->getFile(),
                'class' => get_class($exception),
                'line' => $exception->getLine(),
                'code' => $exception->getCode()
            ]
        ];

        $this->logger->log(sprintf('%s handling failure', $command), LOG_ERR, $additionalData, 'ES.Command');
    }

    /**
     * @param Command $command
     * @return array
     */
    protected function getCommandData(Command $command)
    {
        return $this->commandSerializer->serialize($command);
    }

}