Clearcode\SimpleBusElkBundle\CommandBus\LogEventMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	2
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	handle()	0	10	2

<?php

namespace Clearcode\SimpleBusElkBundle\CommandBus;

use Clearcode\SimpleBusElkBundle\Logstash\CannotWriteToLogstash;
use Clearcode\SimpleBusElkBundle\Logstash\Logstash;
use Psr\Log\LoggerInterface;
use SimpleBus\Message\Bus\Middleware\MessageBusMiddleware;

class LogEventMiddleware implements MessageBusMiddleware
{
    /** @var Logstash */
    private $logstash;
    /** @var LoggerInterface */
    private $logger;

    /**
     * @param Logstash        $logstash
     * @param LoggerInterface $logger
     */
    public function __construct(Logstash $logstash, LoggerInterface $logger)
    {
        $this->logstash = $logstash;
        $this->logger   = $logger;
    }

    /**
     * {@inheritdoc}
     */
    public function handle($message, callable $next)
    {
        try {
            $this->logstash->write($message);
        } catch (CannotWriteToLogstash $e) {
            $this->logger->error($e->getMessage());
        }

        $next($message);
    }
}