Cron.php

Go to the documentation of this file.

<?php

namespace Elgg;

use DateTime;
use GO\Job;
use GO\Scheduler;

class Cron {

    use Loggable;
    use TimeUsing;

    static $intervals = [
        'minute' => '* * * * *',
        'fiveminute' => '*/5 * * * *',
        'fifteenmin' => '*/15 * * * *',
        'halfhour' => '*/30 * * * *',
        'hourly' => '0 * * * *',
        'daily' => '0 0 * * *',
        'weekly' => '0 0 * * 0',
        'monthly' => '0 0 1 * *',
        'yearly' => '0 0 1 1 *',
    ];

    protected $hooks;

    protected $events;

    public function __construct(PluginHooksService $hooks, Logger $logger, EventsService $events) {
        $this->hooks = $hooks;
        $this->logger = $logger;
        $this->events = $events;
    }

    public function run(array $intervals = null, $force = false) {

        if (!isset($intervals)) {
            $intervals = array_keys(self::$intervals);
        }

        $scheduler = new Scheduler();

        $time = $this->getCurrentTime();

        foreach ($intervals as $interval) {
            if (!array_key_exists($interval, self::$intervals)) {
                throw new \CronException("$interval is not a recognized cron interval");
            }

            $cron_interval = $force ? self::$intervals['minute'] : self::$intervals[$interval];

            $scheduler
                ->call(function () use ($interval, $time) {
                    return $this->execute($interval, $time);
                })
                ->at($cron_interval)
                ->before(function () use ($interval, $time) {
                    $this->before($interval, $time);
                })
                ->then(function ($output) use ($interval) {
                    $this->after($output, $interval);
                });
        }

        return $scheduler->run($time);
    }

    protected function before($interval, DateTime $time = null) {

        if (!isset($time)) {
            $time = $this->getCurrentTime();
        }

        $this->events->triggerBefore('cron', $interval, $time);

        // give every period at least 'max_execution_time' (PHP ini setting)
        set_time_limit((int) ini_get('max_execution_time'));

        $now = new DateTime();

        $msg = elgg_echo('admin:cron:started', [$interval, $time->format(DATE_RFC2822)]) . PHP_EOL;
        $msg .= elgg_echo('admin:cron:started:actual', [$interval, $now->format(DATE_RFC2822)]) . PHP_EOL;

        $this->log('output', $interval, $msg);
    }

    protected function execute($interval, DateTime $time = null) {

        if (!isset($time)) {
            $time = $this->getCurrentTime();
        }

        $now = new DateTime();

        $output = [];

        $output[] = elgg_echo('admin:cron:started', [$interval, $time->format(DATE_RFC2822)]);
        $output[] = elgg_echo('admin:cron:started:actual', [$interval, $now->format(DATE_RFC2822)]);

        ob_start();

        $old_stdout = $this->hooks->trigger('cron', $interval, [
            'time' => $time->getTimestamp(),
            'dt' => $time,
        ], '');

        $output[] = ob_get_clean();
        $output[] = $old_stdout;

        $now = new DateTime();

        $output[] = elgg_echo('admin:cron:complete', [$interval, $now->format(DATE_RFC2822)]);

        return implode(PHP_EOL, array_filter($output));
    }

    protected function after($output, $interval) {

        $time = new DateTime();

        $this->log('output', $interval, $output);
        $this->log('completion', $interval, $time->getTimestamp());

        $this->logger->info($output);

        $this->events->triggerAfter('cron', $interval, $time);
    }

    protected function log($setting, $interval, $msg = '') {
        $suffix = $setting ? : 'output';
        
        $fh = new \ElggFile();
        $fh->owner_guid = elgg_get_site_entity()->guid;
        $fh->setFilename("{$interval}-{$suffix}.log");
        
        $fh->open('write');
        $fh->write($msg);
        $fh->close();
    }
    
    public function getLog($setting, $interval) {
        $suffix = $setting ? : 'output';
        
        $fh = new \ElggFile();
        $fh->owner_guid = elgg_get_site_entity()->guid;
        $fh->setFilename("{$interval}-{$suffix}.log");
        
        if (!$fh->exists()) {
            return '';
        }
        
        $contents = $fh->grabFile();
        if (!is_string($contents)) {
            $contents = '';
        }
        
        return $contents;
    }
}