mirror of
https://github.com/nextcloud/server.git
synced 2025-01-30 22:37:01 +00:00
89 lines
2.7 KiB
PHP
89 lines
2.7 KiB
PHP
<?php
|
|
|
|
/**
|
|
* SPDX-FileCopyrightText: 2024 Nextcloud GmbH and Nextcloud contributors
|
|
* SPDX-License-Identifier: AGPL-3.0-or-later
|
|
*/
|
|
namespace OC\TaskProcessing;
|
|
|
|
use OCP\AppFramework\Utility\ITimeFactory;
|
|
use OCP\BackgroundJob\IJobList;
|
|
use OCP\BackgroundJob\QueuedJob;
|
|
use OCP\TaskProcessing\Exception\Exception;
|
|
use OCP\TaskProcessing\Exception\NotFoundException;
|
|
use OCP\TaskProcessing\IManager;
|
|
use OCP\TaskProcessing\ISynchronousProvider;
|
|
use OCP\TaskProcessing\Task;
|
|
use Psr\Log\LoggerInterface;
|
|
|
|
class SynchronousBackgroundJob extends QueuedJob {
|
|
public function __construct(
|
|
ITimeFactory $timeFactory,
|
|
private readonly IManager $taskProcessingManager,
|
|
private readonly IJobList $jobList,
|
|
private readonly LoggerInterface $logger,
|
|
) {
|
|
parent::__construct($timeFactory);
|
|
}
|
|
|
|
|
|
/**
|
|
* @inheritDoc
|
|
*/
|
|
protected function run($argument) {
|
|
$providers = $this->taskProcessingManager->getProviders();
|
|
|
|
foreach ($providers as $provider) {
|
|
if (!$provider instanceof ISynchronousProvider) {
|
|
continue;
|
|
}
|
|
$taskTypeId = $provider->getTaskTypeId();
|
|
// only use this provider if it is the preferred one
|
|
$preferredProvider = $this->taskProcessingManager->getPreferredProvider($taskTypeId);
|
|
if ($provider->getId() !== $preferredProvider->getId()) {
|
|
continue;
|
|
}
|
|
try {
|
|
$task = $this->taskProcessingManager->getNextScheduledTask([$taskTypeId]);
|
|
} catch (NotFoundException $e) {
|
|
continue;
|
|
} catch (Exception $e) {
|
|
$this->logger->error('Unknown error while retrieving scheduled TaskProcessing tasks', ['exception' => $e]);
|
|
continue;
|
|
}
|
|
if (!$this->taskProcessingManager->processTask($task, $provider)) {
|
|
// Schedule again
|
|
$this->jobList->add(self::class, $argument);
|
|
}
|
|
}
|
|
|
|
// check if this job needs to be scheduled again:
|
|
// if there is at least one preferred synchronous provider that has a scheduled task
|
|
$synchronousProviders = array_filter($providers, fn ($provider) =>
|
|
$provider instanceof ISynchronousProvider);
|
|
$synchronousPreferredProviders = array_filter($synchronousProviders, function ($provider) {
|
|
$taskTypeId = $provider->getTaskTypeId();
|
|
$preferredProvider = $this->taskProcessingManager->getPreferredProvider($taskTypeId);
|
|
return $provider->getId() === $preferredProvider->getId();
|
|
});
|
|
$taskTypes = array_values(
|
|
array_map(
|
|
fn ($provider) => $provider->getTaskTypeId(),
|
|
$synchronousPreferredProviders
|
|
)
|
|
);
|
|
$taskTypesWithTasks = array_filter($taskTypes, function ($taskType) {
|
|
try {
|
|
$this->taskProcessingManager->getNextScheduledTask([$taskType]);
|
|
return true;
|
|
} catch (NotFoundException|Exception $e) {
|
|
return false;
|
|
}
|
|
});
|
|
|
|
if (count($taskTypesWithTasks) > 0) {
|
|
// Schedule again
|
|
$this->jobList->add(self::class, $argument);
|
|
}
|
|
}
|
|
}
|