MultiJsonStream::__construct() - Code Metrics - stage1/docker-php - Measure and Improve Code Quality continuously with Scrutinizer

MultiJsonStream::__construct() A
last analyzed 2016-01-29 12:26 UTC

↳ Parent: MultiJsonStream

Complexity

Conditions	1
Paths	1

Size

Total Lines	6
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
cc	1
eloc	3
c	1
b	0
f	1
nc	1
nop	2
dl	0
loc	6
ccs	4
cts	4
cp	1
crap	1
rs	9.4285

<?php

namespace Docker\Stream;
use Psr\Http\Message\StreamInterface;
use Symfony\Component\Serializer\SerializerInterface;

/**
 * Represent a stream that decode a stream with multiple json in it
 */
abstract class MultiJsonStream extends CallbackStream
{
    /** @var SerializerInterface Serializer to decode incoming json object */
    private $serializer;

    public function __construct(StreamInterface $stream, SerializerInterface $serializer)
    {
        parent::__construct($stream);

        $this->serializer = $serializer;
    }

    /**
     * {@inheritdoc}
     */
    protected function readFrame()
    {
        $jsonFrameEnd = false;
        $lastJsonChar = '';
        $inquote      = false;
        $jsonFrame    = "";
        $level        = 0;

        while (!$jsonFrameEnd && !$this->stream->eof()) {
            $jsonChar   = $this->stream->read(1);

            if ((boolean)($jsonChar == '"' && $lastJsonChar != '\\')) {
                $inquote = !$inquote;
            }

            if (!$inquote && in_array($jsonChar, [" ", "\r", "\n", "\t"])) {
                continue;
            }

            if (!$inquote && in_array($jsonChar, ['{', '['])) {
                $level++;
            }

            if (!$inquote && in_array($jsonChar, ['}', ']'])) {
                $level--;

                if ($level == 0) {
                    $jsonFrameEnd = true;
                    $jsonFrame .= $jsonChar;

                    continue;
                }
            }

            $jsonFrame .= $jsonChar;
        }

        // Invalid last json, or timeout, or connection close before receiving
        if (!$jsonFrameEnd) {
            return null;
        }

        return $this->serializer->deserialize($jsonFrame, $this->getDecodeClass(), 'json');
    }

    /**
     * Get the decode class to pass to serializer
     *
     * @return string
     */
    abstract protected function getDecodeClass();
}


1		<?php
2
3		namespace Docker\Stream;
4		use Psr\Http\Message\StreamInterface;
5		use Symfony\Component\Serializer\SerializerInterface;
6
7		/**
8		* Represent a stream that decode a stream with multiple json in it
9		*/
10		abstract class MultiJsonStream extends CallbackStream
11		{
12		/** @var SerializerInterface Serializer to decode incoming json object */
13		private $serializer;
14
15	8	public function __construct(StreamInterface $stream, SerializerInterface $serializer)
16		{
17	8	parent::__construct($stream);
18
19	8	$this->serializer = $serializer;
20	8	}
21
22		/**
23		* {@inheritdoc}
24		*/
25	8	protected function readFrame()
26		{
27	8	$jsonFrameEnd = false;
28	8	$lastJsonChar = '';
29	8	$inquote = false;
30	8	$jsonFrame = "";
31	8	$level = 0;
32
33	8	while (!$jsonFrameEnd && !$this->stream->eof()) {
34	8	$jsonChar = $this->stream->read(1);
35
36	8	if ((boolean)($jsonChar == '"' && $lastJsonChar != '\\')) {
37	8	$inquote = !$inquote;
38	8	}
39
40	8	if (!$inquote && in_array($jsonChar, [" ", "\r", "\n", "\t"])) {
41	8	continue;
42		}
43
44	8	if (!$inquote && in_array($jsonChar, ['{', '['])) {
45	8	$level++;
46	8	}
47
48	8	if (!$inquote && in_array($jsonChar, ['}', ']'])) {
49	8	$level--;
50
51	8	if ($level == 0) {
52	8	$jsonFrameEnd = true;
53	8	$jsonFrame .= $jsonChar;
54
55	8	continue;
56		}
57	6	}
58
59	8	$jsonFrame .= $jsonChar;
60	8	}
61
62		// Invalid last json, or timeout, or connection close before receiving
63	8	if (!$jsonFrameEnd) {
64	8	return null;
65		}
66
67	8	return $this->serializer->deserialize($jsonFrame, $this->getDecodeClass(), 'json');
68		}
69
70		/**
71		* Get the decode class to pass to serializer
72		*
73		* @return string
74		*/
75		abstract protected function getDecodeClass();
76		}
77

stage1 / docker-php

MultiJsonStream::__construct() A last analyzed 2016-01-29 12:26 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MultiJsonStream::__construct() A
last analyzed 2016-01-29 12:26 UTC