App\Queue\Cleanup\Task::run()

Complexity

Conditions	2
Paths	2

Size

Total Lines

24

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function run($request): void // phpcs:ignore SlevomatCodingStandard.TypeHints
    {
        if (QueuedJobService::singleton()->isMaintenanceLockActive()) {
            return;
        }

        $table = QueuedJobDescriptor::config()->get('table_name');

        // determine expiry
        $expired = DBDatetime::now()->modify(sprintf('-%s hours', self::EXPIRY_HOURS))->Rfc2822();

        // Format query
        $query = sprintf(
            "DELETE FROM `%s` WHERE `JobStatus` = '%s' AND (`JobFinished` <= '%s' OR `JobFinished` IS NULL) LIMIT %d",
            $table,
            QueuedJob::STATUS_COMPLETE,
            $expired,
            self::EXPIRY_LIMIT
        );

        DB::query($query);

        echo sprintf('%d job descriptors deleted.', (int) DB::affected_rows());
    }
}