App\Middleware\AccessLoggerMiddleware

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	process()	0	19	3
A	getEmail()	0	3	1
A	getClientIp()	0	7	2

<?php

declare(strict_types=1);

namespace App\Middleware;

use App\Infra\Log\AccessLogger;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;

class AccessLoggerMiddleware implements MiddlewareInterface
{
    /**
     * @var AccessLogger
     */
    private $accessLogger;

    public function __construct(AccessLogger $accessLogger)
    {
        $this->accessLogger = $accessLogger;
    }

    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $response = $handler->handle($request);

        $ip = $this->getClientIp($request);
        $email = $this->getEmail($request);

        try {
            $this->accessLogger->log(
                $response->getStatusCode() === 200 ? AccessLogger::TYPE_LOGIN_SUCCESS :
				AccessLogger::TYPE_LOGIN_FAILURE,
                $email,
                $ip
            );
        } catch (\Throwable $e) {
            // Discard any error
            error_log('AccessLoggerMiddleware failure' . $e->getMessage());
        } finally {
            return $response;
        }
    }

    private function getEmail(ServerRequestInterface $request): string {
		$body = $request->getParsedBody();
		return trim($body['email'] ?? '');
	}

    private function getClientIp(ServerRequestInterface $request): ?string
    {
        $serverParams = $request->getServerParams();
        if (isset($serverParams['REMOTE_ADDR'])) {
            return $serverParams['REMOTE_ADDR'];
        }
        return null;
    }
}