summaryrefslogtreecommitdiff
path: root/plugins/jobs/oooold/tests/Jobs
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/oooold/tests/Jobs')
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Amqp/BrokerTest.php20
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Amqp/ErrorJob.php22
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Amqp/Job.php26
-rw-r--r--plugins/jobs/oooold/tests/Jobs/BaseTest.php115
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Beanstalk/BrokerTest.php20
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Beanstalk/ErrorJob.php22
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Beanstalk/Job.php26
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Local/BrokerTest.php20
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Local/ErrorJob.php22
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Local/Job.php26
-rw-r--r--plugins/jobs/oooold/tests/Jobs/OptionsTest.php34
-rw-r--r--plugins/jobs/oooold/tests/Jobs/RegistryTest.php43
-rw-r--r--plugins/jobs/oooold/tests/Jobs/ShortCircuitTest.php90
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Sqs/BrokerTest.php20
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Sqs/ErrorJob.php22
-rw-r--r--plugins/jobs/oooold/tests/Jobs/Sqs/Job.php26
16 files changed, 0 insertions, 554 deletions
diff --git a/plugins/jobs/oooold/tests/Jobs/Amqp/BrokerTest.php b/plugins/jobs/oooold/tests/Jobs/Amqp/BrokerTest.php
deleted file mode 100644
index 637c14d6..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Amqp/BrokerTest.php
+++ /dev/null
@@ -1,20 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Amqp;
-
-use Spiral\Jobs\Tests\BaseTest;
-
-class BrokerTest extends BaseTest
-{
- public const JOB = Job::class;
- public const ERROR_JOB = ErrorJob::class;
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Amqp/ErrorJob.php b/plugins/jobs/oooold/tests/Jobs/Amqp/ErrorJob.php
deleted file mode 100644
index 82b6e7e0..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Amqp/ErrorJob.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Amqp;
-
-use Spiral\Jobs\JobHandler;
-
-class ErrorJob extends JobHandler
-{
- public function invoke(string $id): void
- {
- throw new \Error('something is wrong');
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Amqp/Job.php b/plugins/jobs/oooold/tests/Jobs/Amqp/Job.php
deleted file mode 100644
index 2c6ad819..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Amqp/Job.php
+++ /dev/null
@@ -1,26 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Amqp;
-
-use Spiral\Jobs\JobHandler;
-
-class Job extends JobHandler
-{
- public const JOB_FILE = __DIR__ . '/../../local.job';
-
- public function invoke(string $id, array $payload): void
- {
- file_put_contents(self::JOB_FILE, json_encode(
- $payload + compact('id')
- ));
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/BaseTest.php b/plugins/jobs/oooold/tests/Jobs/BaseTest.php
deleted file mode 100644
index 67f280b5..00000000
--- a/plugins/jobs/oooold/tests/Jobs/BaseTest.php
+++ /dev/null
@@ -1,115 +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\Goridge\RPC;
-use Spiral\Goridge\SocketRelay;
-use Spiral\Jobs\Options;
-use Spiral\Jobs\Queue;
-use Spiral\Jobs\Registry\ContainerRegistry;
-
-abstract class BaseTest extends TestCase
-{
- public const JOB = null;
- public const ERROR_JOB = null;
-
- private $job;
- private $errorJob;
-
- public function setUp(): void
- {
- $this->job = static::JOB;
- $this->errorJob = static::ERROR_JOB;
- }
-
- protected function tearDown(): void
- {
- if (file_exists((static::JOB)::JOB_FILE)) {
- unlink((static::JOB)::JOB_FILE);
- }
- }
-
- public function testJob(): void
- {
- $jobs = $this->makeJobs();
-
- $id = $jobs->push($this->job, ['data' => 100]);
-
- $this->assertNotEmpty($id);
-
- $this->waitForJob();
- $this->assertFileExists($this->job::JOB_FILE);
-
- $data = json_decode(file_get_contents($this->job::JOB_FILE), true);
- $this->assertSame($id, $data['id']);
- $this->assertSame(100, $data['data']);
- }
-
- public function testErrorJob(): void
- {
- $jobs = $this->makeJobs();
-
- $id = $jobs->push($this->errorJob, ['data' => 100]);
- $this->assertNotEmpty($id);
- }
-
- public function testDelayJob(): void
- {
- $jobs = $this->makeJobs();
-
- $id = $jobs->push($this->job, ['data' => 100], Options::delayed(1));
-
- $this->assertNotEmpty($id);
-
- $this->assertTrue($this->waitForJob() > 1);
- $this->assertFileExists($this->job::JOB_FILE);
-
- $data = json_decode(file_get_contents($this->job::JOB_FILE), true);
- $this->assertSame($id, $data['id']);
- $this->assertSame(100, $data['data']);
- }
-
- /**
- * @expectedException \Spiral\Jobs\Exception\JobException
- */
- public function testConnectionException(): void
- {
- $jobs = new Queue(
- new RPC(new SocketRelay('localhost', 6002)),
- new ContainerRegistry(new Container())
- );
-
- $jobs->push($this->job, ['data' => 100]);
- }
-
- public function makeJobs(): Queue
- {
- return new Queue(
- new RPC(new SocketRelay('localhost', 6001)),
- new ContainerRegistry(new Container())
- );
- }
-
- private function waitForJob(): float
- {
- $start = microtime(true);
- $try = 0;
- while (!file_exists($this->job::JOB_FILE) && $try < 10) {
- usleep(250000);
- $try++;
- }
-
- return microtime(true) - $start;
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Beanstalk/BrokerTest.php b/plugins/jobs/oooold/tests/Jobs/Beanstalk/BrokerTest.php
deleted file mode 100644
index d1ea4682..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Beanstalk/BrokerTest.php
+++ /dev/null
@@ -1,20 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Beanstalk;
-
-use Spiral\Jobs\Tests\BaseTest;
-
-class BrokerTest extends BaseTest
-{
- public const JOB = Job::class;
- public const ERROR_JOB = ErrorJob::class;
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Beanstalk/ErrorJob.php b/plugins/jobs/oooold/tests/Jobs/Beanstalk/ErrorJob.php
deleted file mode 100644
index c4349871..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Beanstalk/ErrorJob.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Beanstalk;
-
-use Spiral\Jobs\JobHandler;
-
-class ErrorJob extends JobHandler
-{
- public function invoke(string $id): void
- {
- throw new \Error('something is wrong');
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Beanstalk/Job.php b/plugins/jobs/oooold/tests/Jobs/Beanstalk/Job.php
deleted file mode 100644
index f8bd541a..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Beanstalk/Job.php
+++ /dev/null
@@ -1,26 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Beanstalk;
-
-use Spiral\Jobs\JobHandler;
-
-class Job extends JobHandler
-{
- public const JOB_FILE = __DIR__ . '/../../local.job';
-
- public function invoke(string $id, array $payload): void
- {
- file_put_contents(self::JOB_FILE, json_encode(
- $payload + compact('id')
- ));
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Local/BrokerTest.php b/plugins/jobs/oooold/tests/Jobs/Local/BrokerTest.php
deleted file mode 100644
index 9ba83de6..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Local/BrokerTest.php
+++ /dev/null
@@ -1,20 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Local;
-
-use Spiral\Jobs\Tests\BaseTest;
-
-class BrokerTest extends BaseTest
-{
- public const JOB = Job::class;
- public const ERROR_JOB = ErrorJob::class;
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Local/ErrorJob.php b/plugins/jobs/oooold/tests/Jobs/Local/ErrorJob.php
deleted file mode 100644
index 70b1365b..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Local/ErrorJob.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Local;
-
-use Spiral\Jobs\JobHandler;
-
-class ErrorJob extends JobHandler
-{
- public function invoke(string $id): void
- {
- throw new \Error('something is wrong');
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Local/Job.php b/plugins/jobs/oooold/tests/Jobs/Local/Job.php
deleted file mode 100644
index 2f5803c8..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Local/Job.php
+++ /dev/null
@@ -1,26 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Local;
-
-use Spiral\Jobs\JobHandler;
-
-class Job extends JobHandler
-{
- public const JOB_FILE = __DIR__ . '/../../local.job';
-
- public function invoke(string $id, array $payload): void
- {
- file_put_contents(self::JOB_FILE, json_encode(
- $payload + compact('id')
- ));
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/OptionsTest.php b/plugins/jobs/oooold/tests/Jobs/OptionsTest.php
deleted file mode 100644
index 5d00794e..00000000
--- a/plugins/jobs/oooold/tests/Jobs/OptionsTest.php
+++ /dev/null
@@ -1,34 +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\Jobs\Options;
-
-class OptionsTest extends TestCase
-{
- public function testDelay(): void
- {
- $o = new Options();
- $this->assertNull($o->getDelay());
- $o = $o->withDelay(10);
- $this->assertSame(10, $o->getDelay());
- }
-
- public function testPipeline(): void
- {
- $o = new Options();
- $this->assertNull($o->getPipeline());
- $o = $o->withPipeline('custom');
- $this->assertSame('custom', $o->getPipeline());
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/RegistryTest.php b/plugins/jobs/oooold/tests/Jobs/RegistryTest.php
deleted file mode 100644
index 7abd75f7..00000000
--- a/plugins/jobs/oooold/tests/Jobs/RegistryTest.php
+++ /dev/null
@@ -1,43 +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\Registry\ContainerRegistry;
-use Spiral\Jobs\Tests\Local\Job;
-
-class RegistryTest extends TestCase
-{
- public function testMakeJob(): void
- {
- $factory = new ContainerRegistry(new Container());
-
- $j = $factory->getHandler('spiral.jobs.tests.local.job');
- $this->assertInstanceOf(Job::class, $j);
-
- $this->assertSame(json_encode(['data' => 200]), $j->serialize(
- 'spiral.jobs.tests.local.job',
- ['data' => 200]
- ));
- }
-
- /**
- * @expectedException \Spiral\Jobs\Exception\JobException
- */
- public function testMakeUndefined(): void
- {
- $factory = new ContainerRegistry(new Container());
-
- $factory->getHandler('spiral.jobs.undefined');
- }
-}
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']);
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Sqs/BrokerTest.php b/plugins/jobs/oooold/tests/Jobs/Sqs/BrokerTest.php
deleted file mode 100644
index ccaa96de..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Sqs/BrokerTest.php
+++ /dev/null
@@ -1,20 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Sqs;
-
-use Spiral\Jobs\Tests\BaseTest;
-
-class BrokerTest extends BaseTest
-{
- public const JOB = Job::class;
- public const ERROR_JOB = ErrorJob::class;
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Sqs/ErrorJob.php b/plugins/jobs/oooold/tests/Jobs/Sqs/ErrorJob.php
deleted file mode 100644
index 738b9f2b..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Sqs/ErrorJob.php
+++ /dev/null
@@ -1,22 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Sqs;
-
-use Spiral\Jobs\JobHandler;
-
-class ErrorJob extends JobHandler
-{
- public function invoke(string $id): void
- {
- throw new \Error('something is wrong');
- }
-}
diff --git a/plugins/jobs/oooold/tests/Jobs/Sqs/Job.php b/plugins/jobs/oooold/tests/Jobs/Sqs/Job.php
deleted file mode 100644
index e22483a8..00000000
--- a/plugins/jobs/oooold/tests/Jobs/Sqs/Job.php
+++ /dev/null
@@ -1,26 +0,0 @@
-<?php
-
-/**
- * Spiral Framework.
- *
- * @license MIT
- * @author Anton Titov (Wolfy-J)
- */
-
-declare(strict_types=1);
-
-namespace Spiral\Jobs\Tests\Sqs;
-
-use Spiral\Jobs\JobHandler;
-
-class Job extends JobHandler
-{
- public const JOB_FILE = __DIR__ . '/../../local.job';
-
- public function invoke(string $id, array $payload): void
- {
- file_put_contents(self::JOB_FILE, json_encode(
- $payload + compact('id')
- ));
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2025-02-01 23:49:31 +0000