Sid\Phalcon\Cron\Manager

Complexity

Total Complexity

12

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	addCrontab()	0	10	2
A	runInForeground()	0	12	2
A	runInBackground()	0	10	2
A	wait()	0	6	2
A	terminate()	0	6	2
A	kill()	0	6	2

<?php

namespace Sid\Phalcon\Cron;

use DateTime;

class Manager extends \Sid\Cron\Manager
{
    /**
     * For background jobs.
     *
     * @var array
     */
    protected $processes = [];



    public function addCrontab(string $filename)
    {
        $crontab = new CrontabParser($filename);

        $jobs = $crontab->getJobs();

        foreach ($jobs as $job) {
            $this->add($job);
        }
    }



    /**
     * Run all due jobs in the foreground.
     */
    public function runInForeground(DateTime $now = null) : array
    {
        $jobs = $this->getDueJobs($now);

        $outputs = [];

        foreach ($jobs as $job) {
            $outputs[] = $job->runInForeground();
        }

        return $outputs;
    }

    /**
     * Run all due jobs in the background.
     */
    public function runInBackground(DateTime $now = null) : array
    {
        $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();
        }
    }
}