Asylamba\Classes\Daemon\Server

Complexity

Total Complexity

34

Size/Duplication

Total Lines	250
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	14

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
A	shutdown()	0	10	3
A	createHttpServer()	0	8	2
B	listen()	0	24	6
B	treatHttpInput()	0	35	6
B	treatProcessInput()	0	22	6
A	treatCommand()	0	21	3
A	prepareStreamsState()	0	18	2
A	addInput()	0	4	1
A	addOutput()	0	4	1
A	removeInput()	0	4	1
A	removeOutput()	0	4	1
A	debug()	0	6	1

<?php

namespace Asylamba\Classes\Daemon;

use Asylamba\Classes\Router\Router;
use Asylamba\Classes\Library\Http\RequestFactory;
use Asylamba\Classes\Library\Http\ResponseFactory;
use Asylamba\Classes\Daemon\ClientManager;

use Asylamba\Classes\Scheduler\RealTimeActionScheduler;
use Asylamba\Classes\Scheduler\CyclicActionScheduler;

use Asylamba\Classes\Event\ExceptionEvent;
use Asylamba\Classes\Event\ErrorEvent;

use Asylamba\Classes\DependencyInjection\Container;

use Asylamba\Classes\Exception\ErrorException;

use Asylamba\Classes\Process\ProcessManager;
use Asylamba\Classes\Task\TaskManager;

class Server
{
	/** @var Container **/
	protected $container;
    /** @var Router **/
    protected $router;
    /** @var RequestFactory **/
    protected $requestFactory;
    /** @var ResponseFactory **/
    protected $responseFactory;
    /** @var ClientManager **/
    protected $clientManager;
	/** @var RealTimeActionScheduler **/
	protected $realTimeActionScheduler;
	/** @var CyclicActionScheduler **/
	protected $cyclicActionScheduler;
	/** @var ProcessManager **/
	protected $processManager;
	/** @var TaskManager **/
	protected $taskManager;
    /** @var int **/
    protected $serverCycleTimeout;
    /** @var int **/
    protected $port;
    /** @var boolean **/
    protected $shutdown = false;
    /** @var array **/
    protected $connections;
    /** @var array **/
    protected $inputs = [];
    /** @var array **/
    protected $outputs = [];
    /** @var int **/
    protected $nbUncollectedCycles = 0;
    /** @var int **/
    protected $collectionCyclesNumber;

    /**
     * @param Container $container
     * @param int $serverCycleTimeout

There is no parameter named $serverCycleTimeout. Was it maybe removed?

     * @param int $port

There is no parameter named $port. Was it maybe removed?

     */
    public function __construct(Container $container)
    {
        $this->container = $container;
        $this->router = $container->get('router');
        $this->requestFactory = $container->get('request_factory');
        $this->responseFactory = $container->get('response_factory');
        $this->clientManager = $container->get('client_manager');
		$this->realTimeActionScheduler = $container->get('realtime_action_scheduler');
		$this->cyclicActionScheduler = $container->get('cyclic_action_scheduler');
        $this->serverCycleTimeout = $container->getParameter('server_cycle_timeout');
        $this->port = $container->getParameter('server_port');
        $this->collectionCyclesNumber = $container->getParameter('server_collection_cycles_number');
    }
	
    public function shutdown()
    {
        $this->shutdown = true;
        foreach($this->inputs as $input) {

Expected 1 space after FOREACH keyword; 0 found

            fclose($input);
        }
        foreach($this->outputs as $output) {

Expected 1 space after FOREACH keyword; 0 found

            fclose($output);
        }
    }

    public function createHttpServer()
    {
        $stream = stream_socket_server("tcp://0.0.0.0:{$this->port}", $errno, $errstr);
        if (!$stream) {
            throw new ErrorException("$errstr ($errno)");
        }
        $this->inputs['http_server'] = $stream;
    }

    public function listen()
    {
		$this->processManager = $this->container->get('process_manager');
		$this->taskManager = $this->container->get('task_manager');
        $inputs = $this->inputs;
        $outputs = $this->outputs;
        $errors = null;
        gc_disable();
        while ($this->shutdown === false && ($nbUpgradedStreams = stream_select($inputs, $outputs, $errors, $this->serverCycleTimeout)) !== false) {
            if ($nbUpgradedStreams === 0) {
                $this->prepareStreamsState($inputs, $outputs, $errors);
                continue;
            }
            foreach ($inputs as $stream) {
				$name = array_search($stream, $this->inputs);
				if ($name === 'http_server') {
					$this->treatHttpInput(stream_socket_accept($stream));
				} else {
					$this->treatProcessInput($name);
				}
            }
            $this->prepareStreamsState($inputs, $outputs, $errors);
        }
    }
	
	protected function treatHttpInput($input)
	{
		$client = $request = $response = null;
		try {
			$data = fread($input, 8192);
			if (empty($data)) {
				fclose($input);
				return;
			}
			$request = $this->requestFactory->createRequestFromInput($data);

$data is of type string, but the function expects a resource.

			$this->container->set('app.request', $request);
			if (($client = $this->clientManager->getClient($request)) === null) {
				$client = $this->clientManager->createClient($request);
			}
			$response = $this->router->processRequest($request);
			$this->container->set('app.response', $response);
			$this->responseFactory->processResponse($request, $response, $client);
		} catch (\Exception $ex) {
			$this->container->get('event_dispatcher')->dispatch($event = new ExceptionEvent($request, $ex));

It seems like $request defined by $response = null on line 126 can be null; however, Asylamba\Classes\Event\ExceptionEvent::__construct() does not accept null, maybe add an additional type check?

			$response = $event->getResponse();
			$this->responseFactory->processResponse($request, $response, $client);

It seems like $request defined by $response = null on line 126 can be null; however, Asylamba\Classes\Library\Http\ResponseFactory::processResponse() does not accept null, maybe add an additional type check?

It seems like $client defined by $request = $response = null on line 126 can be null; however, Asylamba\Classes\Library\Http\ResponseFactory::processResponse() does not accept null, maybe add an additional type check?

		} catch (\Error $err) {
			$this->container->get('event_dispatcher')->dispatch($event = new ErrorEvent($request, $err));

It seems like $request defined by $response = null on line 126 can be null; however, Asylamba\Classes\Event\ErrorEvent::__construct() does not accept null, maybe add an additional type check?

			$response = $event->getResponse();
			$this->responseFactory->processResponse($request, $response, $client);

It seems like $request defined by $response = null on line 126 can be null; however, Asylamba\Classes\Library\Http\ResponseFactory::processResponse() does not accept null, maybe add an additional type check?

It seems like $client defined by $request = $response = null on line 126 can be null; however, Asylamba\Classes\Library\Http\ResponseFactory::processResponse() does not accept null, maybe add an additional type check?

		} finally {
			// @TODO Needs further investigation
			if ($response !== null) {
				fputs ($input, $response->send());

Space before opening parenthesis of function call prohibited

				fclose($input);
			}
			$this->nbUncollectedCycles++;
			$this->container->get('session_wrapper')->clearWrapper();
		}
	}
	
	protected function treatProcessInput($name)
	{
		$process = $this->processManager->getByName($name);
		$content = fgets($process->getInput(), 1024);
		if ($content === false) {
			$this->processManager->removeProcess($name, 'The process failed');
			return;
		}
		if (empty($content)) {
			return;
		}
		$data = json_decode($content, true);
		if (isset($data['technical'])) {
			$this->processManager->updateTechnicalData($process, $data['technical']);
		}
		if (isset($data['command'])) {
			return $this->treatCommand($data);
		}
		if (isset($data['task'])) {
			return $this->taskManager->validateTask($process, $data);
		}
	}
	
	/**
	 * @param array $data
	 */
	public function treatCommand($data)
	{
		switch ($data['command']) {
			case 'schedule':
				$this->realTimeActionScheduler->scheduleFromProcess(
					$data['data']['manager'],
					$data['data']['method'],
					$data['data']['object_class'],
					$data['data']['object_id'],
					$data['data']['date']
				);
				break;
			case 'cancel':
				$this->realTimeActionScheduler->cancelFromProcess(
					$data['data']['object_class'],
					$data['data']['object_id'],
					$data['data']['date']
				);
				break;
		}
	}
    
	/**
	 * @param array $inputs
	 * @param array $outputs
	 * @param array $errors
	 */
    protected function prepareStreamsState(&$inputs, &$outputs, &$errors)
    {
		$this->container->cleanApplication();
		
        $inputs = $this->inputs;
        $outputs = $this->outputs;
        $errors = null;
		
		$this->realTimeActionScheduler->execute();
		$this->cyclicActionScheduler->execute();
		
        if ($this->nbUncollectedCycles > $this->collectionCyclesNumber) {
			$this->container->get('database')->refresh();
			$this->clientManager->clear();
            gc_collect_cycles();
            $this->nbUncollectedCycles = 0;
        }
    }
    
	/**
	 * @param string $name
	 * @param resource $input
	 */
    public function addInput($name, $input)
    {
        $this->inputs[$name] = $input;
    }
    
	/**
	 * @param string $name
	 * @param resource $output
	 */
    public function addOutput($name, $output)
    {
        $this->outputs[$name] = $output;
    }
    
	/**
	 * @param string $name
	 */
    public function removeInput($name)
    {
		unset($this->inputs[$name]);
    }
    
	/**
	 * @param string $name
	 */
    public function removeOutput($name)
    {
		unset($this->outputs[$name]);
    }
    
    public static function debug($debug)
    {
        ob_start();
        var_dump($debug);

var_dump($debug); looks like debug code. Are you sure you do not want to remove it? This might expose sensitive data.

        file_put_contents('/srv/logs/php/test.log', PROCESS_NAME . ': ' . ob_get_clean() . "\n\n", FILE_APPEND);
    }
}