PersistingObserver.php

Go to the documentation of this file.

<?php

namespace ILIAS\BackgroundTasks\Implementation\TaskManager;

use ILIAS\BackgroundTasks\Bucket;
use ILIAS\BackgroundTasks\Observer;
use ILIAS\BackgroundTasks\Persistence;
use ILIAS\BackgroundTasks\Task;

class PersistingObserver implements Observer
{
    protected \ILIAS\BackgroundTasks\Bucket $bucket;
    protected \ILIAS\BackgroundTasks\Persistence $persistence;

    public function __construct(Bucket $bucket, Persistence $persistence)
    {
        $this->bucket = $bucket;
        $this->persistence = $persistence;
    }

    public function notifyState(int $state): void
    {
        $this->bucket->setState($state);
        $this->bucket->heartbeat();
        $this->persistence->updateBucket($this->bucket);
    }

    public function notifyPercentage(Task $task, int $percentage): void
    {
        $this->bucket->setPercentage($task, $percentage);
        $this->bucket->heartbeat();
        $this->persistence->updateBucket($this->bucket);
    }

    public function notifyCurrentTask(Task $task): void
    {
        $this->bucket->setCurrentTask($task);
        $this->bucket->heartbeat();
        $this->persistence->updateBucket($this->bucket);
    }

    public function heartbeat(): void
    {
        $this->bucket->heartbeat();
        $this->persistence->updateBucket($this->bucket);
    }
}