@@ -21,7 +21,7 @@ discard block |
||
| 21 | 21 | |
| 22 | 22 | public function handle() |
| 23 | 23 | { |
| 24 | - $action = (string)$this->argument('action'); |
|
| 24 | + $action = (string) $this->argument('action'); |
|
| 25 | 25 | switch ($action) { |
| 26 | 26 | case 'publish': |
| 27 | 27 | $this->publish(); |
@@ -53,7 +53,7 @@ discard block |
||
| 53 | 53 | { |
| 54 | 54 | // Load configuration laravel.php manually for Lumen |
| 55 | 55 | $basePath = config('laravels.laravel_base_path') ?: base_path(); |
| 56 | - if ($this->isLumen() && file_exists($basePath . '/config/laravels.php')) { |
|
| 56 | + if ($this->isLumen() && file_exists($basePath.'/config/laravels.php')) { |
|
| 57 | 57 | $this->getLaravel()->configure('laravels'); |
| 58 | 58 | } |
| 59 | 59 | } |
@@ -110,7 +110,7 @@ discard block |
||
| 110 | 110 | $laravelSVersion, |
| 111 | 111 | ], |
| 112 | 112 | [ |
| 113 | - $this->getApplication()->getName() . ' [<info>' . env('APP_ENV', config('app.env')) . '</info>]', |
|
| 113 | + $this->getApplication()->getName().' [<info>'.env('APP_ENV', config('app.env')).'</info>]', |
|
| 114 | 114 | $this->getApplication()->getVersion(), |
| 115 | 115 | ], |
| 116 | 116 | ]); |
@@ -120,7 +120,7 @@ discard block |
||
| 120 | 120 | { |
| 121 | 121 | $this->comment('>>> Protocols'); |
| 122 | 122 | |
| 123 | - $config = unserialize((string)file_get_contents($this->getConfPath())); |
|
| 123 | + $config = unserialize((string) file_get_contents($this->getConfPath())); |
|
| 124 | 124 | $ssl = isset($config['server']['swoole']['ssl_key_file'], $config['server']['swoole']['ssl_cert_file']); |
| 125 | 125 | $socketType = isset($config['server']['socket_type']) ? $config['server']['socket_type'] : SWOOLE_SOCK_TCP; |
| 126 | 126 | if (in_array($socketType, [SWOOLE_SOCK_UNIX_DGRAM, SWOOLE_SOCK_UNIX_STREAM])) { |
@@ -160,7 +160,7 @@ discard block |
||
| 160 | 160 | continue; |
| 161 | 161 | } |
| 162 | 162 | |
| 163 | - $name = 'Port#' . $key . ' '; |
|
| 163 | + $name = 'Port#'.$key.' '; |
|
| 164 | 164 | $name .= isset($socketTypeNames[$socket['type']]) ? $socketTypeNames[$socket['type']] : 'Unknown socket'; |
| 165 | 165 | $tableRows [] = [ |
| 166 | 166 | $name, |
@@ -188,8 +188,8 @@ discard block |
||
| 188 | 188 | $laravelConf = [ |
| 189 | 189 | 'root_path' => $svrConf['laravel_base_path'], |
| 190 | 190 | 'static_path' => $svrConf['swoole']['document_root'], |
| 191 | - 'cleaners' => array_unique((array)Arr::get($svrConf, 'cleaners', [])), |
|
| 192 | - 'register_providers' => array_unique((array)Arr::get($svrConf, 'register_providers', [])), |
|
| 191 | + 'cleaners' => array_unique((array) Arr::get($svrConf, 'cleaners', [])), |
|
| 192 | + 'register_providers' => array_unique((array) Arr::get($svrConf, 'register_providers', [])), |
|
| 193 | 193 | 'destroy_controllers' => Arr::get($svrConf, 'destroy_controllers', []), |
| 194 | 194 | 'is_lumen' => $this->isLumen(), |
| 195 | 195 | '_SERVER' => $_SERVER, |
@@ -222,7 +222,7 @@ discard block |
||
| 222 | 222 | $svrConf['ignore_check_pid'] = false; |
| 223 | 223 | } |
| 224 | 224 | if (empty($svrConf['swoole']['document_root'])) { |
| 225 | - $svrConf['swoole']['document_root'] = $svrConf['laravel_base_path'] . '/public'; |
|
| 225 | + $svrConf['swoole']['document_root'] = $svrConf['laravel_base_path'].'/public'; |
|
| 226 | 226 | } |
| 227 | 227 | if ($this->option('daemonize')) { |
| 228 | 228 | $svrConf['swoole']['daemonize'] = true; |
@@ -237,7 +237,7 @@ discard block |
||
| 237 | 237 | } |
| 238 | 238 | |
| 239 | 239 | // Set X-Version |
| 240 | - $xVersion = (string)$this->option('x-version'); |
|
| 240 | + $xVersion = (string) $this->option('x-version'); |
|
| 241 | 241 | if ($xVersion !== '') { |
| 242 | 242 | $_SERVER['X_VERSION'] = $_ENV['X_VERSION'] = $xVersion; |
| 243 | 243 | } |
@@ -264,34 +264,34 @@ discard block |
||
| 264 | 264 | public function publish() |
| 265 | 265 | { |
| 266 | 266 | $basePath = config('laravels.laravel_base_path') ?: base_path(); |
| 267 | - $configPath = $basePath . '/config/laravels.php'; |
|
| 267 | + $configPath = $basePath.'/config/laravels.php'; |
|
| 268 | 268 | $todoList = [ |
| 269 | 269 | [ |
| 270 | - 'from' => realpath(__DIR__ . '/../../config/laravels.php'), |
|
| 270 | + 'from' => realpath(__DIR__.'/../../config/laravels.php'), |
|
| 271 | 271 | 'to' => $configPath, |
| 272 | 272 | 'mode' => 0644, |
| 273 | 273 | ], |
| 274 | 274 | [ |
| 275 | - 'from' => realpath(__DIR__ . '/../../bin/laravels'), |
|
| 276 | - 'to' => $basePath . '/bin/laravels', |
|
| 275 | + 'from' => realpath(__DIR__.'/../../bin/laravels'), |
|
| 276 | + 'to' => $basePath.'/bin/laravels', |
|
| 277 | 277 | 'mode' => 0755, |
| 278 | 278 | 'link' => true, |
| 279 | 279 | ], |
| 280 | 280 | [ |
| 281 | - 'from' => realpath(__DIR__ . '/../../bin/fswatch'), |
|
| 282 | - 'to' => $basePath . '/bin/fswatch', |
|
| 281 | + 'from' => realpath(__DIR__.'/../../bin/fswatch'), |
|
| 282 | + 'to' => $basePath.'/bin/fswatch', |
|
| 283 | 283 | 'mode' => 0755, |
| 284 | 284 | 'link' => true, |
| 285 | 285 | ], |
| 286 | 286 | [ |
| 287 | - 'from' => realpath(__DIR__ . '/../../bin/inotify'), |
|
| 288 | - 'to' => $basePath . '/bin/inotify', |
|
| 287 | + 'from' => realpath(__DIR__.'/../../bin/inotify'), |
|
| 288 | + 'to' => $basePath.'/bin/inotify', |
|
| 289 | 289 | 'mode' => 0755, |
| 290 | 290 | 'link' => true, |
| 291 | 291 | ], |
| 292 | 292 | ]; |
| 293 | 293 | if (file_exists($configPath)) { |
| 294 | - $choice = $this->anticipate($configPath . ' already exists, do you want to override it ? Y/N', |
|
| 294 | + $choice = $this->anticipate($configPath.' already exists, do you want to override it ? Y/N', |
|
| 295 | 295 | ['Y', 'N'], |
| 296 | 296 | 'N' |
| 297 | 297 | ); |
@@ -37,7 +37,7 @@ discard block |
||
| 37 | 37 | |
| 38 | 38 | $ip = isset($conf['listen_ip']) ? $conf['listen_ip'] : '127.0.0.1'; |
| 39 | 39 | $port = isset($conf['listen_port']) ? $conf['listen_port'] : 5200; |
| 40 | - $socketType = isset($conf['socket_type']) ? (int)$conf['socket_type'] : SWOOLE_SOCK_TCP; |
|
| 40 | + $socketType = isset($conf['socket_type']) ? (int) $conf['socket_type'] : SWOOLE_SOCK_TCP; |
|
| 41 | 41 | |
| 42 | 42 | if ($socketType === SWOOLE_SOCK_UNIX_STREAM) { |
| 43 | 43 | $socketDir = dirname($ip); |
@@ -93,7 +93,7 @@ discard block |
||
| 93 | 93 | |
| 94 | 94 | protected function triggerWebSocketEvent($event, array $params) |
| 95 | 95 | { |
| 96 | - return $this->callWithCatchException(function () use ($event, $params) { |
|
| 96 | + return $this->callWithCatchException(function() use ($event, $params) { |
|
| 97 | 97 | $handler = $this->getWebSocketHandler(); |
| 98 | 98 | |
| 99 | 99 | if (method_exists($handler, $event)) { |
@@ -108,19 +108,19 @@ discard block |
||
| 108 | 108 | protected function bindWebSocketEvents() |
| 109 | 109 | { |
| 110 | 110 | if ($this->enableWebSocket) { |
| 111 | - $this->swoole->on('HandShake', function () { |
|
| 111 | + $this->swoole->on('HandShake', function() { |
|
| 112 | 112 | return $this->triggerWebSocketEvent('onHandShake', func_get_args()); |
| 113 | 113 | }); |
| 114 | 114 | |
| 115 | - $this->swoole->on('Open', function () { |
|
| 115 | + $this->swoole->on('Open', function() { |
|
| 116 | 116 | $this->triggerWebSocketEvent('onOpen', func_get_args()); |
| 117 | 117 | }); |
| 118 | 118 | |
| 119 | - $this->swoole->on('Message', function () { |
|
| 119 | + $this->swoole->on('Message', function() { |
|
| 120 | 120 | $this->triggerWebSocketEvent('onMessage', func_get_args()); |
| 121 | 121 | }); |
| 122 | 122 | |
| 123 | - $this->swoole->on('Close', function (WebSocketServer $server, $fd, $reactorId) { |
|
| 123 | + $this->swoole->on('Close', function(WebSocketServer $server, $fd, $reactorId) { |
|
| 124 | 124 | $clientInfo = $server->getClientInfo($fd); |
| 125 | 125 | if (isset($clientInfo['websocket_status']) && $clientInfo['websocket_status'] === \WEBSOCKET_STATUS_FRAME) { |
| 126 | 126 | $this->triggerWebSocketEvent('onClose', func_get_args()); |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | |
| 133 | 133 | protected function triggerPortEvent(Port $port, $handlerClass, $event, array $params) |
| 134 | 134 | { |
| 135 | - return $this->callWithCatchException(function () use ($port, $handlerClass, $event, $params) { |
|
| 135 | + return $this->callWithCatchException(function() use ($port, $handlerClass, $event, $params) { |
|
| 136 | 136 | $handler = $this->getSocketHandler($port, $handlerClass); |
| 137 | 137 | |
| 138 | 138 | if (method_exists($handler, $event)) { |
@@ -177,8 +177,8 @@ discard block |
||
| 177 | 177 | 'BufferEmpty', |
| 178 | 178 | ]; |
| 179 | 179 | foreach ($events as $event) { |
| 180 | - $port->on($event, function () use ($port, $handlerClass, $event) { |
|
| 181 | - $this->triggerPortEvent($port, $handlerClass, 'on' . $event, func_get_args()); |
|
| 180 | + $port->on($event, function() use ($port, $handlerClass, $event) { |
|
| 181 | + $this->triggerPortEvent($port, $handlerClass, 'on'.$event, func_get_args()); |
|
| 182 | 182 | }); |
| 183 | 183 | } |
| 184 | 184 | } |
@@ -227,7 +227,7 @@ discard block |
||
| 227 | 227 | |
| 228 | 228 | protected function bindSwooleTables() |
| 229 | 229 | { |
| 230 | - $tables = isset($this->conf['swoole_tables']) ? (array)$this->conf['swoole_tables'] : []; |
|
| 230 | + $tables = isset($this->conf['swoole_tables']) ? (array) $this->conf['swoole_tables'] : []; |
|
| 231 | 231 | foreach ($tables as $name => $table) { |
| 232 | 232 | $t = new Table($table['size']); |
| 233 | 233 | foreach ($table['column'] as $column) { |
@@ -324,7 +324,7 @@ discard block |
||
| 324 | 324 | $headers = [ |
| 325 | 325 | 'Upgrade' => 'websocket', |
| 326 | 326 | 'Connection' => 'Upgrade', |
| 327 | - 'Sec-WebSocket-Accept' => base64_encode(sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)), |
|
| 327 | + 'Sec-WebSocket-Accept' => base64_encode(sha1($secKey.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)), |
|
| 328 | 328 | 'Sec-WebSocket-Version' => '13', |
| 329 | 329 | ]; |
| 330 | 330 | |
@@ -370,7 +370,7 @@ discard block |
||
| 370 | 370 | if (!($listener instanceof Listener)) { |
| 371 | 371 | throw new \InvalidArgumentException(sprintf('%s must extend the abstract class %s', $listenerClass, Listener::class)); |
| 372 | 372 | } |
| 373 | - $this->callWithCatchException(function () use ($listener) { |
|
| 373 | + $this->callWithCatchException(function() use ($listener) { |
|
| 374 | 374 | $listener->handle(); |
| 375 | 375 | }, [], $event->getTries()); |
| 376 | 376 | } |
@@ -379,7 +379,7 @@ discard block |
||
| 379 | 379 | |
| 380 | 380 | protected function handleTask(Task $task) |
| 381 | 381 | { |
| 382 | - return $this->callWithCatchException(function () use ($task) { |
|
| 382 | + return $this->callWithCatchException(function() use ($task) { |
|
| 383 | 383 | $task->handle(); |
| 384 | 384 | return true; |
| 385 | 385 | }, [], $task->getTries()); |
@@ -388,7 +388,7 @@ discard block |
||
| 388 | 388 | protected function fireEvent($event, $interface, array $arguments) |
| 389 | 389 | { |
| 390 | 390 | if (isset($this->conf['event_handlers'][$event])) { |
| 391 | - $eventHandlers = (array)$this->conf['event_handlers'][$event]; |
|
| 391 | + $eventHandlers = (array) $this->conf['event_handlers'][$event]; |
|
| 392 | 392 | foreach ($eventHandlers as $eventHandler) { |
| 393 | 393 | if (!isset(class_implements($eventHandler)[$interface])) { |
| 394 | 394 | throw new \InvalidArgumentException(sprintf( |
@@ -398,7 +398,7 @@ discard block |
||
| 398 | 398 | ) |
| 399 | 399 | ); |
| 400 | 400 | } |
| 401 | - $this->callWithCatchException(function () use ($eventHandler, $arguments) { |
|
| 401 | + $this->callWithCatchException(function() use ($eventHandler, $arguments) { |
|
| 402 | 402 | call_user_func_array([(new $eventHandler), 'handle'], $arguments); |
| 403 | 403 | }); |
| 404 | 404 | } |