SidRoberts / phalcon-cron

src/Manager.php

Spacing +1 added lines, -1 removed lines

@@ -51,7 +51,7 @@
 
         $jobs = array_filter(
             $jobs,
-            function ($job) use ($now) {
+            function($job) use ($now) {
                 return $job->isDue($now);
             }
         );

Indentation +94 added lines, -94 removed lines

@@ -4,129 +4,129 @@
 
 class Manager
 {
-    /**
-     * @var array
-     */
-    protected $jobs = [];
+	/**
+	 * @var array
+	 */
+	protected $jobs = [];
 
-    /**
-     * For background jobs.
-     *
-     * @var array
-     */
-    protected $processes = [];
+	/**
+	 * For background jobs.
+	 *
+	 * @var array
+	 */
+	protected $processes = [];
 
 
 
-    public function add(Job $job)
-    {
-        $this->jobs[] = $job;
-    }
+	public function add(Job $job)
+	{
+		$this->jobs[] = $job;
+	}
 
-    public function addCrontab(string $filename)
-    {
-        $crontab = new CrontabParser($filename);
+	public function addCrontab(string $filename)
+	{
+		$crontab = new CrontabParser($filename);
 
-        $jobs = $crontab->getJobs();
+		$jobs = $crontab->getJobs();
 
-        foreach ($jobs as $job) {
-            $this->add($job);
-        }
-    }
+		foreach ($jobs as $job) {
+			$this->add($job);
+		}
+	}
 
 
 
-    /**
-     * @param \DateTime|string $now
-     */
-    public function getDueJobs($now = null) : array
-    {
-        $jobs = $this->jobs;
+	/**
+	 * @param \DateTime|string $now
+	 */
+	public function getDueJobs($now = null) : array
+	{
+		$jobs = $this->jobs;
 
-        $jobs = array_filter(
-            $jobs,
-            function ($job) use ($now) {
-                return $job->isDue($now);
-            }
-        );
+		$jobs = array_filter(
+			$jobs,
+			function ($job) use ($now) {
+				return $job->isDue($now);
+			}
+		);
 
-        return $jobs;
-    }
+		return $jobs;
+	}
 
 
 
-    public function getAllJobs() : array
-    {
-        return $this->jobs;
-    }
+	public function getAllJobs() : array
+	{
+		return $this->jobs;
+	}
 
 
 
-    /**
-     * Run all due jobs in the foreground.
-     *
-     * @param \DateTime|string $now
-     */
-    public function runInForeground($now = null) : array
-    {
-        $jobs = $this->getDueJobs($now);
+	/**
+	 * Run all due jobs in the foreground.
+	 *
+	 * @param \DateTime|string $now
+	 */
+	public function runInForeground($now = null) : array
+	{
+		$jobs = $this->getDueJobs($now);
 
-        $outputs = [];
+		$outputs = [];
 
-        foreach ($jobs as $job) {
-            $outputs[] = $job->runInForeground();
-        }
+		foreach ($jobs as $job) {
+			$outputs[] = $job->runInForeground();
+		}
 
-        return $outputs;
-    }
+		return $outputs;
+	}
 
-    /**
-     * Run all due jobs in the background.
-     *
-     * @param \DateTime|string $now
-     */
-    public function runInBackground($now = null) : array
-    {
-        $jobs = $this->getDueJobs($now);
+	/**
+	 * Run all due jobs in the background.
+	 *
+	 * @param \DateTime|string $now
+	 */
+	public function runInBackground($now = null) : array
+	{
+		$jobs = $this->getDueJobs($now);
 
-        foreach ($jobs as $job) {
-            $this->processes[] = $job->runInBackground();
-        }
+		foreach ($jobs as $job) {
+			$this->processes[] = $job->runInBackground();
+		}
 
-        return $this->processes;
-    }
+		return $this->processes;
+	}
 
 
 
-    /**
-     * Wait for all jobs running in the background to finish.
-     */
-    public function wait()
-    {
-        foreach ($this->processes as $process) {
-            $process->wait();
-        }
-    }
+	/**
+	 * Wait for all jobs running in the background to finish.
+	 */
+	public function wait()
+	{
+		foreach ($this->processes as $process) {
+			$process->wait();
+		}
+	}
 
 
 
-    /**
-     * Terminate all jobs running in the background.
-     */
-    public function terminate()
-    {
-        foreach ($this->processes as $process) {
-            $process->terminate();
-        }
-    }
+	/**
+	 * Terminate all jobs running in the background.
+	 */
+	public function terminate()
+	{
+		foreach ($this->processes as $process) {
+			$process->terminate();
+		}
+	}
 
-    /**
-     * Kill all jobs running in the background.
-     */
-    public function kill()
-    {
-        foreach ($this->processes as $process) {
-            $process->kill();
-        }
-    }
+	/**
+	 * Kill all jobs running in the background.
+	 */
+	public function kill()
+	{
+		foreach ($this->processes as $process) {
+			$process->kill();
+		}
+	}
 }

src/Job/System.php

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
         $command = $this->getCommand();
 
         if ($this->getOutput()) {
-            $command .= ' > ' . $this->getOutput() . ' 2>&1';
+            $command .= ' > '.$this->getOutput().' 2>&1';
         }
 
         return $command;

Indentation +42 added lines, -42 removed lines

@@ -6,63 +6,63 @@
 
 class System extends Job
 {
-    /**
-     * @var string
-     */
-    protected $command;
+	/**
+	 * @var string
+	 */
+	protected $command;
 
-    /**
-     * @var string
-     */
-    protected $output;
+	/**
+	 * @var string
+	 */
+	protected $output;
 
 
 
-    public function __construct(string $expression, string $command, string $output = null)
-    {
-        parent::__construct($expression);
+	public function __construct(string $expression, string $command, string $output = null)
+	{
+		parent::__construct($expression);
 
-        $this->command = $command;
-        $this->output  = $output;
-    }
+		$this->command = $command;
+		$this->output  = $output;
+	}
 
 
 
-    public function getCommand() : string
-    {
-        return $this->command;
-    }
+	public function getCommand() : string
+	{
+		return $this->command;
+	}
 
-    /**
-     * @return string
-     */
-    public function getOutput()
-    {
-        return $this->output;
-    }
+	/**
+	 * @return string
+	 */
+	public function getOutput()
+	{
+		return $this->output;
+	}
 
 
 
-    private function buildCommand() : string
-    {
-        $command = $this->getCommand();
+	private function buildCommand() : string
+	{
+		$command = $this->getCommand();
 
-        if ($this->getOutput()) {
-            $command .= ' > ' . $this->getOutput() . ' 2>&1';
-        }
+		if ($this->getOutput()) {
+			$command .= ' > ' . $this->getOutput() . ' 2>&1';
+		}
 
-        return $command;
-    }
+		return $command;
+	}
 
 
 
-    /**
-     * @return string
-     */
-    public function runInForeground()
-    {
-        return shell_exec(
-            $this->buildCommand()
-        );
-    }
+	/**
+	 * @return string
+	 */
+	public function runInForeground()
+	{
+		return shell_exec(
+			$this->buildCommand()
+		);
+	}
 }

src/Process.php

Indentation +62 added lines, -62 removed lines

@@ -9,86 +9,86 @@
  */
 class Process
 {
-    /**
-     * @var int
-     */
-    protected $processID;
+	/**
+	 * @var int
+	 */
+	protected $processID;
 
 
 
-    public function __construct(int $processID)
-    {
-        $this->processID = $processID;
+	public function __construct(int $processID)
+	{
+		$this->processID = $processID;
 
 
 
-        register_shutdown_function(
-            [
-                $this,
-                "wait",
-            ]
-        );
-    }
+		register_shutdown_function(
+			[
+				$this,
+				"wait",
+			]
+		);
+	}
 
 
 
-    public function getProcessID() : int
-    {
-        return $this->processID;
-    }
+	public function getProcessID() : int
+	{
+		return $this->processID;
+	}
 
 
 
-    /**
-     * Determine if this process is currently running. Defunct/zombie processes
-     * are ignored.
-     */
-    public function isRunning() : bool
-    {
-        $result = shell_exec(
-            sprintf(
-                "ps %d | grep -v '<defunct>'",
-                $this->getProcessID()
-            )
-        );
+	/**
+	 * Determine if this process is currently running. Defunct/zombie processes
+	 * are ignored.
+	 */
+	public function isRunning() : bool
+	{
+		$result = shell_exec(
+			sprintf(
+				"ps %d | grep -v '<defunct>'",
+				$this->getProcessID()
+			)
+		);
 
-        return (count(preg_split("/\n/", $result)) > 2);
-    }
+		return (count(preg_split("/\n/", $result)) > 2);
+	}
 
 
 
-    /**
-     * Wait for the process to finish.
-     */
-    public function wait()
-    {
-        pcntl_waitpid(
-            $this->getProcessID(),
-            $status
-        );
-    }
+	/**
+	 * Wait for the process to finish.
+	 */
+	public function wait()
+	{
+		pcntl_waitpid(
+			$this->getProcessID(),
+			$status
+		);
+	}
 
 
 
-    /**
-     * Terminate the process.
-     */
-    public function terminate() : bool
-    {
-        return posix_kill(
-            $this->getProcessID(),
-            SIGTERM
-        );
-    }
+	/**
+	 * Terminate the process.
+	 */
+	public function terminate() : bool
+	{
+		return posix_kill(
+			$this->getProcessID(),
+			SIGTERM
+		);
+	}
 
-    /**
-     * Kill the process.
-     */
-    public function kill() : bool
-    {
-        return posix_kill(
-            $this->getProcessID(),
-            SIGKILL
-        );
-    }
+	/**
+	 * Kill the process.
+	 */
+	public function kill() : bool
+	{
+		return posix_kill(
+			$this->getProcessID(),
+			SIGKILL
+		);
+	}
 }

src/Job.php

Indentation +47 added lines, -47 removed lines

@@ -7,70 +7,70 @@
 
 abstract class Job extends Injectable
 {
-    /**
-     * @var string
-     */
-    protected $expression;
+	/**
+	 * @var string
+	 */
+	protected $expression;
 
 
 
-    public function __construct(string $expression)
-    {
-        $this->expression = $expression;
-    }
+	public function __construct(string $expression)
+	{
+		$this->expression = $expression;
+	}
 
 
 
-    public function getExpression() : string
-    {
-        return $this->expression;
-    }
+	public function getExpression() : string
+	{
+		return $this->expression;
+	}
 
 
 
-    /**
-     * @param \DateTime|string $datetime
-     */
-    public function isDue($datetime = "now") : bool
-    {
-        $cronExpression = CronExpression::factory(
-            $this->getExpression()
-        );
+	/**
+	 * @param \DateTime|string $datetime
+	 */
+	public function isDue($datetime = "now") : bool
+	{
+		$cronExpression = CronExpression::factory(
+			$this->getExpression()
+		);
 
-        return $cronExpression->isDue($datetime);
-    }
+		return $cronExpression->isDue($datetime);
+	}
 
 
 
-    /**
-     * @return mixed
-     */
-    abstract public function runInForeground();
+	/**
+	 * @return mixed
+	 */
+	abstract public function runInForeground();
 
-    /**
-     * @throws Exception
-     */
-    public function runInBackground() : Process
-    {
-        $processID = pcntl_fork();
+	/**
+	 * @throws Exception
+	 */
+	public function runInBackground() : Process
+	{
+		$processID = pcntl_fork();
 
-        if ($processID == -1) {
-            throw new Exception(
-                "Failed to fork process."
-            );
-        }
+		if ($processID == -1) {
+			throw new Exception(
+				"Failed to fork process."
+			);
+		}
 
-        // This is the child process.
-        if ($processID == 0) {
-            // @codeCoverageIgnoreStart
-            $this->runInForeground();
+		// This is the child process.
+		if ($processID == 0) {
+			// @codeCoverageIgnoreStart
+			$this->runInForeground();
 
-            exit(0);
-            // @codeCoverageIgnoreEnd
-        }
+			exit(0);
+			// @codeCoverageIgnoreEnd
+		}
 
-        $process = new Process($processID);
+		$process = new Process($processID);
 
-        return $process;
-    }
+		return $process;
+	}
 }

src/Job/Callback.php

Indentation +21 added lines, -21 removed lines

@@ -6,36 +6,36 @@
 
 class Callback extends Job
 {
-    /**
-     * @var callable
-     */
-    protected $callback;
+	/**
+	 * @var callable
+	 */
+	protected $callback;
     
     
 
-    public function __construct(string $expression, callable $callback)
-    {
-        parent::__construct($expression);
+	public function __construct(string $expression, callable $callback)
+	{
+		parent::__construct($expression);
         
-        $this->callback = $callback;
-    }
+		$this->callback = $callback;
+	}
     
     
     
-    public function getCallback() : callable
-    {
-        return $this->callback;
-    }
+	public function getCallback() : callable
+	{
+		return $this->callback;
+	}
     
     
     
-    /**
-     * @return mixed
-     */
-    public function runInForeground()
-    {
-        $contents = call_user_func($this->callback);
+	/**
+	 * @return mixed
+	 */
+	public function runInForeground()
+	{
+		$contents = call_user_func($this->callback);
         
-        return $contents;
-    }
+		return $contents;
+	}
 }

src/Job/Phalcon.php

Indentation +37 added lines, -37 removed lines

@@ -7,60 +7,60 @@
 
 class Phalcon extends Job
 {
-    /**
-     * @var array|null
-     */
-    protected $body;
+	/**
+	 * @var array|null
+	 */
+	protected $body;
 
 
 
-    /**
-     * @param array|null $body
-     *
-     * @throws Exception
-     */
-    public function __construct(string $expression, $body = null)
-    {
-        $di = $this->getDI();
-        if (!($di instanceof DiInterface)) {
-            throw new Exception(
-                "A dependency injection object is required to access internal services"
-            );
-        }
+	/**
+	 * @param array|null $body
+	 *
+	 * @throws Exception
+	 */
+	public function __construct(string $expression, $body = null)
+	{
+		$di = $this->getDI();
+		if (!($di instanceof DiInterface)) {
+			throw new Exception(
+				"A dependency injection object is required to access internal services"
+			);
+		}
 
 
 
-        parent::__construct($expression);
+		parent::__construct($expression);
 
 
 
-        $this->body = $body;
-    }
+		$this->body = $body;
+	}
 
 
 
-    /**
-     * @return array|null
-     */
-    public function getBody()
-    {
-        return $this->body;
-    }
+	/**
+	 * @return array|null
+	 */
+	public function getBody()
+	{
+		return $this->body;
+	}
 
 
 
-    public function runInForeground() : string
-    {
-        ob_start();
+	public function runInForeground() : string
+	{
+		ob_start();
 
-        $this->getDI()->get("console")->handle(
-            $this->getBody()
-        );
+		$this->getDI()->get("console")->handle(
+			$this->getBody()
+		);
 
-        $contents = ob_get_contents();
+		$contents = ob_get_contents();
 
-        ob_end_clean();
+		ob_end_clean();
 
-        return $contents;
-    }
+		return $contents;
+	}
 }

src/CrontabParser.php

Indentation +31 added lines, -31 removed lines

@@ -6,46 +6,46 @@
 
 class CrontabParser
 {
-    /**
-     * @var string
-     */
-    protected $filename;
+	/**
+	 * @var string
+	 */
+	protected $filename;
 
 
 
-    /**
-     * @throws Exception
-     */
-    public function __construct(string $filename)
-    {
-        if (!file_exists($filename)) {
-            throw new Exception(
-                "Crontab file does not exist."
-            );
-        }
+	/**
+	 * @throws Exception
+	 */
+	public function __construct(string $filename)
+	{
+		if (!file_exists($filename)) {
+			throw new Exception(
+				"Crontab file does not exist."
+			);
+		}
 
-        $this->filename = $filename;
-    }
+		$this->filename = $filename;
+	}
 
 
 
-    public function getJobs() : array
-    {
-        $contents = file_get_contents($this->filename);
+	public function getJobs() : array
+	{
+		$contents = file_get_contents($this->filename);
 
-        $lines = explode(PHP_EOL, $contents);
+		$lines = explode(PHP_EOL, $contents);
 
-        $jobs = [];
+		$jobs = [];
 
-        foreach ($lines as $line) {
-            if (preg_match("/^(\@\w+|[^\s]+\s[^\s]+\s[^\s]+\s[^\s]+\s[^\s]+)\s+(.*)$/", $line, $matches)) {
-                $jobs[] = new SystemJob(
-                    $matches[1],
-                    $matches[2]
-                );
-            }
-        }
+		foreach ($lines as $line) {
+			if (preg_match("/^(\@\w+|[^\s]+\s[^\s]+\s[^\s]+\s[^\s]+\s[^\s]+)\s+(.*)$/", $line, $matches)) {
+				$jobs[] = new SystemJob(
+					$matches[1],
+					$matches[2]
+				);
+			}
+		}
 
-        return $jobs;
-    }
+		return $jobs;
+	}
 }