swooletw / laravel-swoole

src/HttpServiceProvider.php

Spacing +6 added lines, -6 removed lines

@@ -149,7 +149,7 @@ 
         $options = $config->get('swoole_http.server.options');
 
         // only enable task worker in websocket mode and for queue driver
-        if ($config->get('queue.default') !== 'swoole' && ! $this->isWebsocket) {
+        if ($config->get('queue.default') !== 'swoole' && !$this->isWebsocket) {
             unset($options['task_worker_num']);
         }
 
@@ -163,7 +163,7 @@ 
      */
     protected function registerServer()
     {
-        $this->app->singleton(Server::class, function () {
+        $this->app->singleton(Server::class, function() {
             if (is_null(static::$server)) {
                 $this->createSwooleServer();
                 $this->configureSwooleServer();
@@ -179,8 +179,8 @@ 
      */
     protected function registerDatabaseDriver()
     {
-        $this->app->extend(DatabaseManager::class, function (DatabaseManager $db) {
-            $db->extend('mysql-coroutine', function ($config, $name) {
+        $this->app->extend(DatabaseManager::class, function(DatabaseManager $db) {
+            $db->extend('mysql-coroutine', function($config, $name) {
                 $config['name'] = $name;
 
                 $connection = new MySqlConnection(
@@ -223,8 +223,8 @@ 
      */
     protected function registerSwooleQueueDriver()
     {
-        $this->app->afterResolving('queue', function (QueueManager $manager) {
-            $manager->addConnector('swoole', function () {
+        $this->app->afterResolving('queue', function(QueueManager $manager) {
+            $manager->addConnector('swoole', function() {
                 return new SwooleTaskConnector($this->app->make(Server::class));
             });
         });

src/Helpers/Dumper.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
 
     public static function dump(...$args)
     {
-        if (! static::$cloner instanceOf VarCloner) {
+        if (!static::$cloner instanceOf VarCloner) {
             static::$cloner = new VarCloner;
         }
 
@@ -29,7 +29,7 @@ 
 
     public static function getDumper()
     {
-        $dumper = defined('IN_PHPUNIT') || ! config('swoole_http.ob_output')
+        $dumper = defined('IN_PHPUNIT') || !config('swoole_http.ob_output')
             ? CliDumper::class
             : HtmlDumper::class;
 

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;
     }
 
     /**
@@ -221,7 +221,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->server->isEstablished($fd);
         });
     }
@@ -233,7 +233,7 @@ 
      */
     public function shouldPushToDescriptor(int $fd): bool
     {
-        if (! $this->server->isEstablished($fd)) {
+        if (!$this->server->isEstablished($fd)) {
             return false;
         }
 
@@ -250,7 +250,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/LaravelServiceProvider.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
      */
     protected function registerManager()
     {
-        $this->app->singleton(Manager::class, function ($app) {
+        $this->app->singleton(Manager::class, function($app) {
             return new Manager($app, 'laravel', base_path(), $this->app[PidManager::class]);
         });
 

src/LumenServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -18,7 +18,7 @@ 
      */
     protected function registerManager()
     {
-        $this->app->singleton(Manager::class, function ($app) {
+        $this->app->singleton(Manager::class, function($app) {
             return new Manager($app, 'lumen', base_path(), $this->app[PidManager::class]);
         });
 
@@ -33,7 +33,7 @@ 
     protected function bootWebsocketRoutes()
     {
         $this->app->router
-            ->group(['namespace' => 'SwooleTW\Http\Controllers'], function ($router) {
+            ->group(['namespace' => 'SwooleTW\Http\Controllers'], function($router) {
                 require __DIR__ . '/../routes/lumen_routes.php';
             });
     }

src/Commands/HttpServerCommand.php

Spacing +11 added lines, -11 removed lines

@@ -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;
@@ -256,7 +256,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'."
             );
@@ -277,7 +277,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();
         };
@@ -330,7 +330,7 @@ 
             $start = time();
 
             do {
-                if (! $this->isRunning()) {
+                if (!$this->isRunning()) {
                     break;
                 }
 
@@ -360,13 +360,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.3.1', 'ge')) {
+        if (!version_compare(swoole_version(), '4.3.1', 'ge')) {
             $this->error('Your Swoole version must be higher than `4.3.1`.');
 
             exit(1);
@@ -378,15 +378,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/Server/PidManager.php

Indentation +56 added lines, -56 removed lines

@@ -4,69 +4,69 @@
 
 class PidManager
 {
-	/**
-	 * @var string
-	 */
-	private $pidFile = '';
+    /**
+     * @var string
+     */
+    private $pidFile = '';
 
-	public function __construct(string $pidFile)
-	{
-		$this->pidFile = $pidFile;
-	}
+    public function __construct(string $pidFile)
+    {
+        $this->pidFile = $pidFile;
+    }
 
-	/**
-	 * Write master pid and manager pid to pid file
-	 *
-	 * @throws \RuntimeException When $pidFile is not writable
-	 */
-	public function write(int $masterPid, int $managerPid): void
-	{
-		if (! is_writable($this->pidFile) && ! is_writable(dirname($this->pidFile))) {
-			throw new \RuntimeException(sprintf('Pid file "%s" is not writable', $this->pidFile));
-		}
+    /**
+     * Write master pid and manager pid to pid file
+     *
+     * @throws \RuntimeException When $pidFile is not writable
+     */
+    public function write(int $masterPid, int $managerPid): void
+    {
+        if (! is_writable($this->pidFile) && ! is_writable(dirname($this->pidFile))) {
+            throw new \RuntimeException(sprintf('Pid file "%s" is not writable', $this->pidFile));
+        }
 
-		file_put_contents($this->pidFile, $masterPid . ',' . $managerPid);
-	}
+        file_put_contents($this->pidFile, $masterPid . ',' . $managerPid);
+    }
 
-	/**
-	 * Read master pid and manager pid from pid file
-	 *
-	 * @return string[] {
-	 *	 @var string $masterPid
-	 *	 @var string $managerPid
-	 * }
-	 */
-	public function read(): array
-	{
-		$pids = [];
+    /**
+     * Read master pid and manager pid from pid file
+     *
+     * @return string[] {
+     *	 @var string $masterPid
+     *	 @var string $managerPid
+     * }
+     */
+    public function read(): array
+    {
+        $pids = [];
 
-		if (is_readable($this->pidFile)) {
-			$content = file_get_contents($this->pidFile);
-			$pids = explode(',', $content);
-		}
+        if (is_readable($this->pidFile)) {
+            $content = file_get_contents($this->pidFile);
+            $pids = explode(',', $content);
+        }
 
-		return $pids;
-	}
+        return $pids;
+    }
 
-	/**
-	 * Gets pid file path.
-	 *
-	 * @return string
-	 */
-	public function file()
-	{
-		return $this->pidFile;
-	}
+    /**
+     * Gets pid file path.
+     *
+     * @return string
+     */
+    public function file()
+    {
+        return $this->pidFile;
+    }
 
-	/**
-	 * Delete pid file
-	 */
-	public function delete(): bool
-	{
-		if (is_writable($this->pidFile)) {
-			return unlink($this->pidFile);
-		}
+    /**
+     * Delete pid file
+     */
+    public function delete(): bool
+    {
+        if (is_writable($this->pidFile)) {
+            return unlink($this->pidFile);
+        }
 
-		return false;
-	}
+        return false;
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
 	 */
 	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/Server/PidManagerFactory.php

Indentation +6 added lines, -6 removed lines

@@ -7,10 +7,10 @@
 
 class PidManagerFactory
 {
-	public function __invoke(ContainerInterface $container): PidManager
-	{
-		return new PidManager(
-			$container->get('config')->get('swoole_http.server.options.pid_file') ?? sys_get_temp_dir() . '/swoole.pid'
-		);
-	}
+    public function __invoke(ContainerInterface $container): PidManager
+    {
+        return new PidManager(
+            $container->get('config')->get('swoole_http.server.options.pid_file') ?? sys_get_temp_dir() . '/swoole.pid'
+        );
+    }
 }