k911/swoole-bundle

<?php

declare(strict_types=1);

namespace K911\Swoole\Server;

use Assert\Assertion;
use K911\Swoole\Server\Config\Socket;
use Swoole\Http\Server;

final class HttpServerFactory
{
    private const SWOOLE_RUNNING_MODE = [
        'process' => \SWOOLE_PROCESS,
        'reactor' => \SWOOLE_BASE,
        //        'thread' => SWOOLE_THREAD,
    ];

    /**
     * @param Socket ...$additional
     *
     * @see https://github.com/swoole/swoole-docs/blob/master/modules/swoole-server/methods/construct.md#parameter
     * @see https://github.com/swoole/swoole-docs/blob/master/modules/swoole-server/methods/addListener.md#prototype
     */
    public static function make(Socket $main, string $runningMode = 'process', Socket ...$additional): Server
    {
        Assertion::inArray($runningMode, \array_keys(self::SWOOLE_RUNNING_MODE));
        $mainServer = new Server($main->host(), $main->port(), self::SWOOLE_RUNNING_MODE[$runningMode], $main->type());

        $usedPorts = [$main->port() => true];
        foreach ($additional as $socket) {
            Assertion::keyNotExists($usedPorts, $socket->port(), 'Socket with port %s is already used. Ports cannot be duplicated.');

            $additionalServer = $mainServer->addListener($socket->host(), $socket->port(), $socket->type());
            $usedPorts[$additionalServer->port] = true;
        }

        return $mainServer;
    }
}