class.ilCronEcsTaskScheduler.php

Go to the documentation of this file.

<?php
 
use ILIAS\Cron\Job\Schedule\JobScheduleType;
use ILIAS\Cron\Job\JobResult;
 
class ilCronEcsTaskScheduler extends \ILIAS\Cron\CronJob
{
    public const ID = 'ecs_task_handler';
    public const DEFAULT_SCHEDULE_VALUE = 1;
 
    private ilLogger $logger;
    private ilLanguage $lng;
    private JobResult $result;
 
    public function __construct()
    {
        global $DIC;
 
        $this->logger = $DIC->logger()->wsrv();
        $this->lng = $DIC->language();
        $this->lng->loadLanguageModule('ecs');
 
        $this->result = new \ILIAS\Cron\Job\JobResult();
    }
 
    public function getTitle(): string
    {
        return $this->lng->txt('ecs_cron_task_scheduler');
    }
 
    public function getDescription(): string
    {
        return $this->lng->txt('ecs_cron_task_scheduler_info');
    }
 
    public function getId(): string
    {
        return self::ID;
    }
 
    public function hasAutoActivation(): bool
    {
        return false;
    }
 
    public function hasFlexibleSchedule(): bool
    {
        return true;
    }
 
    public function getDefaultScheduleType(): JobScheduleType
    {
        return JobScheduleType::IN_HOURS;
    }
 
    public function getDefaultScheduleValue(): ?int
    {
        return self::DEFAULT_SCHEDULE_VALUE;
    }
 
    public function run(): JobResult
    {
        $this->logger->debug('Starting ecs task scheduler...');
 
        $servers = \ilECSServerSettings::getInstance();
 
        foreach ($servers->getServers(ilECSServerSettings::ACTIVE_SERVER) as $server) {
            try {
                $this->logger->info('Starting task execution for ecs server: ' . $server->getTitle());
                $scheduler = \ilECSTaskScheduler::_getInstanceByServerId($server->getServerId());
                $scheduler->startTaskExecution();
            } catch (Exception $e) {
                $this->result->setStatus(\ILIAS\Cron\Job\JobResult::STATUS_CRASHED);
                $this->result->setMessage(
                    mb_substr(sprintf('Exc.: %s / %s', $e->getMessage(), $e->getTraceAsString()), 0, 400)
                );
                $this->logger->error('ECS task execution failed with message: ' . $e->getMessage());
                $this->logger->error($e->getTraceAsString());
                return $this->result;
            }
        }
        $this->result->setStatus(\ILIAS\Cron\Job\JobResult::STATUS_OK);
        return $this->result;
    }
}