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);
        }
    }
}