StreamGroupConsumer::create() - Code Metrics - Inspection of "Mvp 6" - asiries335/redis-streams-php - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#8)

by Sergey

created 2020-09-29 14:08 UTC

StreamGroupConsumer::create() A

↳ Parent: StreamGroupConsumer

Complexity

Conditions	2
Paths	2

Size

Total Lines	18
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
cc	2
eloc	11
nc	2
nop	2
dl	0
loc	18
ccs	0
cts	17
cp	0
crap	6
rs	9.9
c	1
b	0
f	1

<?php
declare(strict_types=1);

namespace Asiries335\redisSteamPhp;


use Asiries335\redisSteamPhp\Data\Constants;
use Asiries335\redisSteamPhp\Dto\StreamCommandCallTransporter;

final class StreamGroupConsumer extends RedisStream
{
    /**
     * Create group Consumer
     *
     * @param string $groupName
     * @param bool $isShowFullHistoryStream
     *
     * @return bool
     *
     * @throws \Exception
     */
    public function create(string $groupName, bool $isShowFullHistoryStream = true) : bool
    {
        $transporter = new StreamCommandCallTransporter(
            [
                'command' => Constants::COMMAND_XGROUP,
                'args'    => [
                    Constants::COMMAND_OPTION_XGROUP_CREATE,
                    $this->_streamName,
                    $groupName,
                    (int) $isShowFullHistoryStream
                ]
            ]
        );

        try {
            return (bool) $this->_client->call($transporter);
        } catch (\Exception $exception) {
            throw $exception;
        }
    }

    /**
     * Delete group Consumer
     *
     * @param string $groupName
     *
     * @return bool
     *
     * @throws \Exception
     */
    public function destroy(string $groupName) : bool
    {
        $transporter = new StreamCommandCallTransporter(
            [
                'command' => Constants::COMMAND_XGROUP,
                'args'    => [
                    Constants::COMMAND_OPTION_XGROUP_DESTROY,
                    $this->_streamName,
                    $groupName,
                ]
            ]
        );

        try {
            return (bool) $this->_client->call($transporter);
        } catch (\Exception $exception) {
            throw $exception;
        }
    }
}

1			<?php
2			declare(strict_types=1);
3
4			namespace Asiries335\redisSteamPhp;
5
6
7			use Asiries335\redisSteamPhp\Data\Constants;
8			use Asiries335\redisSteamPhp\Dto\StreamCommandCallTransporter;
9
10			final class StreamGroupConsumer extends RedisStream
11			{
12			/**
13			* Create group Consumer
14			*
15			* @param string $groupName
16			* @param bool $isShowFullHistoryStream
17			*
18			* @return bool
19			*
20			* @throws \Exception
21			*/
22			public function create(string $groupName, bool $isShowFullHistoryStream = true) : bool
23			{
24			$transporter = new StreamCommandCallTransporter(
25			[
26			'command' => Constants::COMMAND_XGROUP,
27			'args' => [
28			Constants::COMMAND_OPTION_XGROUP_CREATE,
29			$this->_streamName,
30			$groupName,
31			(int) $isShowFullHistoryStream
32			]
33			]
34			);
35
36			try {
37			return (bool) $this->_client->call($transporter);
38			} catch (\Exception $exception) {
39			throw $exception;
40			}
41			}
42
43			/**
44			* Delete group Consumer
45			*
46			* @param string $groupName
47			*
48			* @return bool
49			*
50			* @throws \Exception
51			*/
52			public function destroy(string $groupName) : bool
53			{
54			$transporter = new StreamCommandCallTransporter(
55			[
56			'command' => Constants::COMMAND_XGROUP,
57			'args' => [
58			Constants::COMMAND_OPTION_XGROUP_DESTROY,
59			$this->_streamName,
60			$groupName,
61			]
62			]
63			);
64
65			try {
66			return (bool) $this->_client->call($transporter);
67			} catch (\Exception $exception) {
68			throw $exception;
69			}
70			}
71			}

asiries335 / redis-streams-php

Pull Request — master (#8)

StreamGroupConsumer::create() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like