TcpServer::setListeners() - Code Metrics - Inspection of "[WIP]feature(server): integrate tcp server and lis..." - asiries335/redis-streams-php - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#11)

by Sergey

created 2022-05-10 19:45 UTC

TcpServer::setListeners() A

↳ Parent: TcpServer

Complexity

Conditions	1
Paths	1

Size

Total Lines	2
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
cc	1
eloc	1
c	0
b	0
f	0
nc	1
nop	1
dl	0
loc	2
ccs	0
cts	2
cp	0
crap	2
rs	10

<?php

namespace Asiries335\redisSteamPhp\Server;

use Asiries335\redisSteamPhp\Listeners\ListenerInterface;
use React\Socket\ConnectionInterface;

/**
 *
 */
class TcpServer implements ServerInterface
{

    private array $config;

    /**
     * @var \React\Socket\ServerInterface
     */
    private $tcpServer = null;


    /**
     * @var ListenerInterface[]
     */
    private array $listeners;

    /**
     * @param array $config
     * @return void
     */
    public function setConfig(array $config): void {
        $this->config = $config;
    }

    /**
     * @return void
     */
    public function start(): void {
        if ($this->tcpServer !== null) {
            return;
        }

        $ip = $this->config['ip'] ?? '0.0.0.0';
        $port = $this->config['port'] ?? '2341';

        $this->tcpServer = new \React\Socket\TcpServer($ip . ':' . $port);

        $this->tcpServer->on('connection', function (ConnectionInterface $connection) {

            $connection->pipe($connection);

            $connection->on('data', function ($payload) {
                foreach ($this->listeners as $listener) {
                    $listener->handle($payload);
                }
            });
        });
    }

    /**
     * @return void
     */
    public function down(): void {
        $this->tcpServer->close();
    }

    /**
     * @param array $listeners
     * @return void
     */
    public function setListeners(array $listeners): void {
        $this->listeners = $listeners;
    }
}

1			<?php
2
3			namespace Asiries335\redisSteamPhp\Server;
4
5			use Asiries335\redisSteamPhp\Listeners\ListenerInterface;
6			use React\Socket\ConnectionInterface;
7
8			/**
9			*
10			*/
11			class TcpServer implements ServerInterface
12			{
13
14			private array $config;
15
16			/**
17			* @var \React\Socket\ServerInterface
18			*/
19			private $tcpServer = null;
20
21
22			/**
23			* @var ListenerInterface[]
24			*/
25			private array $listeners;
26
27			/**
28			* @param array $config
29			* @return void
30			*/
31			public function setConfig(array $config): void {
32			$this->config = $config;
33			}
34
35			/**
36			* @return void
37			*/
38			public function start(): void {
39			if ($this->tcpServer !== null) {
40			return;
41			}
42
43			$ip = $this->config['ip'] ?? '0.0.0.0';
44			$port = $this->config['port'] ?? '2341';
45
46			$this->tcpServer = new \React\Socket\TcpServer($ip . ':' . $port);
47
48			$this->tcpServer->on('connection', function (ConnectionInterface $connection) {
49
50			$connection->pipe($connection);
51
52			$connection->on('data', function ($payload) {
53			foreach ($this->listeners as $listener) {
54			$listener->handle($payload);
55			}
56			});
57			});
58			}
59
60			/**
61			* @return void
62			*/
63			public function down(): void {
64			$this->tcpServer->close();
65			}
66
67			/**
68			* @param array $listeners
69			* @return void
70			*/
71			public function setListeners(array $listeners): void {
72			$this->listeners = $listeners;
73			}
74			}

asiries335 / redis-streams-php

Pull Request — master (#11)

TcpServer::setListeners() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like