Asiries335\redisSteamPhp\Server\TcpServer

Complexity

Total Complexity

6

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	start()	0	17	3
A	setConfig()	0	2	1
A	down()	0	2	1
A	setConsumers()	0	2	1

<?php

namespace Asiries335\redisSteamPhp\Server;

use Asiries335\redisSteamPhp\Consumer\ConsumerInterface;
use React\Socket\ConnectionInterface;

/**
 *
 */
class TcpServer implements ServerInterface
{

    private array $config;

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


    /**
     * @var ConsumerInterface[]
     */
    private array $consumers;

    /**
     * @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->consumers as $consumer) {
                    $consumer->handle($payload);
                }
            });
        });
    }

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

    /**
     * @param ConnectionInterface[] $consumers
     * @return void
     */
    public function setConsumers(array $consumers): void {
        $this->consumers = $consumers;

It seems like $consumers of type React\Socket\ConnectionInterface[] is incompatible with the declared type Asiries335\redisSteamPhp\Consumer\ConsumerInterface[] of property $consumers.

    }
}