SidRoberts / phalcon-cron

src/Manager.php

Indentation +138 added lines, -138 removed lines

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

src/Process.php

Indentation +55 added lines, -55 removed lines

@@ -9,79 +9,79 @@
  */
 class Process
 {
-    /**
-     * @var int
-     */
-    protected $processID;
+	/**
+	 * @var int
+	 */
+	protected $processID;
 
 
 
-    /**
-     * @param int $processID
-     */
-    public function __construct($processID)
-    {
-        $this->processID = $processID;
+	/**
+	 * @param int $processID
+	 */
+	public function __construct($processID)
+	{
+		$this->processID = $processID;
 
 
 
-        register_shutdown_function([$this, "wait"]);
-    }
+		register_shutdown_function([$this, "wait"]);
+	}
 
 
 
-    /**
-     * @return int
-     */
-    public function getProcessID()
-    {
-        return $this->processID;
-    }
+	/**
+	 * @return int
+	 */
+	public function getProcessID()
+	{
+		return $this->processID;
+	}
 
 
 
-    /**
-     * Determine if this process is currently running. Defunct/zombie processes
-     * are ignored.
-     *
-     * @return boolean
-     */
-    public function isRunning()
-    {
-        $result = shell_exec(sprintf("ps %d", $this->getProcessID()) . " | grep -v '<defunct>'");
+	/**
+	 * Determine if this process is currently running. Defunct/zombie processes
+	 * are ignored.
+	 *
+	 * @return boolean
+	 */
+	public function isRunning()
+	{
+		$result = shell_exec(sprintf("ps %d", $this->getProcessID()) . " | grep -v '<defunct>'");
 
-        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.
-     *
-     * @return boolean
-     */
-    public function terminate()
-    {
-        return posix_kill($this->getProcessID(), SIGTERM);
-    }
+	/**
+	 * Terminate the process.
+	 *
+	 * @return boolean
+	 */
+	public function terminate()
+	{
+		return posix_kill($this->getProcessID(), SIGTERM);
+	}
 
-    /**
-     * Kill the process.
-     *
-     * @return boolean
-     */
-    public function kill()
-    {
-        return posix_kill($this->getProcessID(), SIGKILL);
-    }
+	/**
+	 * Kill the process.
+	 *
+	 * @return boolean
+	 */
+	public function kill()
+	{
+		return posix_kill($this->getProcessID(), SIGKILL);
+	}
 }

src/Job/System.php

Indentation +51 added lines, -51 removed lines

@@ -6,72 +6,72 @@
 
 class System extends Job
 {
-    /**
-     * @var string
-     */
-    protected $command;
+	/**
+	 * @var string
+	 */
+	protected $command;
 
-    /**
-     * @var string
-     */
-    protected $output;
+	/**
+	 * @var string
+	 */
+	protected $output;
 
 
 
-    /**
-     * @param string $expression
-     * @param string $command
-     * @param string $output
-     */
-    public function __construct($expression, $command, $output = null)
-    {
-        parent::__construct($expression);
+	/**
+	 * @param string $expression
+	 * @param string $command
+	 * @param string $output
+	 */
+	public function __construct($expression, $command, $output = null)
+	{
+		parent::__construct($expression);
 
-        $this->command = $command;
-        $this->output  = $output;
-    }
+		$this->command = $command;
+		$this->output  = $output;
+	}
 
 
 
-    /**
-     * @return string
-     */
-    public function getCommand()
-    {
-        return $this->command;
-    }
+	/**
+	 * @return string
+	 */
+	public function getCommand()
+	{
+		return $this->command;
+	}
 
-    /**
-     * @return string
-     */
-    public function getOutput()
-    {
-        return $this->output;
-    }
+	/**
+	 * @return string
+	 */
+	public function getOutput()
+	{
+		return $this->output;
+	}
 
 
 
-    /**
-     * @return string
-     */
-    private function buildCommand()
-    {
-        $command = $this->getCommand();
+	/**
+	 * @return string
+	 */
+	private function buildCommand()
+	{
+		$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/Job/Callback.php

Indentation +28 added lines, -28 removed lines

@@ -6,43 +6,43 @@
 
 class Callback extends Job
 {
-    /**
-     * @var callable
-     */
-    protected $callback;
+	/**
+	 * @var callable
+	 */
+	protected $callback;
     
     
     
-    /**
-     * @param string   $expression
-     * @param callable $callback
-     */
-    public function __construct($expression, callable $callback)
-    {
-        parent::__construct($expression);
+	/**
+	 * @param string   $expression
+	 * @param callable $callback
+	 */
+	public function __construct($expression, callable $callback)
+	{
+		parent::__construct($expression);
         
-        $this->callback = $callback;
-    }
+		$this->callback = $callback;
+	}
     
     
     
-    /**
-     * @return callable
-     */
-    public function getCallback()
-    {
-        return $this->callback;
-    }
+	/**
+	 * @return callable
+	 */
+	public function getCallback()
+	{
+		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 +39 added lines, -39 removed lines

@@ -7,62 +7,62 @@
 
 class Phalcon extends Job
 {
-    /**
-     * @var array|null
-     */
-    protected $body;
+	/**
+	 * @var array|null
+	 */
+	protected $body;
 
 
 
-    /**
-     * @param string     $expression
-     * @param array|null $body
-     *
-     * @throws Exception
-     */
-    public function __construct($expression, $body = null)
-    {
-        $di = $this->getDI();
-        if (!($di instanceof DiInterface)) {
-            throw new Exception("A dependency injection object is required to access internal services");
-        }
+	/**
+	 * @param string     $expression
+	 * @param array|null $body
+	 *
+	 * @throws Exception
+	 */
+	public function __construct($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;
+	}
 
 
 
-    /**
-     * @return string
-     */
-    public function runInForeground()
-    {
-        ob_start();
+	/**
+	 * @return string
+	 */
+	public function runInForeground()
+	{
+		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;
 
 
 
-    /**
-     * @param string $filename
-     *
-     * @throws Exception
-     */
-    public function __construct($filename)
-    {
-        if (!file_exists($filename)) {
-            throw new Exception("Crontab file does not exist.");
-        }
+	/**
+	 * @param string $filename
+	 *
+	 * @throws Exception
+	 */
+	public function __construct($filename)
+	{
+		if (!file_exists($filename)) {
+			throw new Exception("Crontab file does not exist.");
+		}
 
-        $this->filename = $filename;
-    }
+		$this->filename = $filename;
+	}
 
 
 
-    /**
-     * @return array
-     */
-    public function getJobs()
-    {
-        $contents = file_get_contents($this->filename);
+	/**
+	 * @return array
+	 */
+	public function getJobs()
+	{
+		$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;
+	}
 }

src/Job.php

Indentation +52 added lines, -52 removed lines

@@ -7,74 +7,74 @@
 
 abstract class Job extends Injectable
 {
-    /**
-     * @var string
-     */
-    protected $expression;
+	/**
+	 * @var string
+	 */
+	protected $expression;
 
 
 
-    /**
-     * @param string $expression
-     */
-    public function __construct($expression)
-    {
-        $this->expression = $expression;
-    }
+	/**
+	 * @param string $expression
+	 */
+	public function __construct($expression)
+	{
+		$this->expression = $expression;
+	}
 
 
 
-    /**
-     * @return string
-     */
-    public function getExpression()
-    {
-        return $this->expression;
-    }
+	/**
+	 * @return string
+	 */
+	public function getExpression()
+	{
+		return $this->expression;
+	}
 
 
 
-    /**
-     * @param \DateTime|string $datetime
-     *
-     * @return boolean
-     */
-    public function isDue($datetime = "now")
-    {
-        return CronExpression::factory($this->getExpression())->isDue($datetime);
-    }
+	/**
+	 * @param \DateTime|string $datetime
+	 *
+	 * @return boolean
+	 */
+	public function isDue($datetime = "now")
+	{
+		return CronExpression::factory($this->getExpression())->isDue($datetime);
+	}
 
 
 
-    /**
-     * @return mixed
-     */
-    abstract public function runInForeground();
+	/**
+	 * @return mixed
+	 */
+	abstract public function runInForeground();
 
-    /**
-     * @return Process
-     *
-     * @throws Exception
-     */
-    public function runInBackground()
-    {
-        $processID = pcntl_fork();
+	/**
+	 * @return Process
+	 *
+	 * @throws Exception
+	 */
+	public function runInBackground()
+	{
+		$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;
+	}
 }