swooletw / laravel-swoole

src/Websocket/CanWebsocket.php

Spacing +10 added lines, -10 removed lines

@@ -65,7 +65,7 @@ 
             $this->sandbox->enable();
             $application = $this->sandbox->getLaravelApp();
             // check if socket.io connection established
-            if (! $this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
+            if (!$this->websocketHandler->onOpen($swooleRequest->fd, $illuminateRequest)) {
                 return;
             }
             // trigger 'connect' websocket event
@@ -129,7 +129,7 @@ 
      */
     public function onClose(Server $server, $fd, $reactorId)
     {
-        if (! $this->isWebsocket($fd)) {
+        if (!$this->isWebsocket($fd)) {
             return;
         }
 
@@ -160,12 +160,12 @@ 
         $message = $this->parser->encode($event, $message);
 
         // attach sender if not broadcast
-        if (! $broadcast && $sender && ! in_array($sender, $fds)) {
+        if (!$broadcast && $sender && !in_array($sender, $fds)) {
             $fds[] = $sender;
         }
 
         // check if to broadcast all clients
-        if ($broadcast && empty($fds) && ! $assigned) {
+        if ($broadcast && empty($fds) && !$assigned) {
             foreach ($server->connections as $fd) {
                 if ($this->isWebsocket($fd)) {
                     $fds[] = $fd;
@@ -175,7 +175,7 @@ 
 
         // push message to designated fds
         foreach ($fds as $fd) {
-            if (($broadcast && $sender === (integer) $fd) || ! $server->exist($fd)) {
+            if (($broadcast && $sender === (integer) $fd) || !$server->exist($fd)) {
                 continue;
             }
             $server->push($fd, $message, $opcode);
@@ -219,13 +219,13 @@ 
     {
         $handlerClass = $this->container['config']->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new Exception('websocket handler not set in swoole_websocket config');
         }
 
         $handler = $this->app->make($handlerClass);
 
-        if (! $handler instanceof HandlerContract) {
+        if (!$handler instanceof HandlerContract) {
             throw new Exception(sprintf('%s must implement %s', get_class($handler), HandlerContract::class));
         }
 
@@ -250,7 +250,7 @@ 
      */
     protected function bindRoom()
     {
-        $this->app->singleton(RoomContract::class, function ($app) {
+        $this->app->singleton(RoomContract::class, function($app) {
             return $this->websocketRoom;
         });
         $this->app->alias(RoomContract::class, 'swoole.room');
@@ -261,7 +261,7 @@ 
      */
     protected function bindWebsocket()
     {
-        $this->app->singleton(Websocket::class, function ($app) {
+        $this->app->singleton(Websocket::class, function($app) {
             return $this->websocket = new Websocket($app['swoole.room'], new Pipeline);
         });
         $this->app->alias(Websocket::class, 'swoole.websocket');
@@ -274,7 +274,7 @@ 
     {
         $routePath = $this->container['config']->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 

src/Task/CanSwooleTask.php

Spacing +1 added lines, -1 removed lines

@@ -9,7 +9,7 @@
      */
     protected function bindSwooleTask()
     {
-        $this->app->singleton('swoole.task', function () {
+        $this->app->singleton('swoole.task', function() {
             return new SwooleTask($this);
         });
     }

src/Server/helpers.php

Spacing +2 added lines, -2 removed lines

@@ -5,7 +5,7 @@ 
 /**
  * This is only for `function not exists` in config/swoole_http.php.
  */
-if (! function_exists('swoole_cpu_num')) {
+if (!function_exists('swoole_cpu_num')) {
     function swoole_cpu_num()
     {
         return;
@@ -13,7 +13,7 @@ 
 }
 
 
-if (! function_exists('swoole_async_task')) {
+if (!function_exists('swoole_async_task')) {
     /**
      * Swoole Async task helper.
      *