Mosaic\Http\WebServer

Complexity

Total Complexity

9

Size/Duplication

Total Lines	97
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	serve()	0	17	3
A	relay()	0	11	1
A	pipe()	0	6	1
A	getEmitter()	0	4	1
A	setResolver()	0	6	1

<?php

namespace Mosaic\Http;

use InvalidArgumentException;
use Mosaic\Http\Emitters\SapiEmitter;
use Mosaic\Http\Server as ServerContract;
use Psr\Http\Message\ResponseInterface;
use Relay\RelayBuilder;

class WebServer implements ServerContract
{
    /**
     * @var array
     */
    protected $pipes = [];

    /**
     * @var Emitter
     */
    protected $emitter;

    /**
     * @var callable
     */
    protected $resolver;

    /**
     * @param Emitter $emitter
     */
    public function __construct(Emitter $emitter = null)
    {
        $this->emitter = $emitter ?: new SapiEmitter;

        $this->setResolver(function ($class) {
            return new $class;
        });
    }

    /**
     * @param Request       $request
     * @param callable|null $terminate
     */
    public function serve(Request $request, callable $terminate = null)
    {
        if (count($this->pipes) < 1) {
            throw new InvalidArgumentException('No pipes were given to the web server. Response could not be served.');
        }

        ob_start();
        $bufferLevel = ob_get_level();

        $response = $this->relay($request);

        if (is_callable($terminate)) {
            $terminate($request->toPsr7(), $response);
        }

        $this->getEmitter()->emit($response, $bufferLevel);
    }

    /**
     * @param  Request           $request
     * @return ResponseInterface
     */
    protected function relay(Request $request)
    {
        $relay = (new RelayBuilder($this->resolver))->newInstance($this->pipes);

        $response = $relay(
            $request->toPsr7(),
            $request->prepareResponse()->toPsr7()
        );

        return $response;
    }

    /**
     * @param array ...$pipes
     * @return Server
     */
    public function pipe(...$pipes)
    {
        $this->pipes = $pipes;

        return $this;
    }

    /**
     * @return Emitter
     */
    protected function getEmitter() : Emitter
    {
        return $this->emitter;
    }

    /**
     * @param  callable $resolver
     * @return Server
     */
    public function setResolver(callable $resolver)
    {
        $this->resolver = $resolver;

        return $this;
    }
}