SyncTaskManager.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\BackgroundTasks\Implementation\TaskManager;
 
use ILIAS\BackgroundTasks\Bucket;
use ILIAS\BackgroundTasks\Implementation\Bucket\State;
use ILIAS\BackgroundTasks\Implementation\Tasks\UserInteraction\UserInteractionRequiredException;
use ILIAS\BackgroundTasks\Implementation\Tasks\UserInteraction\UserInteractionSkippedException;
use ILIAS\BackgroundTasks\Persistence;
use ILIAS\BackgroundTasks\Task\UserInteraction;
 
class SyncTaskManager extends BasicTaskManager
{
    protected Persistence $persistence;
 
    public function __construct(Persistence $persistence)
    {
        $this->persistence = $persistence;
    }
 
    public function run(Bucket $bucket): void
    {
        $task = $bucket->getTask();
        $bucket->setCurrentTask($task);
        $observer = new NonPersistingObserver($bucket);
 
        try {
            $task = $this->executeTask($task, $observer);
            if ($task instanceof UserInteraction && $task->canBeSkipped($task->getInput())) {
                throw new UserInteractionSkippedException('can be skipped');
            }
            $bucket->setState(State::FINISHED);
        } catch (UserInteractionSkippedException $e) {
            $bucket->setState(State::FINISHED);
        } catch (UserInteractionRequiredException $e) {
            // We're okay!
            $this->persistence->saveBucketAndItsTasks($bucket);
        }
    }
}