Symplify\PHP7_Sculpin\HttpServer\HttpServer

Complexity

Total Complexity

12

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

36.54%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	init()	0	21	3
A	addPeriodicTimer()	0	4	1
A	run()	0	10	1
A	setupDependencies()	0	6	1
A	send404Response()	0	15	1
A	logRequest()	0	10	1
A	send200Response()	0	9	1
A	prepareResponseMessage()	0	11	2

<?php

declare(strict_types=1);

/*
 * This file is part of Symplify
 * Copyright (c) 2016 Tomas Votruba (http://tomasvotruba.cz).
 */

namespace Symplify\PHP7_Sculpin\HttpServer;

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 Symfony\Component\Console\Output\OutputInterface;

final class HttpServer
{
    /**
     * @var string
     */
    private $outputDirectory;

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

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

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

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

    /**
     * @var OutputInterface
     */
    private $output;

    public function __construct(string $outputDirectory, OutputInterface $output)
    {
        $this->outputDirectory = $outputDirectory;
        $this->output = $output;
    }

    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->send404Response($request, $response);
            } else {
                $this->send200Response($request, $response, $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->output->writeln(sprintf(
            'Starting Sculpin at <info>http://localhost:%s</info>',
            $this->port
        ));
        $this->output->writeln('Quit the server with <info>CONTROL-C</info>.');

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

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

    private function send404Response(Request $request, Response $response)
    {
        $this->logRequest(404, $request);
        $response->writeHead(404, [
            'Content-Type' => 'text/html',
        ]);

        $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>'
        );
    }

    private function logRequest(int $responseCode, Request $request)
    {
        $message = sprintf(
            '%s for path: "%s"',
            $responseCode,
            $request->getPath()
        );

        $this->output->writeln($this->prepareResponseMessage($responseCode, $message));
    }

    private function send200Response(Request $request, Response $response, string $path)
    {
        $response->writeHead(200, [
            'Content-Type' => 'text/html',
        ]);

        $this->logRequest(200, $request);
        $response->end(file_get_contents($path));
    }

    private function prepareResponseMessage(int $responseCode, string $message) : string
    {
        $wrapOpen = '<info>';
        $wrapClose = '</info>';
        if ($responseCode >= 400) {
            $wrapOpen = '<error>';
            $wrapClose = '</error>';
        }

        return $wrapOpen.$message.$wrapClose;
    }
}