resquebundle / resque

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);
 

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;
     }

DependencyInjection/ResqueExtension.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
         $configuration = new Configuration();
         $config        = $this->processConfiguration($configuration, $configs);
 
-        $loader = new Loader\XmlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
+        $loader = new Loader\XmlFileLoader($container, new FileLocator(__DIR__ . '/../Resources/config'));
         $loader->load('services.xml');
 
         $container->setParameter('resque.vendor_dir', $config['vendor_dir']);

DependencyInjection/Configuration.php

Spacing +2 added lines, -2 removed lines

@@ -27,7 +27,7 @@ 
 
         if (method_exists($treeBuilder, 'getRootNode')) {
             // Symfony 4+
-            $root =   $treeBuilder->getRootNode();
+            $root = $treeBuilder->getRootNode();
         } else {
             // Symfony 3
             $root = $treeBuilder->root('resque');
@@ -56,7 +56,7 @@ 
                 ->arrayNode('auto_retry')
                     ->beforeNormalization()
                         ->ifArray()
-                        ->then(function ($var) {
+                        ->then(function($var) {
                             if (\array_key_exists(0, $var)) {
                                 return [$var];
                             }