Yiisoft\Yii\Debug\Collector\Web\RequestCollector

Complexity

Total Complexity

15

Size/Duplication

Total Lines	111
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	reset()	0	9	1
A	collect()	0	22	6
B	getCollected()	0	43	7
A	getSummary()	0	13	1

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\Collector\Web;

use GuzzleHttp\Psr7\Message;
use JsonException;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Yiisoft\Yii\Http\Event\AfterRequest;
use Yiisoft\Yii\Http\Event\BeforeRequest;
use Yiisoft\Yii\Debug\Collector\CollectorTrait;
use Yiisoft\Yii\Debug\Collector\SummaryCollectorInterface;

use function is_object;

final class RequestCollector implements SummaryCollectorInterface
{
    use CollectorTrait;

    private string $requestUrl = '';
    private string $requestPath = '';
    private string $requestQuery = '';
    private string $requestMethod = '';
    private bool $requestIsAjax = false;
    private ?string $userIp = null;
    private int $responseStatusCode = 200;
    private ?ServerRequestInterface $request = null;
    private ?ResponseInterface $response = null;

    public function getCollected(): array
    {
        $content = null;
        if ($this->response !== null) {
            $stream = $this->response->getBody();
            if ($stream->isReadable() && $stream->isSeekable()) {
                $position = $stream->tell();
                $stream->rewind();
                $content = $stream->getContents();
                try {
                    $content = json_decode($content, associative: true, flags: JSON_THROW_ON_ERROR);
                } catch (JsonException) {
                    // pass
                }
                $stream->seek($position);
            }
        }

        $requestRaw = null;
        if ($this->request instanceof ServerRequestInterface) {
            $requestRaw = Message::toString($this->request);
            Message::rewindBody($this->request);
        }

        $responseRaw = null;
        if ($this->response instanceof ResponseInterface) {
            $responseRaw = Message::toString($this->response);
            Message::rewindBody($this->response);
        }

        return [
            'requestUrl' => $this->requestUrl,
            'requestPath' => $this->requestPath,
            'requestQuery' => $this->requestQuery,
            'requestMethod' => $this->requestMethod,
            'requestIsAjax' => $this->requestIsAjax,
            'userIp' => $this->userIp,
            'responseStatusCode' => $this->responseStatusCode,
            'request' => $this->request,
            'requestRaw' => $requestRaw,
            'response' => $this->response,
            'responseRaw' => $responseRaw,
            'content' => $content,
        ];
    }

    public function collect(object $event): void
    {
        if (!is_object($event) || !$this->isActive()) {
            return;
        }

        if ($event instanceof BeforeRequest) {
            $request = $event->getRequest();

            $this->request = $request;
            $this->requestUrl = (string) $request->getUri();
            $this->requestPath = $request->getUri()->getPath();
            $this->requestQuery = $request->getUri()->getQuery();
            $this->requestMethod = $request->getMethod();
            $this->requestIsAjax = strtolower($request->getHeaderLine('X-Requested-With')) === 'xmlhttprequest';
            $this->userIp = $request->getServerParams()['REMOTE_ADDR'] ?? null;
        }
        if ($event instanceof AfterRequest) {
            $response = $event->getResponse();

            $this->response = $response;
            $this->responseStatusCode = $response !== null ? $response->getStatusCode() : 500;
        }
    }

    public function getSummary(): array
    {
        return [
            'request' => [
                'url' => $this->requestUrl,
                'path' => $this->requestPath,
                'query' => $this->requestQuery,
                'method' => $this->requestMethod,
                'isAjax' => $this->requestIsAjax,
                'userIp' => $this->userIp,
            ],
            'response' => [
                'statusCode' => $this->responseStatusCode,
            ],
        ];
    }

    private function reset(): void

The method reset() is not used, and could be removed.

    {
        $this->request = null;
        $this->response = null;
        $this->requestUrl = '';
        $this->requestMethod = '';
        $this->requestIsAjax = false;
        $this->userIp = null;
        $this->responseStatusCode = 200;
    }
}