* This file is licensed under the Affero General Public License version 3 or * later. * See the COPYING-README file. */ namespace Test\BackgroundJob; use OCP\BackgroundJob\IJob; /** * Class DummyJobList * * in memory job list for testing purposes */ class DummyJobList extends \OC\BackgroundJob\JobList { /** * @var IJob[] */ private array $jobs = []; private int $last = 0; public function __construct() { } /** * @param IJob|class-string $job * @param mixed $argument */ public function add($job, $argument = null): void { if (is_string($job)) { /** @var IJob $job */ $job = \OCP\Server::get($job); } $job->setArgument($argument); if (!$this->has($job, null)) { $this->jobs[] = $job; } } /** * @param IJob|string $job * @param mixed $argument */ public function remove($job, $argument = null): void { $index = array_search($job, $this->jobs); if ($index !== false) { unset($this->jobs[$index]); } } /** * check if a job is in the list * * @param $job * @param mixed $argument * @return bool */ public function has($job, $argument): bool { return array_search($job, $this->jobs) !== false; } /** * get all jobs in the list * * @return IJob[] */ public function getAll(): array { return $this->jobs; } public function getJobs($job, ?int $limit, int $offset): array { if ($job instanceof IJob) { $jobClass = get_class($job); } else { $jobClass = $job; } return array_slice( array_filter( $this->jobs, fn ($job) => ($jobClass === null) || (get_class($job) == $jobClass) ), $offset, $limit ); } /** * get the next job in the list */ public function getNext(bool $onlyTimeSensitive = false): ?IJob { if (count($this->jobs) > 0) { if ($this->last < (count($this->jobs) - 1)) { $i = $this->last + 1; } else { $i = 0; } return $this->jobs[$i]; } else { return null; } } /** * set the job that was last ran * * @param \OC\BackgroundJob\Job $job */ public function setLastJob(IJob $job): void { $i = array_search($job, $this->jobs); if ($i !== false) { $this->last = $i; } else { $this->last = 0; } } public function getById(int $id): IJob { foreach ($this->jobs as $job) { if ($job->getId() === $id) { return $job; } } return null; } public function getDetailsById(int $id): ?array { return null; } public function setLastRun(IJob $job): void { $job->setLastRun(time()); } public function setExecutionTime(IJob $job, $timeTaken): void { } public function resetBackgroundJob(IJob $job): void { } }