swooletw / laravel-swoole

src/Commands/HttpServerCommand.php

Spacing +9 added lines, -9 removed lines

@@ -102,7 +102,7 @@ 
     {
         $pid = $this->getPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
             exit(1);
         }
@@ -144,7 +144,7 @@ 
     {
         $pid = $this->getPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
             exit(1);
         }
@@ -153,7 +153,7 @@ 
 
         $isRunning = $this->killProcess($pid, SIGUSR1);
 
-        if (! $isRunning) {
+        if (!$isRunning) {
             $this->error('> failure');
             exit(1);
         }
@@ -211,7 +211,7 @@ 
     {
         $this->action = $this->argument('action');
 
-        if (! in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'])) {
+        if (!in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'])) {
             $this->error("Invalid argument '{$this->action}'. Expected 'start', 'stop', 'restart', 'reload' or 'infos'.");
             exit(1);
         }
@@ -225,13 +225,13 @@ 
      */
     protected function isRunning($pid)
     {
-        if (! $pid) {
+        if (!$pid) {
             return false;
         }
 
         Process::kill($pid, 0);
 
-        return ! swoole_errno();
+        return !swoole_errno();
     }
 
     /**
@@ -250,7 +250,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning($pid)) {
+                if (!$this->isRunning($pid)) {
                     break;
                 }
 
@@ -278,7 +278,7 @@ 
         if (file_exists($path)) {
             $pid = (int) file_get_contents($path);
 
-            if (! $pid) {
+            if (!$pid) {
                 $this->removePidFile();
             } else {
                 $this->pid = $pid;
@@ -323,7 +323,7 @@ 
     {
         if (strtoupper(substr(PHP_OS, 0, 3)) === 'WIN') {
             throw new \RuntimeException("Swoole extension doesn't support Windows OS yet.");
-        } elseif (! extension_loaded('swoole')) {
+        } elseif (!extension_loaded('swoole')) {
             throw new \RuntimeException("Can't detect Swoole extension installed.");
         }
     }

src/Websocket/Rooms/RedisRoom.php

Spacing +3 added lines, -3 removed lines

@@ -91,7 +91,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function ($pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function($pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->sadd($redisKey, $value);
             }
@@ -105,7 +105,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function ($pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function($pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->srem($redisKey, $value);
             }
@@ -126,7 +126,7 @@ 
 
     protected function checkTable(string $table)
     {
-        if (! in_array($table, ['rooms', 'fds'])) {
+        if (!in_array($table, ['rooms', 'fds'])) {
             throw new \InvalidArgumentException('invalid table name.');
         }
     }

src/Websocket/Rooms/TableRoom.php

Spacing +2 added lines, -2 removed lines

@@ -55,7 +55,7 @@ 
         foreach ($rooms as $room) {
             $fds = $this->getClients($room);
 
-            if (! in_array($fd, $fds)) {
+            if (!in_array($fd, $fds)) {
                 continue;
             }
 
@@ -122,7 +122,7 @@ 
 
     protected function checkTable(string $table)
     {
-        if (! property_exists($this, $table) || ! $this->$table instanceof Table) {
+        if (!property_exists($this, $table) || !$this->$table instanceof Table) {
             throw new \InvalidArgumentException('invalid table name.');
         }
     }

src/Websocket/SocketIO/Packet.php

Spacing +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
     {
         $type = $packet[0] ?? null;
 
-        if (! array_key_exists($type, static::$socketTypes)) {
+        if (!array_key_exists($type, static::$socketTypes)) {
             return null;
         }
 

src/Websocket/SocketIO/WebsocketHandler.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
      */
     public function onOpen($fd, Request $request)
     {
-        if (! $request->input('sid')) {
+        if (!$request->input('sid')) {
             $payload = json_encode([
                 'sid' => base64_encode(uniqid()),
                 'upgrades' => [],

src/Websocket/Authenticatable.php

Spacing +4 added lines, -4 removed lines

@@ -44,7 +44,7 @@ 
     {
         $users = is_object($users) ? func_get_args() : $users;
 
-        $userIds = array_map(function ($user) {
+        $userIds = array_map(function($user) {
             $this->checkUser($user);
             return $user->getAuthIdentifier();
         }, $users);
@@ -72,7 +72,7 @@ 
      */
     public function getUserId()
     {
-        if (! is_null($this->userId)) {
+        if (!is_null($this->userId)) {
             return $this->userId;
         }
 
@@ -92,7 +92,7 @@ 
      */
     public function isUserIdOnline($userId)
     {
-        return ! empty($this->room->getClients(static::USER_PREFIX . $userId));
+        return !empty($this->room->getClients(static::USER_PREFIX . $userId));
     }
 
     /**
@@ -100,7 +100,7 @@ 
      */
     protected function checkUser($user)
     {
-        if (! $user instanceOf AuthenticatableContract) {
+        if (!$user instanceOf AuthenticatableContract) {
             throw new InvalidArgumentException('user object must implement ' . AuthenticatableContract::class);
         }
     }

src/Websocket/CanWebsocket.php

Spacing +10 added lines, -10 removed lines

@@ -65,7 +65,7 @@ 
             $application = $this->sandbox->getLaravelApp();
             $this->sandbox->enable();
             // 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
@@ -130,7 +130,7 @@ 
      */
     public function onClose(Server $server, $fd, $reactorId)
     {
-        if (! $this->isWebsocket($fd)) {
+        if (!$this->isWebsocket($fd)) {
             return;
         }
 
@@ -161,12 +161,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;
@@ -176,7 +176,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);
@@ -220,13 +220,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));
         }
 
@@ -251,7 +251,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');
@@ -262,7 +262,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');
@@ -275,7 +275,7 @@ 
     {
         $routePath = $this->container['config']->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 

src/Websocket/Middleware/StartSession.php

Spacing +3 added lines, -3 removed lines

@@ -53,7 +53,7 @@ 
      */
     protected function startSession(Request $request)
     {
-        return tap($this->getSession($request), function ($session) use ($request) {
+        return tap($this->getSession($request), function($session) use ($request) {
             $session->setRequestOnHandler($request);
 
             $session->start();
@@ -68,7 +68,7 @@ 
      */
     public function getSession(Request $request)
     {
-        return tap($this->manager->driver(), function ($session) use ($request) {
+        return tap($this->manager->driver(), function($session) use ($request) {
             $session->setId($request->cookies->get($session->getName()));
         });
     }
@@ -80,6 +80,6 @@ 
      */
     protected function sessionConfigured()
     {
-        return ! is_null($this->manager->getSessionConfig()['driver'] ?? null);
+        return !is_null($this->manager->getSessionConfig()['driver'] ?? null);
     }
 }

src/Websocket/Middleware/Authenticate.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
     {
         try {
             if ($user = $this->auth->authenticate()) {
-                $request->setUserResolver(function () use ($user) {
+                $request->setUserResolver(function() use ($user) {
                     return $user;
                 });
             }