123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173 |
- <?php
- namespace Test\BackgroundJob;
- use OCP\BackgroundJob\IJob;
- class DummyJobList extends \OC\BackgroundJob\JobList {
-
- private array $jobs = [];
-
- private array $reserved = [];
- private int $last = 0;
- private int $lastId = 0;
- public function __construct() {
- }
-
- public function add($job, $argument = null, ?int $firstCheck = null): void {
- if (is_string($job)) {
-
- $job = \OCP\Server::get($job);
- }
- $job->setArgument($argument);
- $job->setId($this->lastId);
- $this->lastId++;
- if (!$this->has($job, null)) {
- $this->jobs[] = $job;
- }
- }
- public function scheduleAfter(string $job, int $runAfter, $argument = null): void {
- $this->add($job, $argument, $runAfter);
- }
-
- public function remove($job, $argument = null): void {
- foreach ($this->jobs as $index => $listJob) {
- if (get_class($job) === get_class($listJob) && $job->getArgument() == $listJob->getArgument()) {
- unset($this->jobs[$index]);
- return;
- }
- }
- }
- public function removeById(int $id): void {
- foreach ($this->jobs as $index => $listJob) {
- if ($listJob->getId() === $id) {
- unset($this->jobs[$index]);
- return;
- }
- }
- }
-
- public function has($job, $argument): bool {
- return array_search($job, $this->jobs) !== false;
- }
-
- public function getAll(): array {
- return $this->jobs;
- }
- public function getJobsIterator($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
- );
- }
-
- public function getNext(bool $onlyTimeSensitive = false, ?array $jobClasses = null): ?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;
- }
- }
-
- 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 hasReservedJob(?string $className = null): bool {
- return isset($this->reserved[$className ?? '']) && $this->reserved[$className ?? ''];
- }
- public function setHasReservedJob(?string $className, bool $hasReserved): void {
- $this->reserved[$className ?? ''] = $hasReserved;
- }
- public function setExecutionTime(IJob $job, $timeTaken): void {
- }
- public function resetBackgroundJob(IJob $job): void {
- }
- }
|