RemotelyLiving\PHPQueryBus\Middleware\ResultErrorLogger

Complexity

Total Complexity

4

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	formatErrorContext()	0	14	2
A	__invoke()	0	10	2

<?php

declare(strict_types=1);

namespace RemotelyLiving\PHPQueryBus\Middleware;

use Psr\Log;
use RemotelyLiving\PHPQueryBus\Interfaces;
use RemotelyLiving\PHPQueryBus\Traits;

final class ResultErrorLogger implements Log\LoggerAwareInterface
{
    use Traits\Logger;

    public function __invoke(object $query, callable $next): Interfaces\Result
    {
        /** @var \RemotelyLiving\PHPQueryBus\Interfaces\Result $result */
        $result = $next($query);

        if ($result->hasErrors()) {
            $this->getLogger()->error('Query bus result fetched with errors', $this->formatErrorContext($result));
        }

        return $result;
    }

    private function formatErrorContext(Interfaces\Result $result): array
    {
        $errorContext = [];
        foreach ($result->getErrors() as $error) {
            $errorContext[] = [
                'ExceptionClass' => get_class($error),
                'Message' => $error->getMessage(),
                'Line' => $error->getLine(),
                'File' => $error->getFile(),
                'Trace' => $error->getTraceAsString(),
            ];
        }

        return $errorContext;
    }
}