hhxsv5 / laravel-s

src/Swoole/Timer/CheckGlobalTimerAliveCronJob.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 {
     public function interval()
     {
-        return (int)(static::GLOBAL_TIMER_LOCK_SECONDS * 0.9) * 1000;
+        return (int) (static::GLOBAL_TIMER_LOCK_SECONDS * 0.9) * 1000;
     }
 
     public function isImmediate()

src/LaravelS.php

Spacing +1 added lines, -1 removed lines

@@ -76,7 +76,7 @@
         parent::bindWebSocketEvents();
 
         if ($this->enableWebSocket) {
-            $this->swoole->on('Open', function (WebSocketServer $server, SwooleRequest $request) {
+            $this->swoole->on('Open', function(WebSocketServer $server, SwooleRequest $request) {
                 // Start Laravel's lifetime, then support session ...middleware.
                 $laravelRequest = $this->convertRequest($this->laravel, $request);
                 $this->laravel->bindRequest($laravelRequest);

src/Swoole/Server.php

Spacing +17 added lines, -17 removed lines

@@ -41,7 +41,7 @@ 
 
         $ip = isset($conf['listen_ip']) ? $conf['listen_ip'] : '127.0.0.1';
         $port = isset($conf['listen_port']) ? $conf['listen_port'] : 5200;
-        $socketType = isset($conf['socket_type']) ? (int)$conf['socket_type'] : SWOOLE_SOCK_TCP;
+        $socketType = isset($conf['socket_type']) ? (int) $conf['socket_type'] : SWOOLE_SOCK_TCP;
 
         if ($socketType === SWOOLE_SOCK_UNIX_STREAM) {
             $socketDir = dirname($ip);
@@ -97,7 +97,7 @@ 
 
     protected function triggerWebSocketEvent($method, array $params)
     {
-        $this->callWithCatchException(function () use ($method, $params) {
+        $this->callWithCatchException(function() use ($method, $params) {
             $handler = $this->getWebSocketHandler();
 
             if (method_exists($handler, $method)) {
@@ -112,19 +112,19 @@ 
     protected function bindWebSocketEvents()
     {
         if ($this->enableWebSocket) {
-            $this->swoole->on('HandShake', function () {
+            $this->swoole->on('HandShake', function() {
                 $this->triggerWebSocketEvent('onHandShake', func_get_args());
             });
 
-            $this->swoole->on('Open', function () {
+            $this->swoole->on('Open', function() {
                 $this->triggerWebSocketEvent('onOpen', func_get_args());
             });
 
-            $this->swoole->on('Message', function () {
+            $this->swoole->on('Message', function() {
                 $this->triggerWebSocketEvent('onMessage', func_get_args());
             });
 
-            $this->swoole->on('Close', function (WebSocketServer $server, $fd, $reactorId) {
+            $this->swoole->on('Close', function(WebSocketServer $server, $fd, $reactorId) {
                 $clientInfo = $server->getClientInfo($fd);
                 if (isset($clientInfo['websocket_status']) && $clientInfo['websocket_status'] === \WEBSOCKET_STATUS_FRAME) {
                     $this->triggerWebSocketEvent('onClose', func_get_args());
@@ -152,10 +152,10 @@ 
             $port->set(empty($socket['settings']) ? [] : $socket['settings']);
 
             $handlerClass = $socket['handler'];
-            $eventHandler = function ($method, array $params) use ($port, $handlerClass) {
+            $eventHandler = function($method, array $params) use ($port, $handlerClass) {
                 $handler = $this->getSocketHandler($port, $handlerClass);
                 if (method_exists($handler, $method)) {
-                    $this->callWithCatchException(function () use ($handler, $method, $params) {
+                    $this->callWithCatchException(function() use ($handler, $method, $params) {
                         call_user_func_array([$handler, $method], $params);
                     });
                 }
@@ -173,8 +173,8 @@ 
                 'BufferEmpty',
             ];
             foreach ($events as $event) {
-                $port->on($event, function () use ($event, $eventHandler) {
-                    $eventHandler('on' . $event, func_get_args());
+                $port->on($event, function() use ($event, $eventHandler) {
+                    $eventHandler('on'.$event, func_get_args());
                 });
             }
         }
@@ -213,7 +213,7 @@ 
 
     protected function bindSwooleTables()
     {
-        $tables = isset($this->conf['swoole_tables']) ? (array)$this->conf['swoole_tables'] : [];
+        $tables = isset($this->conf['swoole_tables']) ? (array) $this->conf['swoole_tables'] : [];
         foreach ($tables as $name => $table) {
             $t = new Table($table['size']);
             foreach ($table['column'] as $column) {
@@ -310,7 +310,7 @@ 
         $headers = [
             'Upgrade'               => 'websocket',
             'Connection'            => 'Upgrade',
-            'Sec-WebSocket-Accept'  => base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
+            'Sec-WebSocket-Accept'  => base64_encode(sha1($key.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
             'Sec-WebSocket-Version' => '13',
         ];
 
@@ -329,7 +329,7 @@ 
         $response->end();
 
         if (method_exists($this->swoole, 'defer')) {
-            $this->swoole->defer(function () use ($request) {
+            $this->swoole->defer(function() use ($request) {
                 $this->triggerWebSocketEvent('onOpen', [$this->swoole, $request]);
             });
         } else {
@@ -364,7 +364,7 @@ 
             if (!($listener instanceof Listener)) {
                 throw new \InvalidArgumentException(sprintf('%s must extend the abstract class %s', $listenerClass, Listener::class));
             }
-            $this->callWithCatchException(function () use ($listener) {
+            $this->callWithCatchException(function() use ($listener) {
                 $listener->handle();
             }, [], $event->getTries());
         }
@@ -373,7 +373,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -382,7 +382,7 @@ 
     protected function fireEvent($event, $interface, array $arguments)
     {
         if (isset($this->conf['event_handlers'][$event])) {
-            $eventHandlers = (array)$this->conf['event_handlers'][$event];
+            $eventHandlers = (array) $this->conf['event_handlers'][$event];
             foreach ($eventHandlers as $eventHandler) {
                 if (!isset(class_implements($eventHandler)[$interface])) {
                     throw new \InvalidArgumentException(sprintf(
@@ -392,7 +392,7 @@ 
                         )
                     );
                 }
-                $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+                $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                     call_user_func_array([(new $eventHandler), 'handle'], $arguments);
                 });
             }