hhxsv5 / laravel-s

src/Swoole/Server.php

Spacing +18 added lines, -18 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($event, array $params)
     {
-        return $this->callWithCatchException(function () use ($event, $params) {
+        return $this->callWithCatchException(function() use ($event, $params) {
             $handler = $this->getWebSocketHandler();
 
             if (method_exists($handler, $event)) {
@@ -116,19 +116,19 @@ 
     protected function bindWebSocketEvents()
     {
         if ($this->enableWebSocket) {
-            $this->swoole->on('HandShake', function () {
+            $this->swoole->on('HandShake', function() {
                 return $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());
@@ -156,9 +156,9 @@ 
             $port->set(empty($socket['settings']) ? [] : $socket['settings']);
 
             $handlerClass = $socket['handler'];
-            $eventHandler = function ($event, array $params) use ($port, $handlerClass) {
+            $eventHandler = function($event, array $params) use ($port, $handlerClass) {
                 $handler = $this->getSocketHandler($port, $handlerClass);
-                return $this->callWithCatchException(function () use ($handler, $event, $params) {
+                return $this->callWithCatchException(function() use ($handler, $event, $params) {
                     if (method_exists($handler, $event)) {
                         if ($event === 'onHandShake' || $event === 'onRequest') {
                             $this->startHandleHttp($params[0]);
@@ -184,7 +184,7 @@ 
                     // Set default HandShake
                     if ($event === 'onHandShake' && method_exists($handler, 'onOpen')) {
                         $this->startHandleHttp($params[0]);
-                        $params[] = function () use ($handler, $params) {
+                        $params[] = function() use ($handler, $params) {
                             call_user_func_array([$handler, 'onOpen'], func_get_args());
                             $this->endHandleHttp($params[0]);
                         };
@@ -208,8 +208,8 @@ 
                 'BufferEmpty',
             ];
             foreach ($events as $event) {
-                $port->on($event, function () use ($event, $eventHandler) {
-                    return $eventHandler('on' . $event, func_get_args());
+                $port->on($event, function() use ($event, $eventHandler) {
+                    return $eventHandler('on'.$event, func_get_args());
                 });
             }
         }
@@ -258,7 +258,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) {
@@ -355,7 +355,7 @@ 
         $headers = [
             'Upgrade'               => 'websocket',
             'Connection'            => 'Upgrade',
-            'Sec-WebSocket-Accept'  => base64_encode(sha1($secKey . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
+            'Sec-WebSocket-Accept'  => base64_encode(sha1($secKey.'258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true)),
             'Sec-WebSocket-Version' => '13',
         ];
 
@@ -375,7 +375,7 @@ 
 
         if (is_callable($onOpen)) {
             if (method_exists($this->swoole, 'defer')) {
-                $this->swoole->defer(function () use ($onOpen, $request) {
+                $this->swoole->defer(function() use ($onOpen, $request) {
                     call_user_func($onOpen, $this->swoole, $request);
                 });
             } else {
@@ -412,7 +412,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());
         }
@@ -421,7 +421,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -430,7 +430,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(
@@ -440,7 +440,7 @@ 
                         )
                     );
                 }
-                $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+                $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                     call_user_func_array([(new $eventHandler), 'handle'], $arguments);
                 });
             }