kiri-http-server/State.php

<?php

namespace Kiri\Server;

use Kiri\Abstracts\Component;
use Kiri\Server\Abstracts\TraitServer;
use Swoole\Process;
use function config;

class State extends Component
{

    use TraitServer;


    public array $servers = [];


    /**
     * @return void
     */
    public function init(): void
    {
        $this->servers = config('servers.server.ports');
    }


    /**
     * @return bool
     * @throws
     */
    public function isRunner(): bool
    {
        $ports = $this->sortService($this->servers);
        foreach ($ports as $config) {
            if (checkPortIsAlready($config['port'])) {
                return true;
            }
        }
        return false;
    }


    /**
     * @param $port
     * @throws
     */
    public function exit($port): void
    {
        if (!($pid = checkPortIsAlready($port))) {
            return;
        }
        while (checkPortIsAlready($port)) {
            Process::kill($pid, 0) && Process::kill($pid, SIGTERM);
            usleep(300);
        }
    }

}