1 files changed, 90 insertions, 0 deletions
diff --git a/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php b/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php
new file mode 100644
index 00000000..c3306385
--- /dev/null
+++ b/plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php
@@ -0,0 +1,90 @@
+<?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']);
+    }
+}