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	setListeners()	0	2	1
A	down()	0	2	1

<?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;
    }
}