mpclarkson / resque-bundle

Queue.php

Spacing +2 added lines, -2 removed lines

@@ -21,9 +21,9 @@
         return $this->name;
     }
 
-    public function getJobs($start=0, $stop=-1)
+    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 = array();
         foreach ($jobs as $job) {

Worker.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 
     public function getQueues()
     {
-        return \array_map(function ($queue) {
+        return \array_map(function($queue) {
             return new Queue($queue);
         }, $this->worker->queues());
     }

DependencyInjection/Configuration.php

Spacing +1 added lines, -1 removed lines

@@ -39,7 +39,7 @@
                 ->arrayNode('auto_retry')
                     ->beforeNormalization()
                         ->ifArray()
-                        ->then(function ($var) {
+                        ->then(function($var) {
                             if (array_key_exists(0, $var)) {
                                 return array($var);
                             }

Command/ClearQueueCommand.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
         $resque = $this->getContainer()->get('resque');
 
         $queue = $input->getArgument('queue');
-        $count=$resque->clearQueue($queue);
+        $count = $resque->clearQueue($queue);
 
         $output->writeln('Cleared queue '.$queue.' - removed '.$count.' entries');
 

Command/StartWorkerCommand.php

Indentation +9 added lines, -9 removed lines

@@ -100,15 +100,15 @@
         }
 
 
-		// In windows: When you pass an environment to CMD it replaces the old environment
-		// That means we create a lot of problems with respect to user accounts and missing vars
-		// 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);
-			}
-			$env = null;
-		}
+        // In windows: When you pass an environment to CMD it replaces the old environment
+        // That means we create a lot of problems with respect to user accounts and missing vars
+        // 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);
+            }
+            $env = null;
+        }
 
         $process = new Process($workerCommand, null, $env, null, null);
 

Spacing +3 added lines, -3 removed lines

@@ -104,8 +104,8 @@ 
 		// That means we create a lot of problems with respect to user accounts and missing vars
 		// 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);
+			foreach ($env as $key => $value) {
+				putenv($key."=".$value);
 			}
 			$env = null;
 		}
@@ -118,7 +118,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);
             });
         }

Command/StartScheduledWorkerCommand.php

Indentation +11 added lines, -11 removed lines

@@ -72,17 +72,17 @@
             $workerCommand = 'nohup ' . $workerCommand . ' > ' . $logFile .' 2>&1 & echo $!';
         }
 
-		// In windows: When you pass an environment to CMD it replaces the old environment
-		// That means we create a lot of problems with respect to user accounts and missing vars
-		// 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);
-			}
-			$env = null;
-		}
+        // In windows: When you pass an environment to CMD it replaces the old environment
+        // That means we create a lot of problems with respect to user accounts and missing vars
+        // 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);
+            }
+            $env = null;
+        }
 
 
         $process = new Process($workerCommand, null, $env, null, null);

Spacing +7 added lines, -7 removed lines

@@ -23,7 +23,7 @@ 
 
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $pidFile=$this->getContainer()->get('kernel')->getCacheDir().'/resque_scheduledworker.pid';
+        $pidFile = $this->getContainer()->get('kernel')->getCacheDir().'/resque_scheduledworker.pid';
         if (file_exists($pidFile) && !$input->getOption('force')) {
             throw new \Exception('PID file exists - use --force to override');
         }
@@ -68,8 +68,8 @@ 
         if (!$input->getOption('foreground')) {
             $logFile = $this->getContainer()->getParameter(
                 'kernel.logs_dir'
-            ) . '/resque-scheduler_' . $this->getContainer()->getParameter('kernel.environment') . '.log';
-            $workerCommand = 'nohup ' . $workerCommand . ' > ' . $logFile .' 2>&1 & echo $!';
+            ).'/resque-scheduler_'.$this->getContainer()->getParameter('kernel.environment').'.log';
+            $workerCommand = 'nohup '.$workerCommand.' > '.$logFile.' 2>&1 & echo $!';
         }
 
 		// In windows: When you pass an environment to CMD it replaces the old environment
@@ -77,9 +77,9 @@ 
 		// this is a workaround where we add the vars to the existing environment.
 		if (defined('PHP_WINDOWS_VERSION_BUILD'))
 		{
-			foreach($env as $key => $value)
+			foreach ($env as $key => $value)
 			{
-				putenv($key."=". $value);
+				putenv($key."=".$value);
 			}
 			$env = null;
 		}
@@ -90,7 +90,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);
                 });
         }
@@ -104,7 +104,7 @@ 
                 $hostname = php_uname('n');
             }
             $output->writeln(\sprintf('<info>Worker started</info> %s:%s', $hostname, $pid));
-            file_put_contents($pidFile,$pid);
+            file_put_contents($pidFile, $pid);
         }
     }
 }

Command/StopScheduledWorkerCommand.php

Spacing +3 added lines, -3 removed lines

@@ -20,18 +20,18 @@
 
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $pidFile=$this->getContainer()->get('kernel')->getCacheDir().'/resque_scheduledworker.pid';
+        $pidFile = $this->getContainer()->get('kernel')->getCacheDir().'/resque_scheduledworker.pid';
         if (!file_exists($pidFile)) {
             $output->writeln('No PID file found');
 
             return -1;
         }
 
-        $pid=file_get_contents($pidFile);
+        $pid = file_get_contents($pidFile);
 
         $output->writeln('Killing process '.$pid);
 
-        \posix_kill($pid,SIGTERM);
+        \posix_kill($pid, SIGTERM);
 
         unlink($pidFile);
 

Braces +3 added lines, -1 removed lines

@@ -6,7 +6,9 @@
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
-if (!defined('SIGTERM')) define('SIGTERM', 15);
+if (!defined('SIGTERM')) {
+    define('SIGTERM', 15);
+}
 
 class StopScheduledWorkerCommand extends ContainerAwareCommand
 {

Resque.php

Spacing +13 added lines, -13 removed lines

@@ -130,7 +130,7 @@ 
         
         $this->attachRetryStrategy($job);
 
-        return \ResqueScheduler::removeDelayed($job->queue, \get_class($job),$job->args);
+        return \ResqueScheduler::removeDelayed($job->queue, \get_class($job), $job->args);
     }
 
     public function removeFromTimestamp($at, Job $job)
@@ -146,7 +146,7 @@ 
 
     public function getQueues()
     {
-        return \array_map(function ($queue) {
+        return \array_map(function($queue) {
             return new Queue($queue);
         }, \Resque::queues());
     }
@@ -162,7 +162,7 @@ 
 
     public function getWorkers()
     {
-        return \array_map(function ($worker) {
+        return \array_map(function($worker) {
             return new Worker($worker);
         }, \Resque_Worker::all());
     }
@@ -188,12 +188,12 @@ 
 
     public function getDelayedJobTimestamps()
     {
-        $timestamps= \Resque::redis()->zrange('delayed_queue_schedule', 0, -1);
+        $timestamps = \Resque::redis()->zrange('delayed_queue_schedule', 0, -1);
 
         //TODO: find a more efficient way to do this
-        $out=array();
+        $out = array();
         foreach ($timestamps as $timestamp) {
-            $out[]=array($timestamp,\Resque::redis()->llen('delayed:'.$timestamp));
+            $out[] = array($timestamp, \Resque::redis()->llen('delayed:'.$timestamp));
         }
 
         return $out;
@@ -201,12 +201,12 @@ 
 
     public function getFirstDelayedJobTimestamp()
     {
-        $timestamps=$this->getDelayedJobTimestamps();
-        if (count($timestamps)>0) {
+        $timestamps = $this->getDelayedJobTimestamps();
+        if (count($timestamps) > 0) {
             return $timestamps[0];
         }
 
-        return array(null,0);
+        return array(null, 0);
     }
 
     public function getNumberOfDelayedJobs()
@@ -216,10 +216,10 @@ 
 
     public function getJobsForTimestamp($timestamp)
     {
-        $jobs= \Resque::redis()->lrange('delayed:'.$timestamp,0, -1);
-        $out=array();
+        $jobs = \Resque::redis()->lrange('delayed:'.$timestamp, 0, -1);
+        $out = array();
         foreach ($jobs as $job) {
-            $out[]=json_decode($job, true);
+            $out[] = json_decode($job, true);
         }
 
         return $out;
@@ -231,7 +231,7 @@ 
      */
     public function clearQueue($queue)
     {
-        $length=\Resque::redis()->llen('queue:'.$queue);
+        $length = \Resque::redis()->llen('queue:'.$queue);
         \Resque::redis()->del('queue:'.$queue);
 
         return $length;