SamIT\Proxy\Server

Complexity

Total Complexity

3

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes	6
Bugs	0	Features	2

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	handleConnection()	0	16	1
A	createConnection()	0	4	1

<?php


namespace SamIT\Proxy;


use React\Dns\Resolver\Factory;
use React\Dns\Resolver\Resolver;
use React\EventLoop\LoopInterface;
use React\Socket\Connection;

/**
 * Class Server
 * A server that receives proxy connections.
 * If no proxy header is received within 5 seconds after connection opening than the connection is closed.
 * The `connection` event is only triggered after receiving the header.
 * @package SamIT\Proxy
 * @event connection When an new connection has been fully set up (ie a proxy header was received).
 * @emits proxytimeout When a new connection failed to send a proxy header within 5 seconds after opening the connection.
 */
class Server extends \React\Socket\Server
{
    private $loop;

    public function __construct(LoopInterface $loop)
    {
        $this->loop = $loop;
        parent::__construct($loop);
    }

    /**
     * Handle the connection. We only emit the connection event after the proper header was received.
     * @param $socket
     */
    public function handleConnection($socket)
    {
        stream_set_blocking($socket, 0);
        $client = $this->createConnection($socket);

        $timer = $this->loop->addTimer(5, function() use ($client) {
            $client->removeAllListeners('init');
            $client->end('Timeout waiting for PROXY header.');
            $this->emit('proxytimeout', [new Connection($client->stream, $this->loop)]);
        });

        $client->on('init', function($connection) use ($client, $timer) {
            $timer->cancel();
            $this->emit('connection', [$connection]);
        });
    }

    /**
     * @param $socket
     * @return ProxyConnection
     */
    public function createConnection($socket)
    {
        return new ProxyConnection($socket, $this->loop);
    }
}