Cron.php

Go to the documentation of this file.

<?php
 
namespace Elgg\Logger;
 
use Elgg\Application;
use Elgg\Cli\CronLogHandler;
use Elgg\Exceptions\InvalidArgumentException;
use Monolog\Handler\StreamHandler;
use Monolog\Processor\MemoryPeakUsageProcessor;
use Monolog\Processor\MemoryUsageProcessor;
use Monolog\Processor\ProcessIdProcessor;
use Monolog\Processor\PsrLogMessageProcessor;
use Monolog\Processor\TagProcessor;
 
class Cron extends \Monolog\Logger {
    
    protected const CHANNEL = 'CRON';
    
    public static function factory(array $params = []): static {
        $interval = elgg_extract('interval', $params);
        $cron = _elgg_services()->cron;
        if (empty($interval) || !in_array($interval, $cron->getConfiguredIntervals(true))) {
            throw new InvalidArgumentException('Please specify a valid cron interval');
        }
        
        $filename = elgg_extract('filename', $params);
        if (empty($filename)) {
            throw new InvalidArgumentException('Please provide a log filename');
        }
        
        $logger = new static(self::CHANNEL);
        
        // default file output handler
        $handler = new StreamHandler($filename);
        
        $formatter = new ElggLogFormatter();
        $formatter->allowInlineLineBreaks();
        $formatter->ignoreEmptyContextAndExtra();
        
        $handler->setFormatter($formatter);
        
        $handler->pushProcessor(new MemoryUsageProcessor());
        $handler->pushProcessor(new MemoryPeakUsageProcessor());
        $handler->pushProcessor(new ProcessIdProcessor());
        $handler->pushProcessor(new TagProcessor([$interval]));
        $handler->pushProcessor(new PsrLogMessageProcessor());
        
        $logger->pushHandler($handler);
        
        // in cli add handler to log to stdout
        if (Application::isCli() && !_elgg_services()->config->testing_mode) {
            $cli_output = new CronLogHandler();
 
            $cli_output->pushProcessor(new MemoryUsageProcessor());
            $cli_output->pushProcessor(new MemoryPeakUsageProcessor());
            $cli_output->pushProcessor(new ProcessIdProcessor());
            $cli_output->pushProcessor(new TagProcessor([$interval]));
            $cli_output->pushProcessor(new PsrLogMessageProcessor());
 
            $logger->pushHandler($cli_output);
        }
        
        return $logger;
    }
}