CronCommand.php

Go to the documentation of this file.

<?php

namespace Elgg\Cli;

use Elgg\Exceptions\CronException;
use Symfony\Component\Console\Input\InputOption;

class CronCommand extends Command {

    protected function configure() {
        $this->setName('cron')
            ->setDescription(elgg_echo('cli:cron:description'))
            ->addOption('interval', 'i', InputOption::VALUE_OPTIONAL,
                elgg_echo('cli:cron:option:interval')
            )
            ->addOption('force', 'f', InputOption::VALUE_NONE,
                elgg_echo('cli:cron:option:force')
            )
            ->addOption('time', 't', InputOption::VALUE_OPTIONAL,
                elgg_echo('cli:cron:option:time')
            );
    }

    protected function command() {
        $intervals = null;
        $interval = $this->option('interval');
        if ($interval) {
            $intervals = [elgg_strtolower($interval)];
        }

        $time = $this->option('time');
        if (!$time) {
            $time = 'now';
        }

        $time = new \DateTime($time);
        _elgg_services()->cron->setCurrentTime($time);
        
        try {
            $jobs = _elgg_services()->cron->run($intervals, $this->option('force'));
            if (!$this->option('quiet')) {
                foreach ($jobs as $job) {
                    $this->write($job->getOutput());
                }
            }
        } catch (CronException $e) {
            $this->error($e->getMessage());
            return self::FAILURE;
        }

        return self::SUCCESS;
    }
}