swooletw / laravel-swoole

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.');
         }
     }

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/InteractsWithWebsocket.php

Spacing +10 added lines, -10 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;
         }
 
@@ -163,7 +163,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());
         }
 
@@ -174,7 +174,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());
             }
         }
@@ -241,7 +241,7 @@ 
      */
     protected function filterWebsocket(array $descriptors): array
     {
-        $callback = function ($descriptor) {
+        $callback = function($descriptor) {
             return $this->isServerWebsocket($descriptor);
         };
 
@@ -257,7 +257,7 @@ 
     {
         $handlerClass = $this->container->make('config')->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new WebsocketNotSetInConfigException;
         }
 
@@ -304,7 +304,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}");
@@ -321,7 +321,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));
         });
 
@@ -336,7 +336,7 @@ 
         $routePath = $this->container->make('config')
             ->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 
@@ -372,7 +372,7 @@ 
      */
     protected function isWebsocketPushPayload($payload): bool
     {
-        if (! is_array($payload)) {
+        if (!is_array($payload)) {
             return false;
         }
 

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

src/Commands/HttpServerCommand.php

Spacing +12 added lines, -12 removed lines

@@ -133,7 +133,7 @@ 
     {
         $pid = $this->getCurrentPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -177,7 +177,7 @@ 
     {
         $pid = $this->getCurrentPid();
 
-        if (! $this->isRunning($pid)) {
+        if (!$this->isRunning($pid)) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -187,7 +187,7 @@ 
 
         $isRunning = $this->killProcess($pid, SIGUSR1);
 
-        if (! $isRunning) {
+        if (!$isRunning) {
             $this->error('> failure');
 
             return;
@@ -244,7 +244,7 @@ 
     {
         $this->action = $this->argument('action');
 
-        if (! in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'], true)) {
+        if (!in_array($this->action, ['start', 'stop', 'restart', 'reload', 'infos'], true)) {
             $this->error(
                 "Invalid argument '{$this->action}'. Expected 'start', 'stop', 'restart', 'reload' or 'infos'."
             );
@@ -265,7 +265,7 @@ 
         $filter = Arr::get($this->config, 'hot_reload.filter');
         $log = Arr::get($this->config, 'hot_reload.log');
 
-        $cb = function (FSEvent $event) use ($server, $log) {
+        $cb = function(FSEvent $event) use ($server, $log) {
             $log ? $this->info(FSOutput::format($event)) : null;
             $server->reload();
         };
@@ -282,7 +282,7 @@ 
      */
     protected function isRunning($pid)
     {
-        if (! $pid) {
+        if (!$pid) {
             return false;
         }
 
@@ -310,7 +310,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning($pid)) {
+                if (!$this->isRunning($pid)) {
                     break;
                 }
 
@@ -378,13 +378,13 @@ 
             exit(1);
         }
 
-        if (! extension_loaded('swoole')) {
+        if (!extension_loaded('swoole')) {
             $this->error("Can't detect Swoole extension installed.");
 
             exit(1);
         }
 
-        if (! version_compare(swoole_version(), '4.0.0', 'ge')) {
+        if (!version_compare(swoole_version(), '4.0.0', 'ge')) {
             $this->error("Your Swoole version must be higher than 4.0 to use coroutine.");
 
             exit(1);
@@ -396,15 +396,15 @@ 
      */
     protected function registerAccessLog()
     {
-        $this->laravel->singleton(OutputStyle::class, function () {
+        $this->laravel->singleton(OutputStyle::class, function() {
             return new OutputStyle($this->input, $this->output);
         });
 
-        $this->laravel->singleton(AccessOutput::class, function () {
+        $this->laravel->singleton(AccessOutput::class, function() {
             return new AccessOutput(new ConsoleOutput);
         });
 
-        $this->laravel->singleton(AccessLog::class, function (Container $container) {
+        $this->laravel->singleton(AccessLog::class, function(Container $container) {
             return new AccessLog($container->make(AccessOutput::class));
         });
     }

src/Coroutine/Connectors/ConnectorFactory.php

Spacing +2 added lines, -2 removed lines

@@ -39,7 +39,7 @@ 
     public static function make(string $version): MySqlConnector
     {
         $isMatch = static::isFileVersionMatch($version);
-        $class = static::copy(static::stub($version), ! $isMatch);
+        $class = static::copy(static::stub($version), !$isMatch);
 
         return new $class;
     }
@@ -64,7 +64,7 @@ 
      */
     public static function copy(string $stub, bool $rewrite = false): string
     {
-        if (! file_exists(static::CONNECTOR_CLASS_PATH) || $rewrite) {
+        if (!file_exists(static::CONNECTOR_CLASS_PATH) || $rewrite) {
             copy($stub, static::CONNECTOR_CLASS_PATH);
         }