swooletw / laravel-swoole

src/Websocket/Pusher.php

Spacing +4 added lines, -4 removed lines

@@ -209,7 +209,7 @@ 
      */
     public function shouldBroadcast(): bool
     {
-        return $this->broadcast && empty($this->descriptors) && ! $this->assigned;
+        return $this->broadcast && empty($this->descriptors) && !$this->assigned;
     }
 
     /**
@@ -233,7 +233,7 @@ 
      */
     protected function getWebsocketConnections(): array
     {
-        return array_filter(iterator_to_array($this->server->connections), function ($fd) {
+        return array_filter(iterator_to_array($this->server->connections), function($fd) {
             return $this->isServerWebsocket($fd);
         });
     }
@@ -245,7 +245,7 @@ 
      */
     public function shouldPushToDescriptor(int $fd): bool
     {
-        if (! $this->server->exist($fd)) {
+        if (!$this->server->exist($fd)) {
             return false;
         }
 
@@ -262,7 +262,7 @@ 
     public function push($payload): void
     {
         // attach sender if not broadcast
-        if (! $this->broadcast && $this->sender && ! $this->hasDescriptor($this->sender)) {
+        if (!$this->broadcast && $this->sender && !$this->hasDescriptor($this->sender)) {
             $this->addDescriptor($this->sender);
         }
 

src/Concerns/InteractsWithWebsocket.php

Spacing +8 added lines, -8 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 WebsocketServer) {
+        if (!$this->isServerWebsocket($fd) || !$server instanceof WebsocketServer) {
             return;
         }
 
@@ -158,7 +158,7 @@ 
      */
     protected function isWebsocketPushPacket($packet)
     {
-        if (! is_array($packet)) {
+        if (!is_array($packet)) {
             return false;
         }
 
@@ -243,7 +243,7 @@ 
     {
         $handlerClass = $this->container->make('config')->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new WebsocketNotSetInConfigException;
         }
 
@@ -290,7 +290,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}");
@@ -311,7 +311,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));
         });
 
@@ -326,7 +326,7 @@ 
         $routePath = $this->container->make('config')
             ->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 
@@ -342,7 +342,7 @@ 
      */
     public function isWebsocketPushPayload($payload): bool
     {
-        if (! is_array($payload)) {
+        if (!is_array($payload)) {
             return false;
         }