StreamHandler::processLine() - Code Metrics - Inspection of "Added test" - mpyw/cowitter - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 3cf178...59e65f )

by Ryosuke

created 2016-08-16 08:05 UTC

StreamHandler::processLine() B

↳ Parent: StreamHandler

Complexity

Conditions	6
Paths	5

Size

Total Lines	19
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	15
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
c	1
b	0
f	1
dl	0
loc	19
ccs	15
cts	15
cp	1
rs	8.8571
cc	6
eloc	12
nc	5
nop	2
crap	6

<?php

namespace mpyw\Cowitter\Components;

use mpyw\Co\Co;
use mpyw\Cowitter\Response;
use mpyw\Cowitter\Helpers\ResponseBodyDecoder;

class StreamHandler
{
    protected $headerResponse;
    protected $headerResponseBuffer = '';
    protected $headerResponseHandler;
    protected $eventBuffer = '';
    protected $eventHandler;
    protected $haltedByUser = false;

    public function __construct(callable $header_response_handler = null, callable $event_handler = null)
    {
        $this->headerResponseHandler = $header_response_handler;
        $this->eventHandler          = $event_handler;
    }

    public function headerFunction($ch, $str)
    {
        $handle = $this->headerResponseHandler;
        $this->headerResponseBuffer .= $str;
        if (substr($this->headerResponseBuffer, -4) === "\r\n\r\n") {
            $this->headerResponse = new Response($this->headerResponseBuffer, $ch);
            if ($handle) {
                (new \ReflectionFunction($handle))->isGenerator()
abstract class User
{
    /** @return string */
    abstract public function getPassword();
}

class MyUser extends User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}
                ? Co::async($handle($this->headerResponse))
                : $handle($this->headerResponse);
            }
        }
        return strlen($str);
    }

    protected function processLine($ch, $line)
    {
        $handle = $this->eventHandler;
        if ('' === $line = rtrim($line)) {
            return;
        }
        $event = ResponseBodyDecoder::getDecodedResponse($this->headerResponse, $ch, $line);
        if ($handle) {
            if ((new \ReflectionFunction($handle))->isGenerator()) {
                Co::async(function () use ($handle, $event) {
                    if (false === (yield $handle($event->getContent()))) {
                        $this->haltedByUser = true;
                    }
                });
            } elseif (false === $handle($event->getContent())) {
                $this->haltedByUser = true;
            }
        }
    }

    public function writeFunction($ch, $str)
    {
        if ($this->haltedByUser) {
            // @codeCoverageIgnoreStart
            return 0;
            // @codeCoverageIgnoreEnd
        }
        $this->eventBuffer .= $str;
        if (200 !== $code = curl_getinfo($ch, CURLINFO_HTTP_CODE)) {
            ResponseBodyDecoder::getDecodedResponse($this->headerResponse, $ch, $this->eventBuffer);
            throw new \UnexpectedValueException('Unexpected response: ' . $this->eventBuffer);
        }
        while (false !== $pos = strpos($this->eventBuffer, "\n")) {
            $line = substr($this->eventBuffer, 0, $pos + 1);
            $this->eventBuffer = substr($this->eventBuffer, $pos + 1);
            $this->processLine($ch, $line);
            if ($this->haltedByUser) {
                return 0;
            }
        }
        return strlen($str);
    }

    public function isHaltedByUser()
    {
        return $this->haltedByUser;
    }
}


1		<?php
2
3		namespace mpyw\Cowitter\Components;
4
5		use mpyw\Co\Co;
6		use mpyw\Cowitter\Response;
7		use mpyw\Cowitter\Helpers\ResponseBodyDecoder;
8
9		class StreamHandler
10		{
11		protected $headerResponse;
12		protected $headerResponseBuffer = '';
13		protected $headerResponseHandler;
14		protected $eventBuffer = '';
15		protected $eventHandler;
16		protected $haltedByUser = false;
17
18	11	public function __construct(callable $header_response_handler = null, callable $event_handler = null)
19	11	{
20	11	$this->headerResponseHandler = $header_response_handler;
21	11	$this->eventHandler = $event_handler;
22	11	}
23
24	10	public function headerFunction($ch, $str)
25	10	{
26	10	$handle = $this->headerResponseHandler;
27	10	$this->headerResponseBuffer .= $str;
28	10	if (substr($this->headerResponseBuffer, -4) === "\r\n\r\n") {
29	10	$this->headerResponse = new Response($this->headerResponseBuffer, $ch);
30	10	if ($handle) {
31	3	(new \ReflectionFunction($handle))->isGenerator()
		1 ignored issue – show Bug introduced 2016-08-16 08:08 UTC by Report Bug Copy Issue Report It seems like you code against a specific sub-type and not the parent class `ReflectionFunction` as the method `isGenerator()` does only exist in the following sub-classes of `ReflectionFunction`: `Go\ParserReflection\ReflectionFunction`. Maybe you want to `instanceof` check for one of these explicitly? Let’s take a look at an example: abstract class User { /** @return string / abstract public function getPassword(); } class MyUser extends User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different sub-classes of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the parent class: abstract class User { /** @return string / abstract public function getPassword(); /* @return string */ abstract public function getDisplayName(); } Loading history...
32	1	? Co::async($handle($this->headerResponse))
33	2	: $handle($this->headerResponse);
34		}
35		}
36	10	return strlen($str);
37		}
38
39	8	protected function processLine($ch, $line)
40	8	{
41	8	$handle = $this->eventHandler;
42	8	if ('' === $line = rtrim($line)) {
43	5	return;
44		}
45	8	$event = ResponseBodyDecoder::getDecodedResponse($this->headerResponse, $ch, $line);
46	8	if ($handle) {
47	8	if ((new \ReflectionFunction($handle))->isGenerator()) {
48	1	Co::async(function () use ($handle, $event) {
49	1	if (false === (yield $handle($event->getContent()))) {
50	1	$this->haltedByUser = true;
51		}
52	1	});
53	7	} elseif (false === $handle($event->getContent())) {
54	5	$this->haltedByUser = true;
55		}
56		}
57	8	}
58
59	10	public function writeFunction($ch, $str)
60	10	{
61	10	if ($this->haltedByUser) {
62		// @codeCoverageIgnoreStart
63		return 0;
64		// @codeCoverageIgnoreEnd
65		}
66	10	$this->eventBuffer .= $str;
67	10	if (200 !== $code = curl_getinfo($ch, CURLINFO_HTTP_CODE)) {
68	2	ResponseBodyDecoder::getDecodedResponse($this->headerResponse, $ch, $this->eventBuffer);
69	1	throw new \UnexpectedValueException('Unexpected response: ' . $this->eventBuffer);
70		}
71	8	while (false !== $pos = strpos($this->eventBuffer, "\n")) {
72	8	$line = substr($this->eventBuffer, 0, $pos + 1);
73	8	$this->eventBuffer = substr($this->eventBuffer, $pos + 1);
74	8	$this->processLine($ch, $line);
75	8	if ($this->haltedByUser) {
76	6	return 0;
77		}
78		}
79	5	return strlen($str);
80		}
81
82	9	public function isHaltedByUser()
83	9	{
84	9	return $this->haltedByUser;
85		}
86		}
87

mpyw / cowitter

Push — master ( 3cf178...59e65f )

StreamHandler::processLine() B

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Duplication Side-by-Side

Filter issues like