LaravelS::onPipeMessage() - Code Metrics - Inspection of "support reload all custom process" - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 50b448...b57b98 )

by Biao

created 2019-05-10 07:03 UTC

LaravelS::onPipeMessage() A

↳ Parent: LaravelS

Complexity

Conditions	3
Paths	3

Size

Total Lines	16
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	3
eloc	10
nc	3
nop	3
dl	0
loc	16
rs	9.9332
c	0
b	0
f	0

<?php

namespace Hhxsv5\LaravelS;

use Hhxsv5\LaravelS\Illuminate\Laravel;
use Hhxsv5\LaravelS\Swoole\DynamicResponse;
use Hhxsv5\LaravelS\Swoole\Events\WorkerErrorInterface;
use Hhxsv5\LaravelS\Swoole\Events\WorkerStartInterface;
use Hhxsv5\LaravelS\Swoole\Events\WorkerStopInterface;
use Hhxsv5\LaravelS\Swoole\Request;
use Hhxsv5\LaravelS\Swoole\Server;
use Hhxsv5\LaravelS\Swoole\StaticResponse;
use Hhxsv5\LaravelS\Swoole\Traits\CustomProcessTrait;
use Hhxsv5\LaravelS\Swoole\Traits\InotifyTrait;
use Hhxsv5\LaravelS\Swoole\Traits\LaravelTrait;
use Hhxsv5\LaravelS\Swoole\Traits\LogTrait;
use Hhxsv5\LaravelS\Swoole\Traits\ProcessTitleTrait;
use Hhxsv5\LaravelS\Swoole\Traits\TimerTrait;
use Illuminate\Http\Request as IlluminateRequest;
use Swoole\Http\Request as SwooleRequest;
use Swoole\Http\Response as SwooleResponse;
use Swoole\Http\Server as HttpServer;
use Swoole\WebSocket\Server as WebSocketServer;
use Symfony\Component\Console\Style\OutputStyle;
use Symfony\Component\HttpFoundation\BinaryFileResponse;


/**
 * Swoole Request => Laravel Request
 * Laravel Request => Laravel handle => Laravel Response
 * Laravel Response => Swoole Response
 */
class LaravelS extends Server
{
    /**
     * Fix conflicts of traits
     */
    use InotifyTrait, LaravelTrait, LogTrait, ProcessTitleTrait, TimerTrait, CustomProcessTrait {

        LogTrait::log insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LogTrait::logException insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LogTrait::trace insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LogTrait::info insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LogTrait::warning insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LogTrait::error insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LogTrait::callWithCatchException insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        ProcessTitleTrait::setProcessTitle insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
        LaravelTrait::initLaravel insteadof TimerTrait, CustomProcessTrait;
    }
    /**@var array */
    protected $laravelConf;

    /**@var Laravel */
    protected $laravel;

    public function __construct(array $svrConf, array $laravelConf)
    {
        parent::__construct($svrConf);
        $this->laravelConf = $laravelConf;

        $timerCfg = isset($this->conf['timer']) ? $this->conf['timer'] : [];
        $timerCfg['process_prefix'] = $svrConf['process_prefix'];
        $this->swoole->timerProcess = $this->addTimerProcess($this->swoole, $timerCfg, $this->laravelConf);


        $inotifyCfg = isset($this->conf['inotify_reload']) ? $this->conf['inotify_reload'] : [];
        if (!isset($inotifyCfg['watch_path'])) {
            $inotifyCfg['watch_path'] = $this->laravelConf['root_path'];
        }
        $inotifyCfg['process_prefix'] = $svrConf['process_prefix'];
        $this->swoole->inotifyProcess = $this->addInotifyProcess($this->swoole, $inotifyCfg);


        $processes = isset($this->conf['processes']) ? $this->conf['processes'] : [];
        $this->swoole->customProcesses = $this->addCustomProcesses($this->swoole, $svrConf['process_prefix'], $processes, $this->laravelConf);

        $this->swoole->customProcessPids = [];

    }

    protected function bindWebSocketEvent()
    {
        parent::bindWebSocketEvent();

        if ($this->enableWebSocket) {
            $eventHandler = function ($method, array $params) {
                $this->callWithCatchException(function () use ($method, $params) {
                    call_user_func_array([$this->getWebSocketHandler(), $method], $params);
                });
            };

            $this->swoole->on('Open', function (WebSocketServer $server, SwooleRequest $request) use ($eventHandler) {
                // Start Laravel's lifetime, then support session ...middleware.
                $laravelRequest = $this->convertRequest($this->laravel, $request);
                $this->laravel->bindRequest($laravelRequest);
                $this->laravel->handleDynamic($laravelRequest);
                $eventHandler('onOpen', func_get_args());
                $this->laravel->saveSession();
                $this->laravel->clean();
            });
        }
    }

    public function onWorkerStart(HttpServer $server, $workerId)
    {
        parent::onWorkerStart($server, $workerId);

        // To implement gracefully reload
        // Delay to create Laravel
        // Delay to include Laravel's autoload.php
        $this->laravel = $this->initLaravel($this->laravelConf, $this->swoole);

        // Fire WorkerStart event
        $this->fireEvent('WorkerStart', WorkerStartInterface::class, func_get_args());
    }

    public function onWorkerStop(HttpServer $server, $workerId)
    {
        parent::onWorkerStop($server, $workerId);

        // Fire WorkerStop event
        $this->fireEvent('WorkerStop', WorkerStopInterface::class, func_get_args());
    }

    public function onWorkerError(HttpServer $server, $workerId, $workerPId, $exitCode, $signal)
    {
        parent::onWorkerError($server, $workerId, $workerPId, $exitCode, $signal);

        // Fire WorkerError event
        $this->fireEvent('WorkerError', WorkerErrorInterface::class, func_get_args());
    }

    public function onPipeMessage(HttpServer $server, $srcWorkerId, $message)
    {
        // Save the PID file of the custom processes
        if (isset($message['custom_process_pid'])) {
            $server->customProcessPids[] = $message['custom_process_pid'];

            $processCount = count($server->customProcesses);

            $pidCount = count($server->customProcessPids);
            if ($pidCount !== $processCount) {
                return;
            }
            $pidfile = dirname($server->setting['pid_file']) . '/laravels-custom-processes.pid';
            file_put_contents($pidfile, implode(',', $server->customProcessPids));
            return;
        }

        parent::onPipeMessage($server, $srcWorkerId, $message);
    }

    protected function convertRequest(Laravel $laravel, SwooleRequest $request)
    {
        $rawGlobals = $laravel->getRawGlobals();
        $server = isset($rawGlobals['_SERVER']) ? $rawGlobals['_SERVER'] : [];
        $env = isset($rawGlobals['_ENV']) ? $rawGlobals['_ENV'] : [];
        return (new Request($request))->toIlluminateRequest($server, $env);
    }

    public function onRequest(SwooleRequest $swooleRequest, SwooleResponse $swooleResponse)
    {
        try {
            parent::onRequest($swooleRequest, $swooleResponse);
            $laravelRequest = $this->convertRequest($this->laravel, $swooleRequest);
            $this->laravel->bindRequest($laravelRequest);
            $this->laravel->fireEvent('laravels.received_request', [$laravelRequest]);
            $success = $this->handleStaticResource($this->laravel, $laravelRequest, $swooleResponse);
            if ($success === false) {
                $this->handleDynamicResource($this->laravel, $laravelRequest, $swooleResponse);
            }
        } catch (\Exception $e) {
            $this->handleException($e, $swooleResponse);
        } catch (\Throwable $e) {
            $this->handleException($e, $swooleResponse);
        }
    }

    /**
     * @param \Exception|\Throwable $e
     * @param SwooleResponse $response
     */
    protected function handleException($e, SwooleResponse $response)
    {
        $error = sprintf(
            'onRequest: Uncaught exception "%s"([%d]%s) at %s:%s, %s%s',
            get_class($e),
            $e->getCode(),
            $e->getMessage(),
            $e->getFile(),
            $e->getLine(),
            PHP_EOL,
            $e->getTraceAsString()
        );
        $this->error($error);
        try {
            $response->status(500);
            $response->end('Oops! An unexpected error occurred: ' . $e->getMessage());
        } catch (\Exception $e) {
            $this->logException($e);
        }
    }

    protected function handleStaticResource(Laravel $laravel, IlluminateRequest $laravelRequest, SwooleResponse $swooleResponse)
    {
        // For Swoole < 1.9.17
        if (!empty($this->conf['handle_static'])) {
            $laravelResponse = $laravel->handleStatic($laravelRequest);
            if ($laravelResponse !== false) {
                $laravelResponse->headers->set('Server', $this->conf['server'], true);
                $laravel->fireEvent('laravels.generated_response', [$laravelRequest, $laravelResponse]);
                (new StaticResponse($swooleResponse, $laravelResponse))->send($this->conf['enable_gzip']);
                return true;
            }
        }
        return false;
    }

    protected function handleDynamicResource(Laravel $laravel, IlluminateRequest $laravelRequest, SwooleResponse $swooleResponse)
    {
        $laravelResponse = $laravel->handleDynamic($laravelRequest);
        $laravelResponse->headers->set('Server', $this->conf['server'], true);
        $laravel->fireEvent('laravels.generated_response', [$laravelRequest, $laravelResponse]);
        if ($laravelResponse instanceof BinaryFileResponse) {
            $response = new StaticResponse($swooleResponse, $laravelResponse);
        } else {
            $response = new DynamicResponse($swooleResponse, $laravelResponse);
        }
        $response->send($this->conf['enable_gzip']);
        $laravel->clean();
        return true;
    }

    /**@var OutputStyle */
    protected static $outputStyle;

    public static function setOutputStyle(OutputStyle $outputStyle)
    {
        static::$outputStyle = $outputStyle;
    }

    public static function getOutputStyle()
    {
        return static::$outputStyle;
    }
}


1			<?php
2
3			namespace Hhxsv5\LaravelS;
4
5			use Hhxsv5\LaravelS\Illuminate\Laravel;
6			use Hhxsv5\LaravelS\Swoole\DynamicResponse;
7			use Hhxsv5\LaravelS\Swoole\Events\WorkerErrorInterface;
8			use Hhxsv5\LaravelS\Swoole\Events\WorkerStartInterface;
9			use Hhxsv5\LaravelS\Swoole\Events\WorkerStopInterface;
10			use Hhxsv5\LaravelS\Swoole\Request;
11			use Hhxsv5\LaravelS\Swoole\Server;
12			use Hhxsv5\LaravelS\Swoole\StaticResponse;
13			use Hhxsv5\LaravelS\Swoole\Traits\CustomProcessTrait;
14			use Hhxsv5\LaravelS\Swoole\Traits\InotifyTrait;
15			use Hhxsv5\LaravelS\Swoole\Traits\LaravelTrait;
16			use Hhxsv5\LaravelS\Swoole\Traits\LogTrait;
17			use Hhxsv5\LaravelS\Swoole\Traits\ProcessTitleTrait;
18			use Hhxsv5\LaravelS\Swoole\Traits\TimerTrait;
19			use Illuminate\Http\Request as IlluminateRequest;
20			use Swoole\Http\Request as SwooleRequest;
21			use Swoole\Http\Response as SwooleResponse;
22			use Swoole\Http\Server as HttpServer;
23			use Swoole\WebSocket\Server as WebSocketServer;
24			use Symfony\Component\Console\Style\OutputStyle;
25			use Symfony\Component\HttpFoundation\BinaryFileResponse;
26
27
28			/**
29			* Swoole Request => Laravel Request
30			* Laravel Request => Laravel handle => Laravel Response
31			* Laravel Response => Swoole Response
32			*/
33			class LaravelS extends Server
34			{
35			/**
36			* Fix conflicts of traits
37			*/
38			use InotifyTrait, LaravelTrait, LogTrait, ProcessTitleTrait, TimerTrait, CustomProcessTrait {
			0 ignored issues – show Bug introduced 2019-02-26 09:53 UTC by Report Bug Copy Issue Report The trait `Hhxsv5\LaravelS\Swoole\Traits\CustomProcessTrait` requires the property `$pid` which is not provided by `Hhxsv5\LaravelS\LaravelS`. Loading history... introduced 2019-05-10 07:06 UTC by Report Bug Copy Issue Report The trait `Hhxsv5\LaravelS\Swoole\Traits\TimerTrait` requires some properties which are not provided by `Hhxsv5\LaravelS\LaravelS`: `$setting`, `$pid` Loading history...
39			LogTrait::log insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
40			LogTrait::logException insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
41			LogTrait::trace insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
42			LogTrait::info insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
43			LogTrait::warning insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
44			LogTrait::error insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
45			LogTrait::callWithCatchException insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
46			ProcessTitleTrait::setProcessTitle insteadof InotifyTrait, TimerTrait, CustomProcessTrait;
47			LaravelTrait::initLaravel insteadof TimerTrait, CustomProcessTrait;
48			}
49			/*@var array /
50			protected $laravelConf;
51
52			/*@var Laravel /
53			protected $laravel;
54
55			public function __construct(array $svrConf, array $laravelConf)
56			{
57			parent::__construct($svrConf);
58			$this->laravelConf = $laravelConf;
59
60			$timerCfg = isset($this->conf['timer']) ? $this->conf['timer'] : [];
61			$timerCfg['process_prefix'] = $svrConf['process_prefix'];
62			$this->swoole->timerProcess = $this->addTimerProcess($this->swoole, $timerCfg, $this->laravelConf);
			0 ignored issues – show Bug introduced 2019-02-28 10:10 UTC by Report Bug Copy Issue Report The property `timerProcess` does not seem to exist on `Swoole\Http\Server`. Loading history... Bug introduced 2019-02-28 10:10 UTC by Report Bug Copy Issue Report The property `timerProcess` does not seem to exist on `Swoole\WebSocket\Server`. Loading history...
63
64			$inotifyCfg = isset($this->conf['inotify_reload']) ? $this->conf['inotify_reload'] : [];
65			if (!isset($inotifyCfg['watch_path'])) {
66			$inotifyCfg['watch_path'] = $this->laravelConf['root_path'];
67			}
68			$inotifyCfg['process_prefix'] = $svrConf['process_prefix'];
69			$this->swoole->inotifyProcess = $this->addInotifyProcess($this->swoole, $inotifyCfg);
			0 ignored issues – show Bug introduced 2019-02-28 10:10 UTC by Report Bug Copy Issue Report The property `inotifyProcess` does not seem to exist on `Swoole\Http\Server`. Loading history... Bug introduced 2019-02-28 10:10 UTC by Report Bug Copy Issue Report The property `inotifyProcess` does not seem to exist on `Swoole\WebSocket\Server`. Loading history...
70
71			$processes = isset($this->conf['processes']) ? $this->conf['processes'] : [];
72			$this->swoole->customProcesses = $this->addCustomProcesses($this->swoole, $svrConf['process_prefix'], $processes, $this->laravelConf);
			0 ignored issues – show Bug introduced 2019-02-28 10:10 UTC by Report Bug Copy Issue Report The property `customProcesses` does not seem to exist on `Swoole\Http\Server`. Loading history... Bug introduced 2019-02-28 10:10 UTC by Report Bug Copy Issue Report The property `customProcesses` does not seem to exist on `Swoole\WebSocket\Server`. Loading history...
73			$this->swoole->customProcessPids = [];
			0 ignored issues – show Bug introduced 2019-05-10 07:06 UTC by Report Bug Copy Issue Report The property `customProcessPids` does not seem to exist on `Swoole\WebSocket\Server`. Loading history... Bug introduced 2019-05-10 07:06 UTC by Report Bug Copy Issue Report The property `customProcessPids` does not seem to exist on `Swoole\Http\Server`. Loading history...
74			}
75
76			protected function bindWebSocketEvent()
77			{
78			parent::bindWebSocketEvent();
79
80			if ($this->enableWebSocket) {
81			$eventHandler = function ($method, array $params) {
82			$this->callWithCatchException(function () use ($method, $params) {
83			call_user_func_array([$this->getWebSocketHandler(), $method], $params);
84			});
85			};
86
87			$this->swoole->on('Open', function (WebSocketServer $server, SwooleRequest $request) use ($eventHandler) {
88			// Start Laravel's lifetime, then support session ...middleware.
89			$laravelRequest = $this->convertRequest($this->laravel, $request);
90			$this->laravel->bindRequest($laravelRequest);
91			$this->laravel->handleDynamic($laravelRequest);
92			$eventHandler('onOpen', func_get_args());
93			$this->laravel->saveSession();
94			$this->laravel->clean();
95			});
96			}
97			}
98
99			public function onWorkerStart(HttpServer $server, $workerId)
100			{
101			parent::onWorkerStart($server, $workerId);
102
103			// To implement gracefully reload
104			// Delay to create Laravel
105			// Delay to include Laravel's autoload.php
106			$this->laravel = $this->initLaravel($this->laravelConf, $this->swoole);
107
108			// Fire WorkerStart event
109			$this->fireEvent('WorkerStart', WorkerStartInterface::class, func_get_args());
110			}
111
112			public function onWorkerStop(HttpServer $server, $workerId)
113			{
114			parent::onWorkerStop($server, $workerId);
115
116			// Fire WorkerStop event
117			$this->fireEvent('WorkerStop', WorkerStopInterface::class, func_get_args());
118			}
119
120			public function onWorkerError(HttpServer $server, $workerId, $workerPId, $exitCode, $signal)
121			{
122			parent::onWorkerError($server, $workerId, $workerPId, $exitCode, $signal);
123
124			// Fire WorkerError event
125			$this->fireEvent('WorkerError', WorkerErrorInterface::class, func_get_args());
126			}
127
128			public function onPipeMessage(HttpServer $server, $srcWorkerId, $message)
129			{
130			// Save the PID file of the custom processes
131			if (isset($message['custom_process_pid'])) {
132			$server->customProcessPids[] = $message['custom_process_pid'];
			0 ignored issues – show Bug introduced 2019-05-10 07:06 UTC by Report Bug Copy Issue Report The property `customProcessPids` does not seem to exist on `Swoole\Http\Server`. Loading history...
133			$processCount = count($server->customProcesses);
			0 ignored issues – show Bug introduced 2019-05-10 07:06 UTC by Report Bug Copy Issue Report The property `customProcesses` does not seem to exist on `Swoole\Http\Server`. Loading history...
134			$pidCount = count($server->customProcessPids);
135			if ($pidCount !== $processCount) {
136			return;
137			}
138			$pidfile = dirname($server->setting['pid_file']) . '/laravels-custom-processes.pid';
139			file_put_contents($pidfile, implode(',', $server->customProcessPids));
140			return;
141			}
142
143			parent::onPipeMessage($server, $srcWorkerId, $message);
144			}
145
146			protected function convertRequest(Laravel $laravel, SwooleRequest $request)
147			{
148			$rawGlobals = $laravel->getRawGlobals();
149			$server = isset($rawGlobals['_SERVER']) ? $rawGlobals['_SERVER'] : [];
150			$env = isset($rawGlobals['_ENV']) ? $rawGlobals['_ENV'] : [];
151			return (new Request($request))->toIlluminateRequest($server, $env);
152			}
153
154			public function onRequest(SwooleRequest $swooleRequest, SwooleResponse $swooleResponse)
155			{
156			try {
157			parent::onRequest($swooleRequest, $swooleResponse);
158			$laravelRequest = $this->convertRequest($this->laravel, $swooleRequest);
159			$this->laravel->bindRequest($laravelRequest);
160			$this->laravel->fireEvent('laravels.received_request', [$laravelRequest]);
161			$success = $this->handleStaticResource($this->laravel, $laravelRequest, $swooleResponse);
162			if ($success === false) {
163			$this->handleDynamicResource($this->laravel, $laravelRequest, $swooleResponse);
164			}
165			} catch (\Exception $e) {
166			$this->handleException($e, $swooleResponse);
167			} catch (\Throwable $e) {
168			$this->handleException($e, $swooleResponse);
169			}
170			}
171
172			/**
173			* @param \Exception\|\Throwable $e
174			* @param SwooleResponse $response
175			*/
176			protected function handleException($e, SwooleResponse $response)
177			{
178			$error = sprintf(
179			'onRequest: Uncaught exception "%s"([%d]%s) at %s:%s, %s%s',
180			get_class($e),
181			$e->getCode(),
182			$e->getMessage(),
183			$e->getFile(),
184			$e->getLine(),
185			PHP_EOL,
186			$e->getTraceAsString()
187			);
188			$this->error($error);
189			try {
190			$response->status(500);
191			$response->end('Oops! An unexpected error occurred: ' . $e->getMessage());
192			} catch (\Exception $e) {
193			$this->logException($e);
194			}
195			}
196
197			protected function handleStaticResource(Laravel $laravel, IlluminateRequest $laravelRequest, SwooleResponse $swooleResponse)
198			{
199			// For Swoole < 1.9.17
200			if (!empty($this->conf['handle_static'])) {
201			$laravelResponse = $laravel->handleStatic($laravelRequest);
202			if ($laravelResponse !== false) {
203			$laravelResponse->headers->set('Server', $this->conf['server'], true);
204			$laravel->fireEvent('laravels.generated_response', [$laravelRequest, $laravelResponse]);
205			(new StaticResponse($swooleResponse, $laravelResponse))->send($this->conf['enable_gzip']);
206			return true;
207			}
208			}
209			return false;
210			}
211
212			protected function handleDynamicResource(Laravel $laravel, IlluminateRequest $laravelRequest, SwooleResponse $swooleResponse)
213			{
214			$laravelResponse = $laravel->handleDynamic($laravelRequest);
215			$laravelResponse->headers->set('Server', $this->conf['server'], true);
216			$laravel->fireEvent('laravels.generated_response', [$laravelRequest, $laravelResponse]);
217			if ($laravelResponse instanceof BinaryFileResponse) {
218			$response = new StaticResponse($swooleResponse, $laravelResponse);
219			} else {
220			$response = new DynamicResponse($swooleResponse, $laravelResponse);
221			}
222			$response->send($this->conf['enable_gzip']);
223			$laravel->clean();
224			return true;
225			}
226
227			/*@var OutputStyle /
228			protected static $outputStyle;
229
230			public static function setOutputStyle(OutputStyle $outputStyle)
231			{
232			static::$outputStyle = $outputStyle;
233			}
234
235			public static function getOutputStyle()
236			{
237			return static::$outputStyle;
238			}
239			}
240

hhxsv5 / laravel-s

Push — master ( 50b448...b57b98 )

LaravelS::onPipeMessage() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like