mpyw\HyperBuiltinServer\Internal\ConnectionHandler

Complexity

Total Complexity

3

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	6

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__invoke()	0	20	2

<?php

namespace mpyw\HyperBuiltinServer\Internal;
use mpyw\HyperBuiltinServer\Master;
use React\Socket\ConnectionInterface;
use React\Stream\Stream;
use React\Promise\Deferred;

class ConnectionHandler
{
    protected $master;

    public function __construct(Master $master)
    {
        $this->master = $master;
    }

    public function __invoke(ConnectionInterface $conn)
    {
        $sink = new Sink($conn);
        $this->master->queue->executeAsync(function (BuiltinServer $process) use ($conn, $sink) {
            $deferred = new Deferred;
            try {
                $child = new Stream($process->getSocketClient(), $this->master->loop);
                $sink->pipe($child);
                $child->pipe($conn);
                $child->on('close', function () use ($deferred) {
                    $deferred->resolve();
                });
            } catch (\RuntimeException $e) {
                $conn->write("HTTP/1.0 502 Bad Gateway\r\n");
                $conn->end("\r\n");
                $deferred->resolve();
            }
            return $deferred->promise();
        });
    }
}