<?php

namespace BeyondCode\LaravelWebSockets\Server;

use BeyondCode\LaravelWebSockets\Server\Logger\HttpLogger;
use Ratchet\Http\Router;
use Ratchet\Server\IoServer;
use React\EventLoop\Factory as LoopFactory;
use React\EventLoop\LoopInterface;
use React\Socket\SecureServer;
use React\Socket\Server;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Routing\Matcher\UrlMatcher;
use Symfony\Component\Routing\RequestContext;
use Symfony\Component\Routing\RouteCollection;

class WebSocketServerFactory
{
    /**
     * The host the server will run on.
     *
     * @var string
     */
    protected $host = '127.0.0.1';

    /**
     * The port to run on.
     *
     * @var int
     */
    protected $port = 8080;

    /**
     * The event loop instance.
     *
     * @var \React\EventLoop\LoopInterface
     */
    protected $loop;

    /**
     * The routes to register.
     *
     * @var \Symfony\Component\Routing\RouteCollection
     */
    protected $routes;

    /**
     * Console output.
     *
     * @var Symfony\Component\Console\Output\OutputInterface
     */
    protected $consoleOutput;

    /**
     * Initialize the class.
     *
     * @param  string  $host
     * @param  int  $port
     * @return void
     */
    public function __construct(string $host, int $port)
    {
        $this->host = $host;
        $this->port = $port;

        $this->loop = LoopFactory::create();
    }

    /**
     * Add the routes.
     *
     * @param \Symfony\Component\Routing\RouteCollection $routes
     * @return $this
     */
    public function useRoutes(RouteCollection $routes)
    {
        $this->routes = $routes;

        return $this;
    }

    /**
     * Set the loop instance.
     *
     * @param  \React\EventLoop\LoopInterface  $loop
     * @return $this
     */
    public function setLoop(LoopInterface $loop)
    {
        $this->loop = $loop;

        return $this;
    }

    /**
     * Set the console output.
     *
     * @param  \Symfony\Component\Console\Output\OutputInterface  $consoleOutput
     * @return $this
     */
    public function setConsoleOutput(OutputInterface $consoleOutput)
    {
        $this->consoleOutput = $consoleOutput;

        return $this;
    }

    /**
     * Set up the server.
     *
     * @return \Ratchet\Server\IoServer
     */
    public function createServer(): IoServer
    {
        $socket = new Server("{$this->host}:{$this->port}", $this->loop);

        if (config('websockets.ssl.local_cert')) {
            $socket = new SecureServer($socket, $this->loop, config('websockets.ssl'));
        }

        $app = new Router(
            new UrlMatcher($this->routes, new RequestContext)
        );

        $httpServer = new HttpServer($app, config('websockets.max_request_size_in_kb') * 1024);

        if (HttpLogger::isEnabled()) {
            $httpServer = HttpLogger::decorate($httpServer);
        }

        return new IoServer($httpServer, $socket, $this->loop);
    }
}