Symplify\PHP7_Sculpin\SculpinBundle\HttpServer\HttpServer

Complexity

Total Complexity

11

Size/Duplication

Total Lines	138
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
B	init()	0	45	5
A	addPeriodicTimer()	0	4	1
A	run()	0	11	1
A	setupDependencies()	0	6	1
A	logRequest()	0	20	2

<?php

/*
 * This file is a part of Sculpin.
 *
 * (c) Dragonfly Development Inc.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Symplify\PHP7_Sculpin\SculpinBundle\HttpServer;

use Dflydev\ApacheMimeTypes\PhpRepository;
use React\EventLoop\StreamSelectLoop;
use React\Http\Request;
use React\Http\Response;
use React\Http\Server as ReactHttpServer;
use React\Socket\Server as ReactSocketServer;
use Symplify\PHP7_Sculpin\Io\ConsoleIo;

final class HttpServer
{
    /**
     * @var ConsoleIo
     */
    private $consoleIo;

    /**
     * @var string
     */
    private $outputDirectory;

    /**
     * @var PhpRepository
     */
    private $phpRepository;

    /**
     * @var StreamSelectLoop
     */
    private $streamSelectLoop;

    /**
     * @var ReactHttpServer
     */
    private $reactHttpServer;

    /**
     * @var int
     */
    private $port;

    /**
     * @var ReactSocketServer
     */
    private $reactSocketServer;

    public function __construct(
        string $outputDirectory,
        ConsoleIo $consoleIo,
        PhpRepository $phpRepository
    ) {
        $this->outputDirectory = $outputDirectory;
        $this->consoleIo = $consoleIo;
        $this->phpRepository = $phpRepository;
    }

    public function init(int $port = 8000)
    {
        $this->setupDependencies();

        $this->port = $port;

        $this->reactHttpServer->on('request', function (Request $request, Response $response) {
            $path = $this->outputDirectory.'/'.ltrim(rawurldecode($request->getPath()), '/');
            if (is_dir($path)) {
                $path .= '/index.html';
            }

            if (!file_exists($path)) {
                $this->logRequest(404, $request);
                $response->writeHead(404, [
                    'Content-Type' => 'text/html',
                ]);

                return $response->end(
                    '<h1>404</h1>'.
                    '<h2>Not Found</h2>'.
                    '<p>'.
                    'The embedded <a href="https://sculpin.io">Sculpin</a> web server could not find the requested resource.'.
                    '</p>'
                );
            }

            $type = 'application/octet-stream';

            if ('' !== $extension = pathinfo($path, PATHINFO_EXTENSION)) {
                if ($guessedType = $this->phpRepository->findType($extension)) {
                    $type = $guessedType;
                }
            }

            $this->logRequest(200, $request);

            $response->writeHead(200, [
                'Content-Type' => $type,
            ]);
            $response->end(file_get_contents($path));
        });

        $this->reactSocketServer->listen($this->port, '0.0.0.0');
    }

    public function addPeriodicTimer(int $interval, callable $callback)
    {
        $this->streamSelectLoop->addPeriodicTimer($interval, $callback);
    }

    public function run()
    {
        $this->consoleIo->write(sprintf(
            'Starting Sculpin at <info>http://%s:%s</info>',
            'localhost',
            $this->port
        ));
        $this->consoleIo->write('Quit the server with CONTROL-C.');

        $this->streamSelectLoop->run();
    }

    private function setupDependencies()
    {
        $this->streamSelectLoop = new StreamSelectLoop();
        $this->reactSocketServer = new ReactSocketServer($this->streamSelectLoop);
        $this->reactHttpServer = new ReactHttpServer($this->reactSocketServer);
    }

    private function logRequest(string $responseCode, Request $request)
    {
        $wrapOpen = '';
        $wrapClose = '';
        if ($responseCode >= 400) {
            $wrapOpen = '<comment>';
            $wrapClose = '</comment>';
        }

        $message = sprintf(
            '[%s] "%s %s HTTP/%s" %s',
            date('d/M/Y H:i:s'),
            $request->getMethod(),
            $request->getPath(),
            $request->getHttpVersion(),
            $responseCode
        );

        $this->consoleIo->write($wrapOpen.$message.$wrapClose);
    }
}