resquebundle / resque

Command/ClearQueueCommand.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
         $queue = $input->getArgument('queue');
         $count = $this->resque->clearQueue($queue);
 
-        $output->writeln('Cleared queue '.$queue.' - removed '.$count.' entries');
+        $output->writeln('Cleared queue ' . $queue . ' - removed ' . $count . ' entries');
 
         return 0;
     }

Command/StartScheduledWorkerCommand.php

Spacing +18 added lines, -18 removed lines

@@ -48,7 +48,7 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $pidFile = $this->params->get('kernel.cache_dir').'/resque_scheduledworker.pid';
+        $pidFile = $this->params->get('kernel.cache_dir') . '/resque_scheduledworker.pid';
         if (file_exists($pidFile) && !$input->getOption('force')) {
             throw new \Exception('PID file exists - use --force to override');
         }
@@ -60,31 +60,31 @@ 
         $env = [
             'APP_INCLUDE' => $this->params->get('resque.app_include'),
             'VVERBOSE'    => 1,
-            'RESQUE_PHP'  => $this->params->get('resque.vendor_dir').'/chrisboulton/php-resque/lib/Resque.php',
+            'RESQUE_PHP'  => $this->params->get('resque.vendor_dir') . '/chrisboulton/php-resque/lib/Resque.php',
             'INTERVAL'    => $input->getOption('interval'),
         ];
 
         if (!file_exists($env['RESQUE_PHP'])) {
-            $env['RESQUE_PHP'] =  $this->params->get('resque.vendor_dir').'/resque/php-resque/lib/Resque.php';
+            $env['RESQUE_PHP'] = $this->params->get('resque.vendor_dir') . '/resque/php-resque/lib/Resque.php';
         }
 
         if (false !== getenv('APP_INCLUDE')) {
             $env['APP_INCLUDE'] = getenv('APP_INCLUDE');
         }
 
-        $prefix =  $this->params->get('resque.prefix');
+        $prefix = $this->params->get('resque.prefix');
 
         if (!empty($prefix)) {
-            $env['PREFIX'] =  $this->params->get('resque.prefix');
+            $env['PREFIX'] = $this->params->get('resque.prefix');
         }
 
-        $redisHost     =  $this->params->get('resque.redis.host');
-        $redisPort     =  $this->params->get('resque.redis.port');
-        $redisDatabase =  $this->params->get('resque.redis.database');
-        $redisPassword =  $this->params->get('resque.redis.password');
+        $redisHost     = $this->params->get('resque.redis.host');
+        $redisPort     = $this->params->get('resque.redis.port');
+        $redisDatabase = $this->params->get('resque.redis.database');
+        $redisPassword = $this->params->get('resque.redis.password');
 
         if (null != $redisHost && null != $redisPort) {
-            $env['REDIS_BACKEND'] = $redisHost.':'.$redisPort;
+            $env['REDIS_BACKEND'] = $redisHost . ':' . $redisPort;
         }
 
         if (isset($redisDatabase)) {
@@ -98,20 +98,20 @@ 
         if (version_compare(PHP_VERSION, '5.4.0') >= 0) {
             $phpExecutable = PHP_BINARY;
         } else {
-            $phpExecutable = PHP_BINDIR.'/php';
+            $phpExecutable = PHP_BINDIR . '/php';
             if (\defined('PHP_WINDOWS_VERSION_BUILD')) {
                 $phpExecutable = 'php';
             }
         }
 
-        $workdirectory = __DIR__.'/../bin/';
-        $workerCommand = $phpExecutable.' '.$workdirectory.'resque-scheduler';
+        $workdirectory = __DIR__ . '/../bin/';
+        $workerCommand = $phpExecutable . ' ' . $workdirectory . 'resque-scheduler';
 
         if (!$input->getOption('foreground')) {
-            $logFile =  $this->params->get(
+            $logFile = $this->params->get(
                     'kernel.logs_dir'
-                ).'/resque-scheduler_'.$this->params->get('kernel.environment').'.log';
-            $workerCommand = 'nohup '.$workerCommand.' > '.$logFile.' 2>&1 & echo $!';
+                ) . '/resque-scheduler_' . $this->params->get('kernel.environment') . '.log';
+            $workerCommand = 'nohup ' . $workerCommand . ' > ' . $logFile . ' 2>&1 & echo $!';
         }
 
         // In windows: When you pass an environment to CMD it replaces the old environment
@@ -119,7 +119,7 @@ 
         // this is a workaround where we add the vars to the existing environment.
         if (\defined('PHP_WINDOWS_VERSION_BUILD')) {
             foreach ($env as $key => $value) {
-                putenv($key.'='.$value);
+                putenv($key . '=' . $value);
             }
             $env = null;
         }
@@ -129,7 +129,7 @@ 
         $output->writeln(sprintf('Starting worker <info>%s</info>', $process->getCommandLine()));
 
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Command/StopScheduledWorkerCommand.php

Spacing +2 added lines, -2 removed lines

@@ -41,7 +41,7 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $pidFile = $this->params->get('kernel.cache_dir').'/resque_scheduledworker.pid';
+        $pidFile = $this->params->get('kernel.cache_dir') . '/resque_scheduledworker.pid';
 
         if (!file_exists($pidFile)) {
             $output->writeln('No PID file found');
@@ -51,7 +51,7 @@ 
 
         $pid = file_get_contents($pidFile);
 
-        $output->writeln('Killing process '.$pid);
+        $output->writeln('Killing process ' . $pid);
 
         posix_kill($pid, SIGKILL);
 

Command/StartWorkerCommand.php

Spacing +14 added lines, -14 removed lines

@@ -64,15 +64,15 @@ 
             );
         }
 
-        $env['APP_INCLUDE'] =  $this->params->get('resque.app_include');
+        $env['APP_INCLUDE'] = $this->params->get('resque.app_include');
         $env['COUNT']       = $input->getOption('count');
         $env['INTERVAL']    = $input->getOption('interval');
         $env['QUEUE']       = $input->getArgument('queues');
 
         // Allow Sentry.io integration
         if ($this->params->has('sentry.dsn')) {
-            if ($sentryDSN =  $this->params->get('sentry.dsn')) {
-                $output->writeln('Enabling Sentry Reporting to DSN '.$sentryDSN);
+            if ($sentryDSN = $this->params->get('sentry.dsn')) {
+                $output->writeln('Enabling Sentry Reporting to DSN ' . $sentryDSN);
                 $env['SENTRY_DSN'] = $sentryDSN;
             }
         }
@@ -81,9 +81,9 @@ 
             $env['APP_INCLUDE'] = getenv('APP_INCLUDE');
         }
 
-        $prefix =  $this->params->get('resque.prefix');
+        $prefix = $this->params->get('resque.prefix');
         if (!empty($prefix)) {
-            $env['PREFIX'] =  $this->params->get('resque.prefix');
+            $env['PREFIX'] = $this->params->get('resque.prefix');
         }
 
         if ($input->getOption('verbose')) {
@@ -94,12 +94,12 @@ 
             unset($env['VERBOSE']);
         }
 
-        $redisHost     =  $this->params->get('resque.redis.host');
-        $redisPort     =  $this->params->get('resque.redis.port');
-        $redisDatabase =  $this->params->get('resque.redis.database');
+        $redisHost     = $this->params->get('resque.redis.host');
+        $redisPort     = $this->params->get('resque.redis.port');
+        $redisDatabase = $this->params->get('resque.redis.database');
 
         if (null != $redisHost && null != $redisPort) {
-            $env['REDIS_BACKEND'] = $redisHost.':'.$redisPort;
+            $env['REDIS_BACKEND'] = $redisHost . ':' . $redisPort;
         }
 
         if (isset($redisDatabase)) {
@@ -107,14 +107,14 @@ 
         }
 
         $opt = '';
-        if (0 !== $m = (int) $input->getOption('memory-limit')) {
+        if (0 !== $m = (int)$input->getOption('memory-limit')) {
             $opt = sprintf('-d memory_limit=%dM', $m);
         }
 
         if (version_compare(PHP_VERSION, '5.4.0') >= 0) {
             $phpExecutable = PHP_BINARY;
         } else {
-            $phpExecutable = PHP_BINDIR.'/php';
+            $phpExecutable = PHP_BINDIR . '/php';
             if (\defined('PHP_WINDOWS_VERSION_BUILD')) {
                 $phpExecutable = 'php';
             }
@@ -123,7 +123,7 @@ 
         $workerCommand = strtr('%php% %opt% %dir%/resque', [
             '%php%' => $phpExecutable,
             '%opt%' => $opt,
-            '%dir%' => __DIR__.'/../bin',
+            '%dir%' => __DIR__ . '/../bin',
         ]);
 
         if (!$input->getOption('foreground')) {
@@ -138,7 +138,7 @@ 
         // this is a workaround where we add the vars to the existing environment.
         if (\defined('PHP_WINDOWS_VERSION_BUILD')) {
             foreach ($env as $key => $value) {
-                putenv($key.'='.$value);
+                putenv($key . '=' . $value);
             }
             $env = null;
         }
@@ -151,7 +151,7 @@ 
 
         // if foreground, we redirect output
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Resque.php

Spacing +6 added lines, -6 removed lines

@@ -92,7 +92,7 @@ 
         ];
 
         if (!isset($password)) {
-            \Resque::setBackend($host.':'.$port, $database);
+            \Resque::setBackend($host . ':' . $port, $database);
         } else {
             $server = 'redis://:' . $password . '@' . $host . ':' . $port;
             \Resque::setBackend($server, $database);
@@ -263,7 +263,7 @@ 
      */
     public function getQueues()
     {
-        return array_map(function ($queue) {
+        return array_map(function($queue) {
             return new Queue($queue);
         }, \Resque::queues());
     }
@@ -283,7 +283,7 @@ 
      */
     public function getWorkers()
     {
-        return array_map(function ($worker) {
+        return array_map(function($worker) {
             return new Worker($worker);
         }, \Resque_Worker::all());
     }
@@ -293,7 +293,7 @@ 
      */
     public function getRunningWorkers()
     {
-        return array_filter($this->getWorkers(), function (Worker $worker) {
+        return array_filter($this->getWorkers(), function(Worker $worker) {
             return null !== $worker->getCurrentJob();
         });
     }
@@ -370,7 +370,7 @@ 
         //TODO: find a more efficient way to do this
         $out = [];
         foreach ($timestamps as $timestamp) {
-            $out[] = [$timestamp, \Resque::redis()->llen('delayed:'.$timestamp)];
+            $out[] = [$timestamp, \Resque::redis()->llen('delayed:' . $timestamp)];
         }
 
         return $out;
@@ -391,7 +391,7 @@ 
      */
     public function getJobsForTimestamp($timestamp)
     {
-        $jobs = \Resque::redis()->lrange('delayed:'.$timestamp, 0, -1);
+        $jobs = \Resque::redis()->lrange('delayed:' . $timestamp, 0, -1);
         $out  = [];
         foreach ($jobs as $job) {
             $out[] = json_decode($job, true);

ContainerAwareJob.php

Spacing +3 added lines, -3 removed lines

@@ -56,7 +56,7 @@ 
     protected function createKernel()
     {
         $finder = new Finder();
-        $finder->name('*Kernel.php')->depth('<=1')->in($this->args['kernel.project_dir'].'/src');
+        $finder->name('*Kernel.php')->depth('<=1')->in($this->args['kernel.project_dir'] . '/src');
         $results = iterator_to_array($finder);
         $file    = current($results);
         $class   = $file->getBasename('.php');
@@ -64,8 +64,8 @@ 
         // Take into account any namespace
         preg_match('/namespace\s(.*)\;/', file_get_contents($file), $matches);
         if (2 == \count($matches)) {
-            $namespace = '\\'.$matches[1].'\\';
-            $class     = $namespace.$class;
+            $namespace = '\\' . $matches[1] . '\\';
+            $class     = $namespace . $class;
         }
 
         require_once $file;

Controller/DefaultController.php

Spacing +4 added lines, -4 removed lines

@@ -76,7 +76,7 @@ 
         $count = $queue->clear();
         $queue->remove();
 
-        $this->addFlash('info', 'Remove '.$queue->getName().' queue and '.$count.' jobs.');
+        $this->addFlash('info', 'Remove ' . $queue->getName() . ' queue and ' . $count . ' jobs.');
 
         return $this->redirectToRoute('ResqueBundle_homepage');
     }
@@ -183,7 +183,7 @@ 
     {
         $count = $this->resque->retryFailedJobs();
 
-        $this->addFlash('info', 'Retry '.$count.' failed jobs.');
+        $this->addFlash('info', 'Retry ' . $count . ' failed jobs.');
 
         return $this->redirectToRoute('ResqueBundle_homepage');
     }
@@ -195,7 +195,7 @@ 
     {
         $count = $this->resque->retryFailedJobs(true);
 
-        $this->addFlash('info', 'Retry and clear '.$count.' failed jobs.');
+        $this->addFlash('info', 'Retry and clear ' . $count . ' failed jobs.');
 
         return $this->redirectToRoute('ResqueBundle_homepage');
     }
@@ -207,7 +207,7 @@ 
     {
         $count = $this->resque->clearFailedJobs();
 
-        $this->addFlash('info', 'Clear '.$count.' failed jobs.');
+        $this->addFlash('info', 'Clear ' . $count . ' failed jobs.');
 
         return $this->redirectToRoute('ResqueBundle_homepage');
     }

Worker.php

Spacing +2 added lines, -2 removed lines

@@ -43,7 +43,7 @@ 
      */
     public function getId()
     {
-        return (string) $this->worker;
+        return (string)$this->worker;
     }
 
     /**
@@ -51,7 +51,7 @@ 
      */
     public function getQueues()
     {
-        return array_map(function ($queue) {
+        return array_map(function($queue) {
             return new Queue($queue);
         }, $this->worker->queues());
     }

Queue.php

Spacing +3 added lines, -3 removed lines

@@ -47,7 +47,7 @@ 
      */
     public function getJobs($start = 0, $stop = -1)
     {
-        $jobs = \Resque::redis()->lrange('queue:'.$this->name, $start, $stop);
+        $jobs = \Resque::redis()->lrange('queue:' . $this->name, $start, $stop);
 
         $result = [];
         foreach ($jobs as $job) {
@@ -68,8 +68,8 @@ 
      */
     public function clear()
     {
-        $length = \Resque::redis()->llen('queue:'.$this->name);
-        \Resque::redis()->del('queue:'.$this->name);
+        $length = \Resque::redis()->llen('queue:' . $this->name);
+        \Resque::redis()->del('queue:' . $this->name);
 
         return $length;
     }