SubAck::performSpecialActions() - Code Metrics - Inspection of "Preparing codebase to enable it to receive any mes..." - unreal4u/mqtt - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( fc052b...13a97b )

by Camilo

created 2017-12-10 13:43 UTC

SubAck::performSpecialActions() A

↳ Parent: SubAck

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

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

<?php

declare(strict_types=1);

namespace unreal4u\MQTT\Protocol;

use unreal4u\MQTT\Internals\ClientInterface;
use unreal4u\MQTT\Internals\ProtocolBase;
use unreal4u\MQTT\Internals\ReadableContent;
use unreal4u\MQTT\Internals\ReadableContentInterface;
use unreal4u\MQTT\Internals\WritableContentInterface;

/**
 * Class SubAck
 * @package unreal4u\MQTT\Protocol
 */
final class SubAck extends ProtocolBase implements ReadableContentInterface
{
    use ReadableContent;

    const CONTROL_PACKET_VALUE = 9;

    /**
     * @var int
     */
    private $packetIdentifier = 0;

    public function fillObject(string $rawMQTTHeaders): ReadableContentInterface
    {
        $this->packetIdentifier = $this->extractPacketIdentifier($rawMQTTHeaders);
        return $this;
    }

    /**
     * @inheritdoc
     * @throws \LogicException
     */
    public function performSpecialActions(ClientInterface $client, WritableContentInterface $originalRequest): bool
    {
        /** @var Subscribe $originalRequest */
        if ($this->packetIdentifier !== $originalRequest->getPacketIdentifier()) {
            throw new \LogicException('Packet identifiers do not match!');
        }

        $client
            ->updateLastCommunication()
            ->setBlocking(false)
        ;
        return true;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace unreal4u\MQTT\Protocol;
6
7			use unreal4u\MQTT\Internals\ClientInterface;
8			use unreal4u\MQTT\Internals\ProtocolBase;
9			use unreal4u\MQTT\Internals\ReadableContent;
10			use unreal4u\MQTT\Internals\ReadableContentInterface;
11			use unreal4u\MQTT\Internals\WritableContentInterface;
12
13			/**
14			* Class SubAck
15			* @package unreal4u\MQTT\Protocol
16			*/
17			final class SubAck extends ProtocolBase implements ReadableContentInterface
18			{
19			use ReadableContent;
20
21			const CONTROL_PACKET_VALUE = 9;
22
23			/**
24			* @var int
25			*/
26			private $packetIdentifier = 0;
27
28			public function fillObject(string $rawMQTTHeaders): ReadableContentInterface
29			{
30			$this->packetIdentifier = $this->extractPacketIdentifier($rawMQTTHeaders);
31			return $this;
32			}
33
34			/**
35			* @inheritdoc
36			* @throws \LogicException
37			*/
38			public function performSpecialActions(ClientInterface $client, WritableContentInterface $originalRequest): bool
39			{
40			/** @var Subscribe $originalRequest */
41			if ($this->packetIdentifier !== $originalRequest->getPacketIdentifier()) {
42			throw new \LogicException('Packet identifiers do not match!');
43			}
44
45			$client
46			->updateLastCommunication()
47			->setBlocking(false)
48			;
49			return true;
50			}
51			}
52

unreal4u / mqtt

Push — master ( fc052b...13a97b )

SubAck::performSpecialActions() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like