NilPortugues\MessageBus\QueryBus\LoggerQueryBusMiddleware

Complexity

Total Complexity

7

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__invoke()	0	18	3
A	preQueryLog()	0	4	1
A	postQueryLog()	0	4	1
A	logException()	0	4	1

<?php

namespace NilPortugues\MessageBus\QueryBus;

use Exception;
use NilPortugues\MessageBus\QueryBus\Contracts\Query;
use NilPortugues\MessageBus\QueryBus\Contracts\QueryBusMiddleware as QueryBusMiddlewareInterface;
use NilPortugues\MessageBus\QueryBus\Contracts\QueryResponse;
use Psr\Log\LoggerInterface;

class LoggerQueryBusMiddleware implements QueryBusMiddlewareInterface
{
    /** @var LoggerInterface */
    protected $logger;

    /**
     * LoggerQueryBus constructor.
     *
     * @param LoggerInterface $logger
     */
    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    /**
     * @param Query         $query
     * @param callable|null $next
     *
     * @return QueryResponse
     *
     * @throws Exception
     */
    public function __invoke(Query $query, callable $next = null) : QueryResponse
    {
        $response = EmptyResponse::create();

        try {
            if (null !== $next) {
                $this->preQueryLog($query);
                $response = $next($query);
                $this->postQueryLog($query);

                return $response;
            }
        } catch (Exception $e) {
            $this->logException($e);
        }

        return $response;
    }

    /**
     * @param Query $query
     */
    protected function preQueryLog(Query $query)
    {
        $this->logger->info(sprintf('Starting %s handling.', get_class($query)));
    }

    /**
     * @param Query $query
     */
    protected function postQueryLog(Query $query)
    {
        $this->logger->info(sprintf('%s was handled successfully.', get_class($query)));
    }

    /**
     * @param Exception $e
     */
    protected function logException(Exception $e)
    {
        $this->logger->alert(sprintf('[%s:%s] %s', $e->getFile(), $e->getLine(), $e->getMessage()));
    }
}