SidRoberts / phalcon-cron

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