Thruster\Component\Socket\Server

Complexity

Total Complexity

10

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

94.59%

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	listen()	0	34	4
A	handleConnection()	0	8	1
A	getPort()	0	6	1
A	shutdown()	0	8	1
A	createConnection()	0	4	1
A	getSocket()	0	4	1

<?php

namespace Thruster\Component\Socket;

use Thruster\Component\EventEmitter\EventEmitterTrait;
use Thruster\Component\EventLoop\EventLoopInterface;
use Thruster\Component\Socket\Exception\ConnectionException;

/**
 * Class Server
 *
 * @package Thruster\Component\Socket
 * @author  Aurimas Niekis <aurimas@niekis.lt>
 */
class Server implements ServerInterface
{
    use EventEmitterTrait;

    /**
     * @var resource
     */
    protected $socket;

    /**
     * @var EventLoopInterface
     */
    protected $loop;

    public function __construct(EventLoopInterface $loop)
    {
        $this->loop = $loop;
    }

    /**
     * {@inheritDoc}
     */
    public function listen(int $port, string $host = '127.0.0.1')
    {
        if (strpos($host, ':') !== false) {
            // enclose IPv6 addresses in square brackets before appending port
            $host = '[' . $host . ']';
        }

        $this->socket = @stream_socket_server("tcp://$host:$port", $errno, $errstr);

        if (false === $this->socket) {
            $message = sprintf(
                'Could not bind to tcp://%s:%s: %s',
                $host,
                $port,
                $errstr
            );

            throw new ConnectionException($message, $errno);
        }

        stream_set_blocking($this->socket, 0);

        $this->loop->addReadStream($this->socket, function ($master) {
            $newSocket = @stream_socket_accept($master, 0);

            if (false === $newSocket) {
                $this->emit('error', [new \RuntimeException('Error accepting new connection')]);

                return;
            }

            $this->handleConnection($newSocket);
        });
    }

    public function handleConnection($socket)
    {
        stream_set_blocking($socket, 0);

        $client = $this->createConnection($socket);

        $this->emit('connection', [$client]);
    }

    public function getPort() : int
    {
        $name = stream_socket_get_name($this->socket, false);

        return (int)substr(strrchr($name, ':'), 1);
    }

    public function shutdown()
    {
        $this->loop->removeStream($this->socket);

        fclose($this->socket);

        $this->removeListeners();
    }

    protected function createConnection($socket) : Connection
    {
        return new Connection($socket, $this->loop);
    }

    /**
     * @return resource
     */
    public function getSocket()
    {
        return $this->socket;
    }
}