swooletw / laravel-swoole

src/HotReload/FSProcess.php

Spacing +3 added lines, -3 removed lines

@@ -62,8 +62,8 @@ 
      */
     public function make(?callable $callback = null)
     {
-        $mcb = function ($type, $buffer) use ($callback) {
-            if (! $this->locked && AppProcess::OUT === $type && $event = FSEventParser::toEvent($buffer)) {
+        $mcb = function($type, $buffer) use ($callback) {
+            if (!$this->locked && AppProcess::OUT === $type && $event = FSEventParser::toEvent($buffer)) {
                 $this->locked = true;
                 ($callback) ? $callback($event) : null;
                 $this->locked = false;
@@ -71,7 +71,7 @@ 
             }
         };
 
-        return new SwooleProcess(function () use ($mcb) {
+        return new SwooleProcess(function() use ($mcb) {
             (new AppProcess($this->configure()))->setTimeout(0)->run($mcb);
         }, false, false);
     }

src/Concerns/InteractsWithWebsocket.php

Spacing +11 added lines, -11 removed lines

@@ -66,7 +66,7 @@ 
             // enable sandbox
             $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, $fd, $reactorId)
     {
-        if (! $this->isServerWebsocket($fd) || ! $server instanceof Websocket) {
+        if (!$this->isServerWebsocket($fd) || !$server instanceof Websocket) {
             return;
         }
 
@@ -158,7 +158,7 @@ 
      */
     protected function isWebsocketPushPacket($packet)
     {
-        if ( !is_array($packet)) {
+        if (!is_array($packet)) {
             return false;
         }
 
@@ -180,7 +180,7 @@ 
         $payload = $this->payloadParser->encode($push->getEvent(), $push->getMessage());
 
         // attach sender if not broadcast
-        if (! $push->isBroadcast() && $push->getSender() && ! $push->hasOwnDescriptor()) {
+        if (!$push->isBroadcast() && $push->getSender() && !$push->hasOwnDescriptor()) {
             $push->addDescriptor($push->getSender());
         }
 
@@ -191,7 +191,7 @@ 
 
         // push message to designated fds
         foreach ($push->getDescriptors() as $descriptor) {
-            if ($server->exist($descriptor) || ! $push->isBroadcastToDescriptor((int) $descriptor)) {
+            if ($server->exist($descriptor) || !$push->isBroadcastToDescriptor((int) $descriptor)) {
                 $server->push($descriptor, $payload, $push->getOpcode());
             }
         }
@@ -258,7 +258,7 @@ 
      */
     protected function filterWebsocket(array $descriptors): array
     {
-        $callback = function ($descriptor) {
+        $callback = function($descriptor) {
             return $this->isServerWebsocket($descriptor);
         };
 
@@ -274,7 +274,7 @@ 
     {
         $handlerClass = $this->container->make('config')->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new WebsocketNotSetInConfigException;
         }
 
@@ -321,7 +321,7 @@ 
      */
     protected function bindRoom(): void
     {
-        $this->app->singleton(RoomContract::class, function (Container $container) {
+        $this->app->singleton(RoomContract::class, function(Container $container) {
             $config = $container->make('config');
             $driver = $config->get('swoole_websocket.default');
             $settings = $config->get("swoole_websocket.settings.{$driver}");
@@ -338,7 +338,7 @@ 
      */
     protected function bindWebsocket()
     {
-        $this->app->singleton(Websocket::class, function (Container $app) {
+        $this->app->singleton(Websocket::class, function(Container $app) {
             return new Websocket($app->make(RoomContract::class), new Pipeline($app));
         });
 
@@ -353,7 +353,7 @@ 
         $routePath = $this->container->make('config')
             ->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 
@@ -389,7 +389,7 @@ 
      */
     protected function isWebsocketPushPayload($payload): bool
     {
-        if (! is_array($payload)) {
+        if (!is_array($payload)) {
             return false;
         }
 

src/Concerns/InteractsWithSwooleQueue.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
      */
     protected function isSwooleQueuePacket($packet)
     {
-        if (! is_string($packet)) {
+        if (!is_string($packet)) {
             return false;
         }
 

src/Websocket/Rooms/RedisRoom.php

Spacing +4 added lines, -4 removed lines

@@ -57,7 +57,7 @@ 
      */
     public function setRedis(?RedisClient $redis = null)
     {
-        if (! $redis) {
+        if (!$redis) {
             $server = Arr::get($this->config, 'server', []);
             $options = Arr::get($this->config, 'options', []);
 
@@ -139,7 +139,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->sadd($redisKey, $value);
             }
@@ -162,7 +162,7 @@ 
         $this->checkTable($table);
         $redisKey = $this->getKey($key, $table);
 
-        $this->redis->pipeline(function (Pipeline $pipe) use ($redisKey, $values) {
+        $this->redis->pipeline(function(Pipeline $pipe) use ($redisKey, $values) {
             foreach ($values as $value) {
                 $pipe->srem($redisKey, $value);
             }
@@ -202,7 +202,7 @@ 
      */
     protected function checkTable(string $table)
     {
-        if (! in_array($table, [RoomContract::ROOMS_KEY, RoomContract::DESCRIPTORS_KEY])) {
+        if (!in_array($table, [RoomContract::ROOMS_KEY, RoomContract::DESCRIPTORS_KEY])) {
             throw new \InvalidArgumentException("Invalid table name: `{$table}`.");
         }
     }

src/Websocket/Rooms/TableRoom.php

Spacing +2 added lines, -2 removed lines

@@ -87,7 +87,7 @@ 
         foreach ($rooms as $room) {
             $fds = $this->getClients($room);
 
-            if (! in_array($fd, $fds)) {
+            if (!in_array($fd, $fds)) {
                 continue;
             }
 
@@ -206,7 +206,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: `{$table}`.");
         }
     }