ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl Class Reference

Inheritance diagram for ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl:

Collaboration diagram for ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl:

Public Member Functions
	__construct (private JobRepository $job_repository, private \ilDBInterface $db, private \ilSetting $settings, private \ilLogger $logger, private \ILIAS\Data\Clock\ClockFactory $clock_factory)
	runActiveJobs (\ilObjUser $actor)
	runJobManual (string $jobId, \ilObjUser $actor)
	resetJob (\ILIAS\Cron\CronJob $job, \ilObjUser $actor)
	activateJob (\ILIAS\Cron\CronJob $job, \ilObjUser $actor, bool $wasManuallyExecuted=false)
	deactivateJob (\ILIAS\Cron\CronJob $job, \ilObjUser $actor, bool $wasManuallyExecuted=false)
	isJobActive (string $jobId)
	isJobInactive (string $jobId)
	ping (string $jobId)

Private Member Functions
	getMicrotime ()
	runJob (\ILIAS\Cron\CronJob $job, \ilObjUser $actor, ?array $jobData=null, bool $isManualExecution=false)
	Run single cron job (internal) More...

Detailed Description

Definition at line 26 of file JobManagerImpl.php.

Constructor & Destructor Documentation

__construct()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::__construct	(	private JobRepository	$job_repository,
		private \ilDBInterface	$db,
		private \ilSetting	$settings,
		private \ilLogger	$logger,
		private \ILIAS\Data\Clock\ClockFactory	$clock_factory
	)

Definition at line 28 of file JobManagerImpl.php.

      {
    }

Member Function Documentation

activateJob()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::activateJob	(	\ILIAS\Cron\CronJob	$job,
		\ilObjUser	$actor,
		bool	$wasManuallyExecuted = false
	)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 240 of file JobManagerImpl.php.

References ILIAS\Repository\settings().

Referenced by ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\resetJob().

                                                                                                               : void
    {
        $this->job_repository->activateJob($job, $this->clock_factory->system()->now(), $actor, $wasManuallyExecuted);
        $job->activationWasToggled($this->db, $this->settings, true);
    }

Here is the call graph for this function:

Here is the caller graph for this function:

deactivateJob()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::deactivateJob	(	\ILIAS\Cron\CronJob	$job,
		\ilObjUser	$actor,
		bool	$wasManuallyExecuted = false
	)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 246 of file JobManagerImpl.php.

References ILIAS\Repository\settings().

Referenced by ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\runJob().

                                                                                                                 : void
    {
        $this->job_repository->deactivateJob($job, $this->clock_factory->system()->now(), $actor, $wasManuallyExecuted);
        $job->activationWasToggled($this->db, $this->settings, false);
    }

Here is the call graph for this function:

Here is the caller graph for this function:

getMicrotime()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::getMicrotime ( )

private

Definition at line 37 of file JobManagerImpl.php.

Referenced by ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\runJob().

                                   : float
    {
        return ((int) $this->clock_factory->system()->now()->format('Uu')) / 1000000;
    }

Here is the caller graph for this function:

isJobActive()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::isJobActive

(

string

$jobId

)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 252 of file JobManagerImpl.php.

                                              : bool
    {
        $jobs_data = $this->job_repository->getCronJobData($jobId);

        return $jobs_data !== [] && $jobs_data[0]['job_status'];
    }

isJobInactive()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::isJobInactive

(

string

$jobId

)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 259 of file JobManagerImpl.php.

                                                : bool
    {
        $jobs_data = $this->job_repository->getCronJobData($jobId);

        return $jobs_data !== [] && !((bool) $jobs_data[0]['job_status']);
    }

ping()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::ping

(

string

$jobId

)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 266 of file JobManagerImpl.php.

                                       : void
    {
        $this->db->manipulateF(
            'UPDATE cron_job SET alive_ts = %s WHERE job_id = %s',
            ['integer', 'text'],
            [$this->clock_factory->system()->now()->getTimestamp(), $jobId]
        );
    }

resetJob()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::resetJob	(	\ILIAS\Cron\CronJob	$job,
		\ilObjUser	$actor
	)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 221 of file JobManagerImpl.php.

References ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\activateJob(), ILIAS\BackgroundTasks\Task\Job\JobResult\CODE_MANUAL_RESET, and ILIAS\BackgroundTasks\Task\Job\JobResult\STATUS_RESET.

                                                                         : void
    {
        $result = new \ILIAS\Cron\Job\JobResult();
        $result->setStatus(\ILIAS\Cron\Job\JobResult::STATUS_RESET);
        $result->setCode(\ILIAS\Cron\Job\JobResult::CODE_MANUAL_RESET);
        $result->setMessage('Cron job re-activated by admin');

        $this->job_repository->updateJobResult(
            $job,
            $this->clock_factory->system()->now(),
            $actor,
            $result,
            true
        );
        $this->job_repository->resetJob($job);

        $this->activateJob($job, $actor, true);
    }

Here is the call graph for this function:

runActiveJobs()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::runActiveJobs

(

\ilObjUser

$actor

)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 42 of file JobManagerImpl.php.

References ilUtil\_getHttpPath(), ilSetting\_lookupValue(), ilDatePresentation\formatDate(), IL_CAL_UNIX, ILIAS\Repository\logger(), null, ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\runJob(), ILIAS\Repository\settings(), ilDatePresentation\setUseRelativeDates(), and ilDatePresentation\useRelativeDates().

                                                    : void
    {
        $this->logger->info('CRON - batch start');

        $ts = $this->clock_factory->system()->now()->getTimestamp();
        $this->settings->set('last_cronjob_start_ts', (string) $ts);

        $useRelativeDates = \ilDatePresentation::useRelativeDates();
        \ilDatePresentation::setUseRelativeDates(false);
        $this->logger->info(
            \sprintf(
                'Set last datetime to: %s',
                \ilDatePresentation::formatDate(new \ilDateTime($ts, IL_CAL_UNIX))
            )
        );
        $this->logger->info(
            \sprintf(
                'Verification of last run datetime (read from database): %s',
                \ilDatePresentation::formatDate(
                    new \ilDateTime(\ilSetting::_lookupValue('common', 'last_cronjob_start_ts'), IL_CAL_UNIX)
                )
            )
        );
        \ilDatePresentation::setUseRelativeDates($useRelativeDates);

        // ilLink::_getStaticLink() should work in crons
        if (!\defined('ILIAS_HTTP_PATH')) {
            \define('ILIAS_HTTP_PATH', \ilUtil::_getHttpPath());
        }

        // system
        foreach ($this->job_repository->getCronJobData(null, false) as $row) {
            $job = $this->job_repository->getJobInstanceById($row['job_id']);
            if ($job instanceof \ILIAS\Cron\CronJob) {
                // #18411 - we are NOT using the initial job data as it might be outdated at this point
                $this->runJob($job, $actor);
            }
        }

        // plugins
        foreach ($this->job_repository->getPluginJobs(true) as $item) {
            // #18411 - we are NOT using the initial job data as it might be outdated at this point
            $this->runJob($item[0], $actor);
        }

        $this->logger->info('CRON - batch end');
    }

Here is the call graph for this function:

runJob()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::runJob ( \ILIAS\Cron\CronJob  $job, \ilObjUser  $actor, ?array  $jobData = null, bool  $isManualExecution = false  )

private

Run single cron job (internal)

Parameters

null|array<string,mixed>

$jobData

Definition at line 117 of file JobManagerImpl.php.

References Vendor\Package\$e, ILIAS\BackgroundTasks\Task\Job\JobResult\CODE_SUPPOSED_CRASH, ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\deactivateJob(), ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\getMicrotime(), ILIAS\Repository\int(), ILIAS\Repository\logger(), null, ILIAS\BackgroundTasks\Task\Job\JobResult\STATUS_CRASHED, and ilStr\subStr().

Referenced by ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\runActiveJobs(), and ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\runJobManual().

     : bool {
        $did_run = false;

        if ($jobData === null) {
            // aquire "fresh" job (status) data
            $jobsData = $this->job_repository->getCronJobData($job->getId());
            $jobData = array_pop($jobsData);
        }

        $job->setDateTimeProvider(fn(): \DateTimeImmutable => $this->clock_factory->system()->now());

        // already running?
        if ($jobData['alive_ts']) {
            $this->logger->info('CRON - job ' . $jobData['job_id'] . ' still running');

            $cut = 60 * 60 * 3;

            // is running (and has not pinged) for 3 hours straight, we assume it crashed
            if ($this->clock_factory->system()->now()->getTimestamp() - ((int) $jobData['alive_ts']) > $cut) {
                $this->job_repository->updateRunInformation($jobData['job_id'], 0, 0);
                $this->deactivateJob($job, $actor); // #13082

                $result = new \ILIAS\Cron\Job\JobResult();
                $result->setStatus(\ILIAS\Cron\Job\JobResult::STATUS_CRASHED);
                $result->setCode(\ILIAS\Cron\Job\JobResult::CODE_SUPPOSED_CRASH);
                $result->setMessage('Cron job deactivated because it has been inactive for 3 hours');

                $this->job_repository->updateJobResult(
                    $job,
                    $this->clock_factory->system()->now(),
                    $actor,
                    $result,
                    $isManualExecution
                );

                $this->logger->info('CRON - job ' . $jobData['job_id'] . ' deactivated (assumed crash)');
            }
        } // initiate run?
        elseif ($job->isDue(
            $jobData['job_result_ts'] ? (new \DateTimeImmutable(
                '@' . $jobData['job_result_ts']
            ))->setTimezone($this->clock_factory->system()->now()->getTimezone()) : null,
            is_numeric($jobData['schedule_type']) ? JobScheduleType::tryFrom(
                (int) $jobData['schedule_type']
            ) : null,
            $jobData['schedule_value'] ? (int) $jobData['schedule_value'] : null,
            $isManualExecution
        )) {
            $this->logger->info('CRON - job ' . $jobData['job_id'] . ' started');

            $this->job_repository->updateRunInformation(
                $jobData['job_id'],
                $this->clock_factory->system()->now()->getTimestamp(),
                $this->clock_factory->system()->now()->getTimestamp()
            );

            $ts_in = $this->getMicrotime();
            try {
                $result = $job->run();
            } catch (\Throwable $e) {
                $result = new \ILIAS\Cron\Job\JobResult();
                $result->setStatus(\ILIAS\Cron\Job\JobResult::STATUS_CRASHED);
                $result->setMessage(
                    \ilStr::subStr(\sprintf('Exception: %s / %s', $e->getMessage(), $e->getTraceAsString()), 0, 400)
                );

                $this->logger->error($e->getMessage());
                $this->logger->error($e->getTraceAsString());
            } finally {
                $ts_dur = $this->getMicrotime() - $ts_in;
            }

            if ($result->getStatus() === \ILIAS\Cron\Job\JobResult::STATUS_INVALID_CONFIGURATION) {
                $this->deactivateJob($job, $actor);
                $this->logger->info('CRON - job ' . $jobData['job_id'] . ' invalid configuration');
            } else {
                // success!
                $did_run = true;
            }

            $result->setDuration($ts_dur);

            $this->job_repository->updateJobResult(
                $job,
                $this->clock_factory->system()->now(),
                $actor,
                $result,
                $isManualExecution
            );
            $this->job_repository->updateRunInformation($jobData['job_id'], 0, 0);

            $this->logger->info('CRON - job ' . $jobData['job_id'] . ' finished');
        } else {
            $this->logger->info('CRON - job ' . $jobData['job_id'] . ' returned status inactive');
        }

        return $did_run;
    }

Here is the call graph for this function:

Here is the caller graph for this function:

runJobManual()

ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl::runJobManual	(	string	$jobId,
		\ilObjUser	$actor
	)

Implements ILIAS\BackgroundTasks\Task\Job\JobManager.

Definition at line 90 of file JobManagerImpl.php.

References ILIAS\Repository\logger(), null, and ILIAS\BackgroundTasks\Task\Job\Manager\JobManagerImpl\runJob().

                                                                  : bool
    {
        $result = false;

        $this->logger->info('CRON - manual start (' . $jobId . ')');

        $job = $this->job_repository->getJobInstanceById($jobId);
        if ($job instanceof \ILIAS\Cron\CronJob) {
            if ($job->isManuallyExecutable()) {
                $result = $this->runJob($job, $actor, null, true);
            } else {
                $this->logger->info('CRON - job ' . $jobId . ' is not intended to be executed manually');
            }
        } else {
            $this->logger->info('CRON - job ' . $jobId . ' seems invalid or is inactive');
        }

        $this->logger->info('CRON - manual end (' . $jobId . ')');

        return $result;
    }

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• components/ILIAS/Cron/src/Job/Manager/JobManagerImpl.php