App\SharedKernel\Infrastructure\Messenger\Middleware\AuditMiddleware

Complexity

Total Complexity

4

Size/Duplication

Total Lines	29
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	15	2
A	receivedVariableName()	0	3	1
A	__construct()	0	3	1

<?php

declare(strict_types=1);

namespace App\SharedKernel\Infrastructure\Messenger\Middleware;

use Psr\Log\LoggerInterface;

The type Psr\Log\LoggerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Messenger\Envelope;

The type Symfony\Component\Messenger\Envelope was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Messenger\Middleware\MiddlewareInterface;

The type Symfony\Component\Messenger\Middleware\MiddlewareInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Symfony\Component\Messenger\Middleware\StackInterface;

The type Symfony\Component\Messenger\Middleware\StackInterface was not found. Maybe you did not declare it correctly or list all dependencies?

final class AuditMiddleware implements MiddlewareInterface
{
    private LoggerInterface $logger;

    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        $message = $envelope->getMessage();
        $className = get_class($message);

        $body = [];
        foreach ((array) $message as $key => $value) {
            $body[$this->receivedVariableName($key, $className)] = $value;
        }

        $this->logger->info(sprintf('Received & handling %s', $className), $body);

        $next = $stack->next();

        return $next->handle($envelope, $stack);
    }

    private function receivedVariableName(string $name, string $class): string
    {
        return (string) preg_replace('/[\x00-\x1F\x7F]/', '', str_replace($class, '', $name));
    }
}