summaryrefslogtreecommitdiff
path: root/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php')
-rw-r--r--plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php90
1 files changed, 0 insertions, 90 deletions
diff --git a/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php b/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php
deleted file mode 100644
index c3306385..00000000
--- a/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php
+++ /dev/null
@@ -1,90 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests;
-
-use PHPUnit\Framework\TestCase;
-use Spiral\Core\Container;
-use Spiral\Jobs\Options;
-use Spiral\Jobs\Registry\ContainerRegistry;
-use Spiral\Jobs\ShortCircuit;
-use Spiral\Jobs\Tests\Local\ErrorJob;
-use Spiral\Jobs\Tests\Local\Job;
-
-class ShortCircuitTest extends TestCase
-{
- protected function tearDown(): void
- {
- if (file_exists(Job::JOB_FILE)) {
- unlink(Job::JOB_FILE);
- }
- }
-
- public function testLocal(): void
- {
- $c = new ContainerRegistry(new Container());
- $jobs = new ShortCircuit($c, $c);
-
- $id = $jobs->push(Job::class, ['data' => 100]);
-
- $this->assertNotEmpty($id);
-
- $this->assertFileExists(Job::JOB_FILE);
-
- $data = json_decode(file_get_contents(Job::JOB_FILE), true);
- $this->assertSame($id, $data['id']);
- $this->assertSame(100, $data['data']);
- }
-
- public function testLocalDelayed(): void
- {
- $c = new ContainerRegistry(new Container());
- $jobs = new ShortCircuit($c, $c);
-
- $t = microtime(true);
- $id = $jobs->push(Job::class, ['data' => 100], Options::delayed(1));
-
- $this->assertTrue(microtime(true) - $t >= 1);
-
- $this->assertNotEmpty($id);
-
- $this->assertFileExists(Job::JOB_FILE);
-
- $data = json_decode(file_get_contents(Job::JOB_FILE), true);
- $this->assertSame($id, $data['id']);
- $this->assertSame(100, $data['data']);
- }
-
- /**
- * @expectedException \Spiral\Jobs\Exception\JobException
- */
- public function testError(): void
- {
- $c = new ContainerRegistry(new Container());
- $jobs = new ShortCircuit($c, $c);
- $jobs->push(ErrorJob::class);
- }
-
- public function testLocalDelay(): void
- {
- $c = new ContainerRegistry(new Container());
- $jobs = new ShortCircuit($c, $c);
-
- $id = $jobs->push(Job::class, ['data' => 100], Options::delayed(1));
- $this->assertNotEmpty($id);
-
- $this->assertFileExists(Job::JOB_FILE);
-
- $data = json_decode(file_get_contents(Job::JOB_FILE), true);
- $this->assertSame($id, $data['id']);
- $this->assertSame(100, $data['data']);
- }
-}