alpixel / AlpixelCronBundle

src/Alpixel/Bundle/CronBundle/Command/CronEnableJobCommand.php

Spacing +3 added lines, -3 removed lines

@@ -24,15 +24,15 @@
         $jobRepo = $em->getRepository('CronBundle:CronJob');
 
         $job = $jobRepo->findOneByCommand($jobName);
-        if(!$job)
+        if (!$job)
         {
-            $output->writeln("Couldn't find a job by the name of " . $jobName);
+            $output->writeln("Couldn't find a job by the name of ".$jobName);
             return CronJobResult::FAILED;
         }
 
         $job->setEnabled(true);
         $em->flush();
 
-        $output->writeln("Enabled cron job by the name of " . $jobName);
+        $output->writeln("Enabled cron job by the name of ".$jobName);
     }
 }

src/Alpixel/Bundle/CronBundle/Command/CronStatusCommand.php

Spacing +10 added lines, -10 removed lines

@@ -27,13 +27,13 @@ 
         $output->writeln("Cron job statuses:");
 
         $cronJobs = array();
-        if($jobName = $input->getArgument('job'))
+        if ($jobName = $input->getArgument('job'))
         {
             try
             {
                 $cronJobs = array($jobRepo->findOneByCommand($jobName));
             }
-            catch(\Exception $e)
+            catch (\Exception $e)
             {
                 $output->writeln("Couldn't find a job by the name of $jobName");
                 return CronJobResult::FAILED;
@@ -44,16 +44,16 @@ 
             $cronJobs = $em->getRepository('CronBundle:CronJob')->findAll();
         }
 
-        foreach($cronJobs as $cronJob)
+        foreach ($cronJobs as $cronJob)
         {
-            $output->write(" - " . $cronJob->getCommand());
-            if(!$cronJob->getEnabled())
+            $output->write(" - ".$cronJob->getCommand());
+            if (!$cronJob->getEnabled())
             {
                 $output->write(" (disabled)");
             }
             $output->writeln("");
-            $output->writeln("   Description: " . $cronJob->getDescription());
-            if(!$cronJob->getEnabled())
+            $output->writeln("   Description: ".$cronJob->getDescription());
+            if (!$cronJob->getEnabled())
             {
                 $output->writeln("   Not scheduled");
             }
@@ -61,7 +61,7 @@ 
             {
                 $output->write("   Scheduled for: ");
                 $now = new \DateTime();
-                if($cronJob->getNextRun() <= $now)
+                if ($cronJob->getNextRun() <= $now)
                 {
                     $output->writeln("Next run");
                 }
@@ -70,10 +70,10 @@ 
                     $output->writeln(strftime("%c", $cronJob->getNextRun()->getTimestamp()));
                 }
             }
-            if($cronJob->getMostRecentRun())
+            if ($cronJob->getMostRecentRun())
             {
                 $status = "Unknown";
-                switch($cronJob->getMostRecentRun()->getResult())
+                switch ($cronJob->getMostRecentRun()->getResult())
                 {
                     case CronJobResult::SUCCEEDED:
                         $status = "Successful";

src/Alpixel/Bundle/CronBundle/Command/CronScanCommand.php

Spacing +8 added lines, -8 removed lines

@@ -42,16 +42,16 @@ 
         // Enumerate all the jobs currently loaded
         $reader = $this->getContainer()->get("annotation_reader");
 
-        foreach($this->getApplication()->all() as $command)
+        foreach ($this->getApplication()->all() as $command)
         {
             // Check for an @CronJob annotation
             $reflClass = new \ReflectionClass($command);
-            foreach($reader->getClassAnnotations($reflClass) as $anno)
+            foreach ($reader->getClassAnnotations($reflClass) as $anno)
             {
-                if($anno instanceof CronJobAnno)
+                if ($anno instanceof CronJobAnno)
                 {
                     $job = $command->getName();
-                    if(array_key_exists($job, $knownJobs))
+                    if (array_key_exists($job, $knownJobs))
                     {
                         // Clear it from the known jobs so that we don't try to delete it
                         unset($knownJobs[$job]);
@@ -59,7 +59,7 @@ 
                         // Update the job if necessary
                         $currentJob = $jobRepo->findOneByCommand($job);
                         $currentJob->setDescription($command->getDescription());
-                        if($currentJob->getInterval() != $anno->value)
+                        if ($currentJob->getInterval() != $anno->value)
                         {
                             $newTime = new \DateTime();
                             $newTime = $newTime->add(new \DateInterval($anno->value));
@@ -78,9 +78,9 @@ 
         }
 
         // Clear any jobs that weren't found
-        if(!$keepDeleted)
+        if (!$keepDeleted)
         {
-            foreach(array_keys($knownJobs) as $deletedJob)
+            foreach (array_keys($knownJobs) as $deletedJob)
             {
                 $output->writeln("Deleting job: $deletedJob");
                 $jobToDelete = $jobRepo->findOneByCommand($deletedJob);
@@ -101,7 +101,7 @@ 
         $newJob->setNextRun(new \DateTime());
         $newJob->setEnabled(!$defaultDisabled);
 
-        $output->writeln("Added the job " . $newJob->getCommand() . " with interval " . $newJob->getInterval());
+        $output->writeln("Added the job ".$newJob->getCommand()." with interval ".$newJob->getInterval());
         $em->persist($newJob);
     }
 }

src/Alpixel/Bundle/CronBundle/Command/MemoryWriter.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
 
     public function doWrite($message, $newline) {
         $this->backingStore .= $message;
-        if($newline) {
+        if ($newline) {
             $this->backingStore .= "\n";
         }
     }

src/Alpixel/Bundle/CronBundle/Command/CronPruneLogsCommand.php

Spacing +4 added lines, -4 removed lines

@@ -25,7 +25,7 @@ 
         $em = $this->getContainer()->get("doctrine.orm.entity_manager");
         $job = $input->getArgument('job');
 
-        if($job)
+        if ($job)
         {
             $output->writeln("Pruning logs for cron job $job");
         }
@@ -34,12 +34,12 @@ 
             $output->writeln("Pruning logs for all cron jobs");
         }
 
-        if($job)
+        if ($job)
         {
             $jobObj = $em->getRepository('CronBundle:CronJob')->findOneByCommand($job);
-            if(!$jobObj)
+            if (!$jobObj)
             {
-                $output->writeln("Couldn't find a job by the name of " . $job);
+                $output->writeln("Couldn't find a job by the name of ".$job);
                 return CronJobResult::FAILED;
             }
 

src/Alpixel/Bundle/CronBundle/Command/CronRunCommand.php

Spacing +12 added lines, -12 removed lines

@@ -32,17 +32,17 @@ 
         $jobRepo = $em->getRepository('CronBundle:CronJob');
 
         $jobsToRun = array();
-        if($jobName = $input->getArgument('job'))
+        if ($jobName = $input->getArgument('job'))
         {
             try
             {
                 $jobObj = $jobRepo->findOneByCommand($jobName);
-                if($jobObj->getEnabled())
+                if ($jobObj->getEnabled())
                 {
                     $jobsToRun = array($jobObj);
                 }
             }
-            catch(\Exception $e)
+            catch (\Exception $e)
             {
                 $output->writeln("Couldn't find a job by the name of $jobName");
                 return CronJobResult::FAILED;
@@ -56,7 +56,7 @@ 
         $jobCount = count($jobsToRun);
         $output->writeln("Running $jobCount jobs:");
 
-        foreach($jobsToRun as $job)
+        foreach ($jobsToRun as $job)
         {
             $this->runJob($job, $output, $em);
         }
@@ -71,13 +71,13 @@ 
 
     protected function runJob(CronJob $job, OutputInterface $output, EntityManager $em)
     {
-        $output->write("Running " . $job->getCommand() . ": ");
+        $output->write("Running ".$job->getCommand().": ");
 
         try
         {
             $commandToRun = $this->getApplication()->get($job->getCommand());
         }
-        catch(InvalidArgumentException $ex)
+        catch (InvalidArgumentException $ex)
         {
             $output->writeln(" skipped (command no longer exists)");
             $this->recordJobResult($em, $job, 0, "Command no longer exists", CronJobResult::SKIPPED);
@@ -94,32 +94,32 @@ 
         {
             $returnCode = $commandToRun->execute($emptyInput, $jobOutput);
         }
-        catch(\Exception $ex)
+        catch (\Exception $ex)
         {
             $returnCode = CronJobResult::FAILED;
             $jobOutput->writeln("");
-            $jobOutput->writeln("Job execution failed with exception " . get_class($ex) . ":");
+            $jobOutput->writeln("Job execution failed with exception ".get_class($ex).":");
             $jobOutput->writeln($ex->__toString());
         }
         $jobEnd = microtime(true);
 
         // Clamp the result to accepted values
-        if($returnCode < CronJobResult::RESULT_MIN || $returnCode > CronJobResult::RESULT_MAX)
+        if ($returnCode < CronJobResult::RESULT_MIN || $returnCode > CronJobResult::RESULT_MAX)
         {
             $returnCode = CronJobResult::FAILED;
         }
 
         // Output the result
         $statusStr = "unknown";
-        if($returnCode == CronJobResult::SKIPPED)
+        if ($returnCode == CronJobResult::SKIPPED)
         {
             $statusStr = "skipped";
         }
-        elseif($returnCode == CronJobResult::SUCCEEDED)
+        elseif ($returnCode == CronJobResult::SUCCEEDED)
         {
             $statusStr = "succeeded";
         }
-        elseif($returnCode == CronJobResult::FAILED)
+        elseif ($returnCode == CronJobResult::FAILED)
         {
             $statusStr = "failed";
         }

src/Alpixel/Bundle/CronBundle/Command/CronDisableJobCommand.php

Spacing +3 added lines, -3 removed lines

@@ -26,15 +26,15 @@
         $jobRepo = $em->getRepository('CronBundle:CronJob');
 
         $job = $jobRepo->findOneByCommand($jobName);
-        if(!$job)
+        if (!$job)
         {
-            $output->writeln("Couldn't find a job by the name of " . $jobName);
+            $output->writeln("Couldn't find a job by the name of ".$jobName);
             return CronJobResult::FAILED;
         }
 
         $job->setEnabled(false);
         $em->flush();
 
-        $output->writeln("Disabled cron job by the name of " . $jobName);
+        $output->writeln("Disabled cron job by the name of ".$jobName);
     }
 }

src/Alpixel/Bundle/CronBundle/Entity/Repository/CronJobRepository.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
                      ->createQuery("SELECT job.command FROM CronBundle:CronJob job")
                      ->getScalarResult();
         $toRet = array();
-        foreach($data as $datum)
+        foreach ($data as $datum)
         {
             $toRet[] = $datum['command'];
         }