hhxsv5 / laravel-s

src/Swoole/Inotify.php

Spacing +5 added lines, -5 removed lines

@@ -27,7 +27,7 @@ 
 
     public function addFileType($type)
     {
-        $type = '.' . trim($type, '.');
+        $type = '.'.trim($type, '.');
         $this->fileTypes[$type] = true;
     }
 
@@ -54,7 +54,7 @@ 
     public function isExcluded($path)
     {
         foreach ($this->excludedDirs as $excludedDir) {
-            if ($excludedDir === $path || strpos($path, $excludedDir . '/') === 0) {
+            if ($excludedDir === $path || strpos($path, $excludedDir.'/') === 0) {
                 return true;
             }
         }
@@ -88,7 +88,7 @@ 
                 if ($file === '.' || $file === '..' || $this->isExcluded($file)) {
                     continue;
                 }
-                $file = $path . DIRECTORY_SEPARATOR . $file;
+                $file = $path.DIRECTORY_SEPARATOR.$file;
                 if (is_dir($file)) {
                     $this->_watch($file);
                 }
@@ -122,7 +122,7 @@ 
 
     public function start()
     {
-        Event::add($this->fd, function ($fp) {
+        Event::add($this->fd, function($fp) {
             $events = inotify_read($fp);
             foreach ($events as $event) {
                 if ($event['mask'] == IN_IGNORED) {
@@ -138,7 +138,7 @@ 
                     continue;
                 }
 
-                Timer::after(100, function () use ($event) {
+                Timer::after(100, function() use ($event) {
                     call_user_func_array($this->watchHandler, [$event]);
                     $this->doing = false;
                 });

src/Swoole/DynamicResponse.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
         }
 
         if ($len > $this->chunkLimit) {
-            for ($offset = 0, $limit = (int)(0.6 * $this->chunkLimit); $offset < $len; $offset += $limit) {
+            for ($offset = 0, $limit = (int) (0.6 * $this->chunkLimit); $offset < $len; $offset += $limit) {
                 $chunk = substr($content, $offset, $limit);
                 $this->swooleResponse->write($chunk);
             }

src/Swoole/StaticResponse.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         if ($deleteFile) {
             $fp = fopen($path, 'rb');
 
-            for ($offset = 0, $limit = (int)(0.99 * $this->chunkLimit); $offset < $size; $offset += $limit) {
+            for ($offset = 0, $limit = (int) (0.99 * $this->chunkLimit); $offset < $size; $offset += $limit) {
                 fseek($fp, $offset, SEEK_SET);
                 $chunk = fread($fp, $limit);
                 $this->swooleResponse->write($chunk);

src/Swoole/Request.php

Spacing +2 added lines, -2 removed lines

@@ -50,7 +50,7 @@ 
                 $server[$headerServerMapping[$key]] = $value;
             } else {
                 $key = str_replace('-', '_', $key);
-                $server['http_' . $key] = $value;
+                $server['http_'.$key] = $value;
             }
         }
         $server = array_change_key_case($server, CASE_UPPER);
@@ -64,7 +64,7 @@ 
             && isset($_SERVER['QUERY_STRING'])
             && strlen($_SERVER['QUERY_STRING']) > 0
         ) {
-            $_SERVER['REQUEST_URI'] .= '?' . $_SERVER['QUERY_STRING'];
+            $_SERVER['REQUEST_URI'] .= '?'.$_SERVER['QUERY_STRING'];
         }
 
         // Fix argv & argc

src/Swoole/InotifyTrait.php

Spacing +3 added lines, -3 removed lines

@@ -19,17 +19,17 @@
             return false;
         }
 
-        $fileTypes = isset($config['file_types']) ? (array)$config['file_types'] : [];
+        $fileTypes = isset($config['file_types']) ? (array) $config['file_types'] : [];
         if (empty($fileTypes)) {
             $this->warning('No file types to watch by inotify');
             return false;
         }
 
-        $callback = function () use ($config, $laravelConf) {
+        $callback = function() use ($config, $laravelConf) {
             $log = !empty($config['log']);
             $this->setProcessTitle(sprintf('%s laravels: inotify process', $config['process_prefix']));
             $inotify = new Inotify($config['watch_path'], IN_CREATE | IN_DELETE | IN_MODIFY | IN_MOVE,
-                function ($event) use ($log, $laravelConf) {
+                function($event) use ($log, $laravelConf) {
                     $reloadCmd = trim(sprintf('%s -c "%s" %s/bin/laravels reload', PHP_BINARY, php_ini_loaded_file(), $laravelConf['root_path']));
                     Portal::runCommand($reloadCmd);
                     if ($log) {

src/Swoole/Task/BaseTask.php

Spacing +5 added lines, -5 removed lines

@@ -28,7 +28,7 @@ 
         if ($delay < 0) {
             throw new \InvalidArgumentException('The delay must be greater than or equal to 0');
         }
-        $this->delay = (int)$delay;
+        $this->delay = (int) $delay;
         return $this;
     }
 
@@ -51,7 +51,7 @@ 
         if ($tries < 1) {
             throw new \InvalidArgumentException('The number of attempts must be greater than or equal to 1');
         }
-        $this->tries = (int)$tries;
+        $this->tries = (int) $tries;
         return $this;
     }
 
@@ -71,19 +71,19 @@ 
      */
     protected function task($task)
     {
-        $deliver = function () use ($task) {
+        $deliver = function() use ($task) {
             /**@var \Swoole\Http\Server $swoole */
             $swoole = app('swoole');
             // The worker_id of timer process is -1
             if ($swoole->worker_id === -1 || $swoole->taskworker) {
-                $taskWorkerNum = isset($swoole->setting['task_worker_num']) ? (int)$swoole->setting['task_worker_num'] : 0;
+                $taskWorkerNum = isset($swoole->setting['task_worker_num']) ? (int) $swoole->setting['task_worker_num'] : 0;
                 if ($taskWorkerNum < 2) {
                     throw new \InvalidArgumentException('LaravelS: async task needs to set task_worker_num >= 2');
                 }
                 $workerNum = isset($swoole->setting['worker_num']) ? $swoole->setting['worker_num'] : 0;
                 $totalNum = $workerNum + $taskWorkerNum;
 
-                $getAvailableId = function ($startId, $endId, $excludeId) {
+                $getAvailableId = function($startId, $endId, $excludeId) {
                     $ids = range($startId, $endId);
                     $ids = array_flip($ids);
                     unset($ids[$excludeId]);

src/Swoole/Server.php

Spacing +14 added lines, -14 removed lines

@@ -41,7 +41,7 @@ 
 
         $ip = isset($conf['listen_ip']) ? $conf['listen_ip'] : '127.0.0.1';
         $port = isset($conf['listen_port']) ? $conf['listen_port'] : 5200;
-        $socketType = isset($conf['socket_type']) ? (int)$conf['socket_type'] : SWOOLE_SOCK_TCP;
+        $socketType = isset($conf['socket_type']) ? (int) $conf['socket_type'] : SWOOLE_SOCK_TCP;
 
         if ($socketType === SWOOLE_SOCK_UNIX_STREAM) {
             $socketDir = dirname($ip);
@@ -98,21 +98,21 @@ 
     protected function bindWebSocketEvent()
     {
         if ($this->enableWebSocket) {
-            $eventHandler = function ($method, array $params) {
-                $this->callWithCatchException(function () use ($method, $params) {
+            $eventHandler = function($method, array $params) {
+                $this->callWithCatchException(function() use ($method, $params) {
                     call_user_func_array([$this->getWebSocketHandler(), $method], $params);
                 });
             };
 
-            $this->swoole->on('Open', function () use ($eventHandler) {
+            $this->swoole->on('Open', function() use ($eventHandler) {
                 $eventHandler('onOpen', func_get_args());
             });
 
-            $this->swoole->on('Message', function () use ($eventHandler) {
+            $this->swoole->on('Message', function() use ($eventHandler) {
                 $eventHandler('onMessage', func_get_args());
             });
 
-            $this->swoole->on('Close', function (WebSocketServer $server, $fd, $reactorId) use ($eventHandler) {
+            $this->swoole->on('Close', function(WebSocketServer $server, $fd, $reactorId) use ($eventHandler) {
                 $clientInfo = $server->getClientInfo($fd);
                 if (isset($clientInfo['websocket_status']) && $clientInfo['websocket_status'] === \WEBSOCKET_STATUS_FRAME) {
                     $eventHandler('onClose', func_get_args());
@@ -140,10 +140,10 @@ 
             $port->set(empty($socket['settings']) ? [] : $socket['settings']);
 
             $handlerClass = $socket['handler'];
-            $eventHandler = function ($method, array $params) use ($port, $handlerClass) {
+            $eventHandler = function($method, array $params) use ($port, $handlerClass) {
                 $handler = $this->getSocketHandler($port, $handlerClass);
                 if (method_exists($handler, $method)) {
-                    $this->callWithCatchException(function () use ($handler, $method, $params) {
+                    $this->callWithCatchException(function() use ($handler, $method, $params) {
                         call_user_func_array([$handler, $method], $params);
                     });
                 }
@@ -160,8 +160,8 @@ 
                 'BufferEmpty',
             ];
             foreach ($events as $event) {
-                $port->on($event, function () use ($event, $eventHandler) {
-                    $eventHandler('on' . $event, func_get_args());
+                $port->on($event, function() use ($event, $eventHandler) {
+                    $eventHandler('on'.$event, func_get_args());
                 });
             }
         }
@@ -200,7 +200,7 @@ 
 
     protected function bindSwooleTables()
     {
-        $tables = isset($this->conf['swoole_tables']) ? (array)$this->conf['swoole_tables'] : [];
+        $tables = isset($this->conf['swoole_tables']) ? (array) $this->conf['swoole_tables'] : [];
         foreach ($tables as $name => $table) {
             $t = new Table($table['size']);
             foreach ($table['column'] as $column) {
@@ -307,7 +307,7 @@ 
             if (!($listener instanceof Listener)) {
                 throw new \InvalidArgumentException(sprintf('%s must extend the abstract class %s', $listenerClass, Listener::class));
             }
-            $this->callWithCatchException(function () use ($listener) {
+            $this->callWithCatchException(function() use ($listener) {
                 $listener->handle();
             }, [], $event->getTries());
         }
@@ -316,7 +316,7 @@ 
 
     protected function handleTask(Task $task)
     {
-        return $this->callWithCatchException(function () use ($task) {
+        return $this->callWithCatchException(function() use ($task) {
             $task->handle();
             return true;
         }, [], $task->getTries());
@@ -334,7 +334,7 @@ 
                     )
                 );
             }
-            $this->callWithCatchException(function () use ($eventHandler, $arguments) {
+            $this->callWithCatchException(function() use ($eventHandler, $arguments) {
                 call_user_func_array([(new $eventHandler), 'handle'], $arguments);
             });
         }

src/LaravelS.php

Spacing +3 added lines, -3 removed lines

@@ -76,13 +76,13 @@
         parent::bindWebSocketEvent();
 
         if ($this->enableWebSocket) {
-            $eventHandler = function ($method, array $params) {
-                $this->callWithCatchException(function () use ($method, $params) {
+            $eventHandler = function($method, array $params) {
+                $this->callWithCatchException(function() use ($method, $params) {
                     call_user_func_array([$this->getWebSocketHandler(), $method], $params);
                 });
             };
 
-            $this->swoole->on('Open', function (WebSocketServer $server, SwooleRequest $request) use ($eventHandler) {
+            $this->swoole->on('Open', function(WebSocketServer $server, SwooleRequest $request) use ($eventHandler) {
                 // Start Laravel's lifetime, then support session ...middleware.
                 $laravelRequest = $this->convertRequest($this->laravel, $request);
                 $this->laravel->bindRequest($laravelRequest);

src/Swoole/Timer/TimerTrait.php

Spacing +7 added lines, -7 removed lines

@@ -19,8 +19,8 @@ 
         // Add backup cron job.
         $config['jobs'][] = BackupCronJob::class;
 
-        $callback = function (Process $process) use ($swoole, $config, $laravelConfig) {
-            $pidfile = dirname($swoole->setting['pid_file']) . '/' . $this->timerPidFile;
+        $callback = function(Process $process) use ($swoole, $config, $laravelConfig) {
+            $pidfile = dirname($swoole->setting['pid_file']).'/'.$this->timerPidFile;
             file_put_contents($pidfile, $process->pid);
             $this->setProcessTitle(sprintf('%s laravels: timer process', $config['process_prefix']));
             $this->initLaravel($laravelConfig, $swoole);
@@ -42,9 +42,9 @@ 
                 if (empty($job->interval())) {
                     throw new \InvalidArgumentException(sprintf('The interval of %s cannot be empty', get_class($job)));
                 }
-                $runJob = function () use ($job) {
-                    $runCallback = function () use ($job) {
-                        $this->callWithCatchException(function () use ($job) {
+                $runJob = function() use ($job) {
+                    $runCallback = function() use ($job) {
+                        $this->callWithCatchException(function() use ($job) {
                             $job->run();
                         });
                     };
@@ -59,13 +59,13 @@ 
                 }
             }
 
-            Process::signal(SIGUSR1, function ($signo) use ($config, $timerIds, $process) {
+            Process::signal(SIGUSR1, function($signo) use ($config, $timerIds, $process) {
                 foreach ($timerIds as $timerId) {
                     if (Timer::exists($timerId)) {
                         Timer::clear($timerId);
                     }
                 }
-                Timer::after($config['max_wait_time'] * 1000, function () use ($process) {
+                Timer::after($config['max_wait_time'] * 1000, function() use ($process) {
                     $process->exit(0);
                 });
             });