GuzzleCollector::collect() - Code Metrics - Inspection of "wip guzzle logger" - ozo2003/HelperBundle - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 654348...8ec1ee )

by Dāvis

created 2017-10-23 19:40 UTC

GuzzleCollector::collect() C

↳ Parent: GuzzleCollector

Complexity

Conditions	9
Paths	21

Size

Total Lines	63
Code Lines	37

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	9
eloc	37
nc	21
nop	3
dl	0
loc	63
rs	6.6149
c	0
b	0
f	0

How to fix Long Method

<?php

namespace Sludio\HelperBundle\Guzzle\DataCollector;

use Sludio\HelperBundle\Guzzle\GuzzleHttp\History\History;
use Sludio\HelperBundle\Guzzle\GuzzleHttp\Middleware\CacheMiddleware;
use Sludio\HelperBundle\Guzzle\GuzzleHttp\Middleware\MockMiddleware;
use GuzzleHttp\Exception\RequestException;
use Psr\Http\Message\StreamInterface;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\DataCollector\DataCollector;

class GuzzleCollector extends DataCollector
{
    const MAX_BODY_SIZE = 0x10000;

    private $maxBodySize;
    private $history;
    private $curlFormatter = null;

    /**
     * Constructor.
     *
     * @param int $maxBodySize The max body size to store in the profiler storage
     */
    public function __construct($maxBodySize = self::MAX_BODY_SIZE, History $history = null)
    {
        $this->maxBodySize = $maxBodySize;
        $this->history = $history ?: new History();

        if (class_exists(\Namshi\Cuzzle\Formatter\CurlFormatter::class)) {
            $this->curlFormatter = new \Namshi\Cuzzle\Formatter\CurlFormatter();
        }

        $this->data = [];
    }

    /**
     * {@inheritdoc}
     */
    public function collect(Request $request, Response $response, \Exception $exception = null)
    {
        $data = [];

        foreach ($this->history as $request) {
            /* @var \Psr\Http\Message\RequestInterface $request */
            $transaction = $this->history[$request];
            /* @var \Psr\Http\Message\ResponseInterface $response */
            $response = $transaction['response'];
            /* @var \Exception $error */
            $error = $transaction['error'];
            /* @var array $info */
            $info = $transaction['info'];

            $req = [
                'request' => [
                    'method' => $request->getMethod(),
                    'version' => $request->getProtocolVersion(),
                    'headers' => $request->getHeaders(),
                    'body' => $this->cropContent($request->getBody()),
                ],
                'info' => $info,
                'uri' => urldecode($request->getUri()),
                'httpCode' => 0,
                'error' => null,
            ];

            if ($this->curlFormatter && $request->getBody()->getSize() <= $this->maxBodySize) {
                $req['curl'] = $this->curlFormatter->format($request);
            }

            if ($response) {
                $req['response'] = [
                    'reasonPhrase' => $response->getReasonPhrase(),
                    'headers' => $response->getHeaders(),
                    'body' => $this->cropContent($response->getBody()),
                ];

                $req['httpCode'] = $response->getStatusCode();

                if ($response->hasHeader(CacheMiddleware::DEBUG_HEADER)) {
                    $req['cache'] = $response->getHeaderLine(CacheMiddleware::DEBUG_HEADER);
                }

                if ($response->hasHeader(MockMiddleware::DEBUG_HEADER)) {
                    $req['mock'] = $response->getHeaderLine(MockMiddleware::DEBUG_HEADER);
                }
            }

            if ($error && $error instanceof RequestException) {
                $req['error'] = [
                    'message' => $error->getMessage(),
                    'line' => $error->getLine(),
                    'file' => $error->getFile(),
                    'code' => $error->getCode(),
                    'trace' => $error->getTraceAsString(),
                ];
            }

            $data[] = $req;
        }

        $this->data = $data;
    }

    private function cropContent(StreamInterface $stream = null)
    {
        if (null === $stream) {
            return '';
        }

        if ($stream->getSize() <= $this->maxBodySize) {
            return (string)$stream;
        }

        $stream->seek(0);

        return '(partial content)'.$stream->read($this->maxBodySize).'(...)';
    }

    public function getErrors()
    {
        return array_filter($this->data, function($call) {
            return 0 === $call['httpCode'] || $call['httpCode'] >= 400;
        });
    }

    public function getTotalTime()
    {
        return array_sum(array_map(function($call) {
                return isset($call['info']['total_time']) ? $call['info']['total_time'] : 0;
            }, $this->data));
    }

    public function getCalls()
    {
        return $this->data;
    }

    /**
     * {@inheritdoc}
     */
    public function getName()
    {
        return 'guzzle';
    }
}

1			<?php
2
3			namespace Sludio\HelperBundle\Guzzle\DataCollector;
4
5			use Sludio\HelperBundle\Guzzle\GuzzleHttp\History\History;
6			use Sludio\HelperBundle\Guzzle\GuzzleHttp\Middleware\CacheMiddleware;
7			use Sludio\HelperBundle\Guzzle\GuzzleHttp\Middleware\MockMiddleware;
8			use GuzzleHttp\Exception\RequestException;
9			use Psr\Http\Message\StreamInterface;
10			use Symfony\Component\HttpFoundation\Request;
11			use Symfony\Component\HttpFoundation\Response;
12			use Symfony\Component\HttpKernel\DataCollector\DataCollector;
13
14			class GuzzleCollector extends DataCollector
15			{
16			const MAX_BODY_SIZE = 0x10000;
17
18			private $maxBodySize;
19			private $history;
20			private $curlFormatter = null;
21
22			/**
23			* Constructor.
24			*
25			* @param int $maxBodySize The max body size to store in the profiler storage
26			*/
27			public function __construct($maxBodySize = self::MAX_BODY_SIZE, History $history = null)
28			{
29			$this->maxBodySize = $maxBodySize;
30			$this->history = $history ?: new History();
31
32			if (class_exists(\Namshi\Cuzzle\Formatter\CurlFormatter::class)) {
33			$this->curlFormatter = new \Namshi\Cuzzle\Formatter\CurlFormatter();
34			}
35
36			$this->data = [];
37			}
38
39			/**
40			* {@inheritdoc}
41			*/
42			public function collect(Request $request, Response $response, \Exception $exception = null)
43			{
44			$data = [];
45
46			foreach ($this->history as $request) {
47			/* @var \Psr\Http\Message\RequestInterface $request */
48			$transaction = $this->history[$request];
49			/* @var \Psr\Http\Message\ResponseInterface $response */
50			$response = $transaction['response'];
51			/* @var \Exception $error */
52			$error = $transaction['error'];
53			/* @var array $info */
54			$info = $transaction['info'];
55
56			$req = [
57			'request' => [
58			'method' => $request->getMethod(),
59			'version' => $request->getProtocolVersion(),
60			'headers' => $request->getHeaders(),
61			'body' => $this->cropContent($request->getBody()),
62			],
63			'info' => $info,
64			'uri' => urldecode($request->getUri()),
65			'httpCode' => 0,
66			'error' => null,
67			];
68
69			if ($this->curlFormatter && $request->getBody()->getSize() <= $this->maxBodySize) {
70			$req['curl'] = $this->curlFormatter->format($request);
71			}
72
73			if ($response) {
74			$req['response'] = [
75			'reasonPhrase' => $response->getReasonPhrase(),
76			'headers' => $response->getHeaders(),
77			'body' => $this->cropContent($response->getBody()),
78			];
79
80			$req['httpCode'] = $response->getStatusCode();
81
82			if ($response->hasHeader(CacheMiddleware::DEBUG_HEADER)) {
83			$req['cache'] = $response->getHeaderLine(CacheMiddleware::DEBUG_HEADER);
84			}
85
86			if ($response->hasHeader(MockMiddleware::DEBUG_HEADER)) {
87			$req['mock'] = $response->getHeaderLine(MockMiddleware::DEBUG_HEADER);
88			}
89			}
90
91			if ($error && $error instanceof RequestException) {
92			$req['error'] = [
93			'message' => $error->getMessage(),
94			'line' => $error->getLine(),
95			'file' => $error->getFile(),
96			'code' => $error->getCode(),
97			'trace' => $error->getTraceAsString(),
98			];
99			}
100
101			$data[] = $req;
102			}
103
104			$this->data = $data;
105			}
106
107			private function cropContent(StreamInterface $stream = null)
108			{
109			if (null === $stream) {
110			return '';
111			}
112
113			if ($stream->getSize() <= $this->maxBodySize) {
114			return (string)$stream;
115			}
116
117			$stream->seek(0);
118
119			return '(partial content)'.$stream->read($this->maxBodySize).'(...)';
120			}
121
122			public function getErrors()
123			{
124			return array_filter($this->data, function($call) {
125			return 0 === $call['httpCode'] \|\| $call['httpCode'] >= 400;
126			});
127			}
128
129			public function getTotalTime()
130			{
131			return array_sum(array_map(function($call) {
132			return isset($call['info']['total_time']) ? $call['info']['total_time'] : 0;
133			}, $this->data));
134			}
135
136			public function getCalls()
137			{
138			return $this->data;
139			}
140
141			/**
142			* {@inheritdoc}
143			*/
144			public function getName()
145			{
146			return 'guzzle';
147			}
148			}

ozo2003 / HelperBundle

Push — master ( 654348...8ec1ee )

GuzzleCollector::collect() C

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like