LaravelS::onStart() - Code Metrics - Inspection of "fix ServerStart event" - hhxsv5/laravel-s - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( fcbcd2...296f3b )

by Biao

created 2019-09-26 16:07 UTC

LaravelS::onStart() A

↳ Parent: LaravelS

Complexity

Conditions	2
Paths	2

Size

Total Lines	9
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	2
eloc	4
c	1
b	0
f	0
nc	2
nop	1
dl	0
loc	9
rs	10

<?php

namespace Hhxsv5\LaravelS;

use Hhxsv5\LaravelS\Illuminate\Laravel;
use Hhxsv5\LaravelS\Swoole\DynamicResponse;
use Hhxsv5\LaravelS\Swoole\Events\ServerStartInterface;
use Hhxsv5\LaravelS\Swoole\Events\ServerStopInterface;
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;


    /**@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, $this->laravelConf);


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


        // Fire ServerStart event
        if (isset($this->conf['event_handlers']['ServerStart'])) {
            Laravel::autoload($this->laravelConf['root_path']);
            $this->fireEvent('ServerStart', ServerStartInterface::class, [$this->swoole]);
        }
    }

    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->cleanProviders();
                $this->laravel->handleDynamic($laravelRequest);
                $eventHandler('onOpen', func_get_args());
                $this->laravel->saveSession();
                $this->laravel->clean();
            });
        }
    }

    public function onShutdown(HttpServer $server)
    {
        parent::onShutdown($server);

        // Fire ServerStop event
        if (isset($this->conf['event_handlers']['ServerStop'])) {
            Laravel::autoload($this->laravelConf['root_path']);
            $this->fireEvent('ServerStop', ServerStopInterface::class, [$server]);
        }
    }

    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);

        Laravel::autoload($this->laravelConf['root_path']);

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

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

hhxsv5 / laravel-s

Push — master ( fcbcd2...296f3b )

LaravelS::onStart() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like