hhxsv5 / laravel-s

src/Swoole/Timer/CronJob.php

Spacing +5 added lines, -5 removed lines

@@ -92,7 +92,7 @@ 
 
     public static function getGlobalTimerCacheKey()
     {
-        return 'laravels:timer:' . strtolower(self::$globalTimerLockKey);
+        return 'laravels:timer:'.strtolower(self::$globalTimerLockKey);
     }
 
     public static function getGlobalTimerLock()
@@ -105,21 +105,21 @@ 
         $expire = self::GLOBAL_TIMER_LOCK_SECONDS;
         $result = $redis->set($key, $value, 'ex', $expire, 'nx');
         // Compatible with Predis and PhpRedis
-        return $result === true || ((string)$result === 'OK');
+        return $result === true || ((string) $result === 'OK');
     }
 
     public static function isGlobalTimerAlive()
     {
         /**@var \Illuminate\Redis\Connections\PhpRedisConnection $redis */
         $redis = app('redis');
-        return (bool)$redis->exists(self::getGlobalTimerCacheKey());
+        return (bool) $redis->exists(self::getGlobalTimerCacheKey());
     }
 
     public static function renewGlobalTimerLock($expire)
     {
         /**@var \Illuminate\Redis\Connections\PhpRedisConnection $redis */
         $redis = app('redis');
-        return (bool)$redis->expire(self::getGlobalTimerCacheKey(), $expire);
+        return (bool) $redis->expire(self::getGlobalTimerCacheKey(), $expire);
     }
 
     public static function setGlobalTimerLockKey($lockKey)
@@ -129,7 +129,7 @@ 
 
     public static function setEnable($enable)
     {
-        self::$enable = (bool)$enable;
+        self::$enable = (bool) $enable;
     }
 
     public static function isEnable()

src/Swoole/Timer/TimerTrait.php

Spacing +7 added lines, -7 removed lines

@@ -24,8 +24,8 @@ 
             $config['jobs'][] = CheckGlobalTimerAliveCronJob::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);
@@ -39,13 +39,13 @@ 
 
             $timerIds = $this->registerTimers($config['jobs']);
 
-            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);
                 });
             });
@@ -76,9 +76,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) {
                         if (($job instanceof CheckGlobalTimerAliveCronJob) || $job::isEnable()) {
                             $job->run();
                         }