cs\modules\Http_server\cli\Controller

Complexity

Total Complexity

11

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	index_help()	0	20	1
A	index_run_server()	0	23	2
A	index_run_pool()	0	11	3
A	prepare_ports()	0	12	3
A	cross_platform_server_in_background()	0	10	2

<?php
/**
 * @package   Http server
 * @category  modules
 * @author    Nazar Mokrynskyi <nazar@mokrynskyi.com>
 * @copyright Copyright (c) 2015-2016, Nazar Mokrynskyi
 * @license   MIT License, see license.txt
 */
namespace cs\modules\Http_server\cli;
use
	React,
	cs\ExitException,
	cs\modules\Http_server\Request;

class Controller {
	public static function index_help () {
		return <<<HELP
%yHttp server module%n

%yMethods:%n
  %grun_server%n Prints all cli paths and methods available for specified path
  %grun_pool%n   Displays help for module or path (should be provided by developer, otherwise will fallback to %gcli%n)

%yArguments:%n
  %gport%n  Required for %grun_server%n, specifies port on which server will be running
  %gports%n Required for %grun_pool%n, specifies ports on which server will be running (coma-separated list of ports or ports ranged separated by -)

%yExamples:%n
  Run HTTP server on port 8080:
    %g./cli run_server:Http_server port=8080%n
  Run pool of HTTP servers on ports 8080, 8081 and range of ports 8082-8087:
    %g./cli run_pool:Http_server ports=8080,8081,8082-8087%n

HELP;
	}
	/**
	 * @param \cs\Request $Request
	 *
	 * @throws ExitException
	 */
	public static function index_run_server ($Request) {
		$port = $Request->query('port');
		if (!$port) {
			throw new ExitException('Port is required', 400);
		}

		$loop   = React\EventLoop\Factory::create();
		$socket = new React\Socket\Server($loop);
		$http   = new React\Http\Server($socket);
		$http->on(
			'request',
			function (React\Http\Request $request, React\Http\Response $response) {
				$request->on(
					'data',
					function ($data) use ($request, $response) {
						Request::process($request, $response, microtime(true), $data);
					}
				);
			}
		);
		$socket->listen($port);
		$loop->run();
	}
	/**
	 * @param \cs\Request $Request
	 *
	 * @throws ExitException
	 */
	public static function index_run_pool ($Request) {
		$ports = $Request->query('ports');
		if (!$ports) {
			throw new ExitException('Ports are required', 400);
		}
		$ports = static::prepare_ports($ports);
		foreach ($ports as $p) {
			static::cross_platform_server_in_background($p);
		}
		echo "Pool of Http servers started!\n";
	}
	/**
	 * @param string $posts
	 *
	 * @return int[]
	 */
	protected static function prepare_ports ($posts) {
		$result_ports = [];
		foreach (explode(',', $posts) as $p) {
			if (strpos($p, '-') !== false) {
				$result_ports = array_merge($posts, range(...explode('-', $p)));
			} else {
				$result_ports[] = $p;
			}
		}
		sort($result_ports);
		return $result_ports;
	}
	/**
	 * Running Http server in background on any platform
	 *
	 * @param int $port
	 */
	protected static function cross_platform_server_in_background ($port) {
		$dir        = realpath(__DIR__.'/..');
		$supervisor = "php $dir/supervisor.php";
		$cmd        = escapeshellarg(PHP_BINARY.' '.DIR."/cli run_server:Http_server port=$port");
		if (strpos(PHP_OS, 'WIN') === false) {
			exec("$supervisor $cmd > /dev/null &");
		} else {
			pclose(popen("start /B $supervisor $cmd", 'r'));
		}
	}
}