swooletw / laravel-swoole

src/Server/PidManager.php

Spacing +2 added lines, -2 removed lines

@@ -30,8 +30,8 @@
      */
     public function write(int $masterPid, int $managerPid): void
     {
-        if (! is_writable($this->pidFile)
-            && ! is_writable(dirname($this->pidFile))
+        if (!is_writable($this->pidFile)
+            && !is_writable(dirname($this->pidFile))
         ) {
             throw new \RuntimeException(
                 sprintf('Pid file "%s" is not writable', $this->pidFile)

src/Concerns/InteractsWithWebsocket.php

Spacing +10 added lines, -10 removed lines

@@ -88,11 +88,11 @@ 
             // enable sandbox
             $sandbox->enable();
             // call customized handshake handler
-            if ($response && ! $this->app->make($handshakeHandler)->handle($swooleRequest, $response)) {
+            if ($response && !$this->app->make($handshakeHandler)->handle($swooleRequest, $response)) {
                 return;
             }
             // 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
@@ -156,7 +156,7 @@ 
      */
     public function onClose($server, $fd, $reactorId)
     {
-        if (! $this->isServerWebsocket($fd) || ! $server instanceof WebsocketServer) {
+        if (!$this->isServerWebsocket($fd) || !$server instanceof WebsocketServer) {
             return;
         }
 
@@ -186,7 +186,7 @@ 
      */
     protected function isWebsocketPushPacket($packet)
     {
-        if (! is_array($packet)) {
+        if (!is_array($packet)) {
             return false;
         }
 
@@ -241,7 +241,7 @@ 
         $config = $this->container->make('config');
         $parser = $config->get('swoole_websocket.parser');
 
-        if (! $this->isServerWebsocket = $config->get('swoole_http.websocket.enabled')) {
+        if (!$this->isServerWebsocket = $config->get('swoole_http.websocket.enabled')) {
             return;
         }
 
@@ -279,7 +279,7 @@ 
     {
         $handlerClass = $this->container->make('config')->get('swoole_websocket.handler');
 
-        if (! $handlerClass) {
+        if (!$handlerClass) {
             throw new WebsocketNotSetInConfigException;
         }
 
@@ -340,7 +340,7 @@ 
      */
     protected function bindRoom(): void
     {
-        $this->app->singleton(RoomContract::class, function () {
+        $this->app->singleton(RoomContract::class, function() {
             return $this->websocketRoom;
         });
 
@@ -352,7 +352,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));
         });
 
@@ -367,7 +367,7 @@ 
         $routePath = $this->container->make('config')
             ->get('swoole_websocket.route_file');
 
-        if (! file_exists($routePath)) {
+        if (!file_exists($routePath)) {
             $routePath = __DIR__ . '/../../routes/websocket.php';
         }
 
@@ -383,7 +383,7 @@ 
      */
     public function isWebsocketPushPayload($payload): bool
     {
-        if (! is_array($payload)) {
+        if (!is_array($payload)) {
             return false;
         }
 

src/Websocket/Middleware/Authenticate.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
         try {
             $this->auth->setRequest($request);
             if ($user = $this->auth->authenticate()) {
-                $request->setUserResolver(function () use ($user) {
+                $request->setUserResolver(function() use ($user) {
                     return $user;
                 });
             }

src/Server/Manager.php

Spacing +4 added lines, -4 removed lines

@@ -115,7 +115,7 @@ 
         $this->createTables();
         $this->prepareWebsocket();
 
-        if (! $this->container->make(Server::class)->taskworker) {
+        if (!$this->container->make(Server::class)->taskworker) {
             $this->setSwooleServerListeners();
         }
     }
@@ -128,7 +128,7 @@ 
         $server = $this->container->make(Server::class);
         foreach ($this->events as $event) {
             $listener = Str::camel("on_$event");
-            $callback = method_exists($this, $listener) ? [$this, $listener] : function () use ($event) {
+            $callback = method_exists($this, $listener) ? [$this, $listener] : function() use ($event) {
                 $this->container->make('events')->dispatch("swoole.$event", func_get_args());
             };
 
@@ -322,7 +322,7 @@ 
      */
     protected function bindSandbox()
     {
-        $this->app->singleton(Sandbox::class, function ($app) {
+        $this->app->singleton(Sandbox::class, function($app) {
             return new Sandbox($app, $this->framework);
         });
 
@@ -410,7 +410,7 @@ 
      */
     protected function normalizeException(Throwable $e)
     {
-        if (! $e instanceof Exception) {
+        if (!$e instanceof Exception) {
             $e = new FatalThrowableError($e);
         }
 

src/Websocket/Middleware/StartSession.php

Spacing +3 added lines, -3 removed lines

@@ -58,7 +58,7 @@ 
      */
     protected function startSession(Request $request)
     {
-        return tap($this->getSession($request), function (Session $session) use ($request) {
+        return tap($this->getSession($request), function(Session $session) use ($request) {
             $session->setRequestOnHandler($request);
 
             $session->start();
@@ -74,7 +74,7 @@ 
      */
     public function getSession(Request $request)
     {
-        return tap($this->manager->driver(), function (Session $session) use ($request) {
+        return tap($this->manager->driver(), function(Session $session) use ($request) {
             $session->setId($request->cookies->get($session->getName()));
         });
     }
@@ -86,6 +86,6 @@ 
      */
     protected function sessionConfigured()
     {
-        return ! is_null($this->manager->getSessionConfig()['driver'] ?? null);
+        return !is_null($this->manager->getSessionConfig()['driver'] ?? null);
     }
 }

src/Server/helpers.php

Spacing +3 added lines, -3 removed lines

@@ -3,7 +3,7 @@ 
 /**
  * This is only for `function not exists` in config/swoole_http.php.
  */
-if (! function_exists('swoole_cpu_num')) {
+if (!function_exists('swoole_cpu_num')) {
     function swoole_cpu_num(): int
     {
         return 1;
@@ -13,10 +13,10 @@ 
 /**
  * This is only for `function not exists` in config/swoole_http.php.
  */
-if (! defined('SWOOLE_SOCK_TCP')) {
+if (!defined('SWOOLE_SOCK_TCP')) {
     define('SWOOLE_SOCK_TCP', 1);
 }
 
-if (! defined('SWOOLE_PROCESS')) {
+if (!defined('SWOOLE_PROCESS')) {
     define('SWOOLE_PROCESS', 2);
 }

src/Commands/HttpServerCommand.php

Spacing +11 added lines, -11 removed lines

@@ -137,7 +137,7 @@ 
      */
     public function registerProcess($server)
     {
-        $this->laravel->singleton(CustomProcess::class, function () {
+        $this->laravel->singleton(CustomProcess::class, function() {
             return new CustomProcess();
         });
         $customProcess = $this->laravel->make(CustomProcess::class);
@@ -152,7 +152,7 @@ 
      */
     protected function stop()
     {
-        if (! $this->isRunning()) {
+        if (!$this->isRunning()) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -192,7 +192,7 @@ 
      */
     protected function reload()
     {
-        if (! $this->isRunning()) {
+        if (!$this->isRunning()) {
             $this->error("Failed! There is no swoole_http_server process running.");
 
             return;
@@ -200,7 +200,7 @@ 
 
         $this->info('Reloading swoole_http_server...');
 
-        if (! $this->killProcess(SIGUSR1)) {
+        if (!$this->killProcess(SIGUSR1)) {
             $this->error('> failure');
 
             return;
@@ -282,7 +282,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();
         };
@@ -310,11 +310,11 @@ 
 
         if ($managerPid) {
             // Swoole process mode
-            return $masterPid && $managerPid && Process::kill((int)$managerPid, 0);
+            return $masterPid && $managerPid && Process::kill((int) $managerPid, 0);
         }
 
         // Swoole base mode, no manager process
-        return $masterPid && Process::kill((int)$masterPid, 0);
+        return $masterPid && Process::kill((int) $masterPid, 0);
     }
 
     /**
@@ -336,7 +336,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning()) {
+                if (!$this->isRunning()) {
                     break;
                 }
 
@@ -384,15 +384,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/Process/CustomProcess.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
             );
         }
 
-        return new SwooleProcess(function ($process) use ($server, $process_class) {
+        return new SwooleProcess(function($process) use ($server, $process_class) {
             $p = new $process_class();
             $p->handle($server, $process);
         }, false, false);