swooletw / laravel-swoole

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/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;
                 });
             }

src/Websocket/Websocket.php

Spacing +7 added lines, -7 removed lines

@@ -99,7 +99,7 @@ 
         $values = is_string($values) || is_integer($values) ? func_get_args() : $values;
 
         foreach ($values as $value) {
-            if (! in_array($value, $this->to)) {
+            if (!in_array($value, $this->to)) {
                 $this->to[] = $value;
             }
         }
@@ -144,7 +144,7 @@ 
     public function emit(string $event, $data)
     {
         $fds = $this->getFds();
-        $assigned = ! empty($this->to);
+        $assigned = !empty($this->to);
 
         // if no fds are found, but rooms are assigned
         // that means trying to emit to a non-existing room
@@ -190,7 +190,7 @@ 
      */
     public function on(string $event, $callback)
     {
-        if (! is_string($callback) && ! is_callable($callback)) {
+        if (!is_string($callback) && !is_callable($callback)) {
             throw new InvalidArgumentException(
                 'Invalid websocket callback. Must be a string or callable.'
             );
@@ -219,7 +219,7 @@ 
      */
     public function call(string $event, $data = null)
     {
-        if (! $this->eventExists($event)) {
+        if (!$this->eventExists($event)) {
             return null;
         }
 
@@ -289,7 +289,7 @@ 
      */
     protected function getFds()
     {
-        $fds = array_filter($this->to, function ($value) {
+        $fds = array_filter($this->to, function($value) {
             return is_integer($value);
         });
         $rooms = array_diff($this->to, $fds);
@@ -356,7 +356,7 @@ 
     {
         $pipeline = $this->pipeline;
 
-        $closure = function () use ($container) {
+        $closure = function() use ($container) {
             $this->container = $container;
         };
 
@@ -375,7 +375,7 @@ 
         return $this->pipeline
             ->send($request)
             ->through($this->middleware)
-            ->then(function ($request) {
+            ->then(function($request) {
                 return $request;
             });
     }

routes/websocket.php

Spacing +3 added lines, -3 removed lines

@@ -12,15 +12,15 @@
 |
 */
 
-Websocket::on('connect', function ($websocket, Request $request) {
+Websocket::on('connect', function($websocket, Request $request) {
     // called while socket on connect
 });
 
-Websocket::on('disconnect', function ($websocket) {
+Websocket::on('disconnect', function($websocket) {
     // called while socket on disconnect
 });
 
-Websocket::on('example', function ($websocket, $data) {
+Websocket::on('example', function($websocket, $data) {
     $websocket->emit('message', $data);
 });