swooletw / laravel-swoole

src/Task/SwooleTaskQueue.php

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
      */
     public function pushRaw($payload, $queue = null, array $options = [])
     {
-        return $this->swoole->task($payload, ! is_numeric($queue) ? -1 : (int)$queue);
+        return $this->swoole->task($payload, !is_numeric($queue) ? -1 : (int) $queue);
     }
 
     /**
@@ -69,7 +69,7 @@ 
      */
     public function later($delay, $job, $data = '', $queue = null)
     {
-        return Timer::after($this->secondsUntil($delay) * 1000, function () use ($job, $data, $queue) {
+        return Timer::after($this->secondsUntil($delay) * 1000, function() use ($job, $data, $queue) {
             return $this->push($job, $data, $queue);
         });
     }

src/Task/QueueFactory.php

Spacing +2 added lines, -2 removed lines

@@ -41,7 +41,7 @@ 
     public static function make($server, string $version): SwooleTaskQueue
     {
         $isMatch = static::isFileVersionMatch($version);
-        $class = static::copy(static::stub($version), ! $isMatch);
+        $class = static::copy(static::stub($version), !$isMatch);
 
         return new $class($server);
     }
@@ -66,7 +66,7 @@ 
      */
     public static function copy(string $stub, bool $rewrite = false): string
     {
-        if (! file_exists(static::QUEUE_CLASS_PATH) || $rewrite) {
+        if (!file_exists(static::QUEUE_CLASS_PATH) || $rewrite) {
             copy($stub, static::QUEUE_CLASS_PATH);
         }
 

src/Controllers/SocketIOController.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 
     public function upgrade(Request $request)
     {
-        if (! in_array($request->input('transport'), $this->transports)) {
+        if (!in_array($request->input('transport'), $this->transports)) {
             return response()->json(
                 [
                     'code' => 0,

src/Transformers/Request.php

Spacing +2 added lines, -2 removed lines

@@ -158,7 +158,7 @@ 
             $key = str_replace('-', '_', $key);
             $key = strtoupper($key);
 
-            if (! in_array($key, ['REMOTE_ADDR', 'SERVER_PORT', 'HTTPS'])) {
+            if (!in_array($key, ['REMOTE_ADDR', 'SERVER_PORT', 'HTTPS'])) {
                 $key = 'HTTP_' . $key;
             }
 
@@ -187,7 +187,7 @@ 
             return false;
         }
 
-        if (! is_file($fileName) || ! filesize($fileName)) {
+        if (!is_file($fileName) || !filesize($fileName)) {
             return false;
         }
 

src/Websocket/SocketIO/WebsocketHandler.php

Spacing +1 added lines, -1 removed lines

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

src/Websocket/Websocket.php

Spacing +7 added lines, -7 removed lines

@@ -112,7 +112,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;
             }
         }
@@ -163,7 +163,7 @@ 
     public function emit(string $event, $data): bool
     {
         $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
@@ -213,7 +213,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.'
             );
@@ -246,7 +246,7 @@ 
      */
     public function call(string $event, $data = null)
     {
-        if (! $this->eventExists($event)) {
+        if (!$this->eventExists($event)) {
             return null;
         }
 
@@ -320,7 +320,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);
@@ -399,7 +399,7 @@ 
     {
         $pipeline = $this->pipeline;
 
-        $closure = function () use ($container) {
+        $closure = function() use ($container) {
             $this->container = $container;
         };
 
@@ -443,7 +443,7 @@ 
         return $this->pipeline
             ->send($request)
             ->through($this->middleware)
-            ->then(function ($request) {
+            ->then(function($request) {
                 return $request;
             });
     }

src/Websocket/Authenticatable.php

Spacing +4 added lines, -4 removed lines

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

src/Concerns/WithApplication.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
      */
     public function getApplication()
     {
-        if (! $this->app instanceof Container) {
+        if (!$this->app instanceof Container) {
             $this->app = $this->loadApplication();
             $this->bootstrap();
         }
@@ -108,7 +108,7 @@ 
     {
         $framework = strtolower($framework);
 
-        if (! in_array($framework, ['laravel', 'lumen'])) {
+        if (!in_array($framework, ['laravel', 'lumen'])) {
             throw new FrameworkNotSupportException($framework);
         }
 

src/Concerns/InteractsWithSwooleTable.php

Spacing +2 added lines, -2 removed lines

@@ -56,8 +56,8 @@
      */
     protected function bindSwooleTable()
     {
-        if (! $this->app instanceof ConsoleApp) {
-            $this->app->singleton(SwooleTable::class, function () {
+        if (!$this->app instanceof ConsoleApp) {
+            $this->app->singleton(SwooleTable::class, function() {
                 return $this->currentTable;
             });