diff --git a/tests/RedisQueueTest.php b/tests/AsyncRedisQueueTest.php similarity index 99% rename from tests/RedisQueueTest.php rename to tests/AsyncRedisQueueTest.php index 69ed2dd..fea9631 100644 --- a/tests/RedisQueueTest.php +++ b/tests/AsyncRedisQueueTest.php @@ -13,7 +13,7 @@ use Illuminate\Support\Str; use Mockery as m; use stdClass; -class RedisQueueTest extends TestCase +class AsyncRedisQueueTest extends TestCase { use InteractsWithTime; diff --git a/tests/LocalQueueTest.php b/tests/LocalQueueTest.php deleted file mode 100644 index 1b1fa19..0000000 --- a/tests/LocalQueueTest.php +++ /dev/null @@ -1,262 +0,0 @@ -runOnlyOnLocalReplication(); - } - - /** - * {@inheritdoc} - */ - protected function tearDown(): void - { - m::close(); - } - - public function testPushProperlyPushesJobOntoRedis() - { - $uuid = Str::uuid(); - - Str::createUuidsUsing(function () use ($uuid) { - return $uuid; - }); - - $queue = $this->getMockBuilder(RedisQueue::class) - ->setMethods(['getRandomId']) - ->setConstructorArgs([$redis = m::mock(Factory::class), 'default']) - ->getMock(); - - $queue->expects($this->once()) - ->method('getRandomId') - ->willReturn('foo'); - - $redis->shouldReceive('connection') - ->once() - ->andReturn($redis); - - $redis->shouldReceive('eval')->once(); - - $id = $queue->push('foo', ['data']); - - $this->assertSame('foo', $id); - - Str::createUuidsNormally(); - } - - public function testPushProperlyPushesJobOntoRedisWithCustomPayloadHook() - { - $uuid = Str::uuid(); - - Str::createUuidsUsing(function () use ($uuid) { - return $uuid; - }); - - $queue = $this->getMockBuilder(RedisQueue::class) - ->setMethods(['getRandomId']) - ->setConstructorArgs([$redis = m::mock(Factory::class), 'default']) - ->getMock(); - - $queue->expects($this->once()) - ->method('getRandomId') - ->willReturn('foo'); - - $redis->shouldReceive('connection') - ->once() - ->andReturn($redis); - - $redis->shouldReceive('eval')->once(); - - Queue::createPayloadUsing(function ($connection, $queue, $payload) { - return ['custom' => 'taylor']; - }); - - $id = $queue->push('foo', ['data']); - - $this->assertSame('foo', $id); - - Queue::createPayloadUsing(null); - - Str::createUuidsNormally(); - } - - public function testPushProperlyPushesJobOntoRedisWithTwoCustomPayloadHook() - { - $uuid = Str::uuid(); - - Str::createUuidsUsing(function () use ($uuid) { - return $uuid; - }); - - $queue = $this->getMockBuilder(RedisQueue::class) - ->setMethods(['getRandomId']) - ->setConstructorArgs([$redis = m::mock(Factory::class), 'default']) - ->getMock(); - - $queue->expects($this->once()) - ->method('getRandomId') - ->willReturn('foo'); - - $redis->shouldReceive('connection') - ->once() - ->andReturn($redis); - - $redis->shouldReceive('eval')->once(); - - Queue::createPayloadUsing(function ($connection, $queue, $payload) { - return ['custom' => 'taylor']; - }); - - Queue::createPayloadUsing(function ($connection, $queue, $payload) { - return ['bar' => 'foo']; - }); - - $id = $queue->push('foo', ['data']); - - $this->assertSame('foo', $id); - - Queue::createPayloadUsing(null); - - Str::createUuidsNormally(); - } - - public function testDelayedPushProperlyPushesJobOntoRedis() - { - $uuid = Str::uuid(); - - Str::createUuidsUsing(function () use ($uuid) { - return $uuid; - }); - - $queue = $this->getMockBuilder(RedisQueue::class) - ->setMethods(['availableAt', 'getRandomId']) - ->setConstructorArgs([$redis = m::mock(Factory::class), 'default']) - ->getMock(); - - $queue->expects($this->once()) - ->method('getRandomId') - ->willReturn('foo'); - - $queue->expects($this->once()) - ->method('availableAt') - ->with(1) - ->willReturn(2); - - $redis->shouldReceive('connection') - ->once() - ->andReturn($redis); - - $redis->shouldReceive('zadd')->once(); - - $id = $queue->later(1, 'foo', ['data']); - - $this->assertSame('foo', $id); - - Str::createUuidsNormally(); - } - - public function testDelayedPushWithDateTimeProperlyPushesJobOntoRedis() - { - $uuid = Str::uuid(); - - Str::createUuidsUsing(function () use ($uuid) { - return $uuid; - }); - - $date = Carbon::now(); - - $queue = $this->getMockBuilder(RedisQueue::class) - ->setMethods(['availableAt', 'getRandomId']) - ->setConstructorArgs([$redis = m::mock(Factory::class), 'default']) - ->getMock(); - - $queue->expects($this->once()) - ->method('getRandomId') - ->willReturn('foo'); - - $queue->expects($this->once()) - ->method('availableAt') - ->with($date) - ->willReturn(2); - - $redis->shouldReceive('connection') - ->once() - ->andReturn($redis); - - $redis->shouldReceive('zadd')->once(); - - $queue->later($date, 'foo', ['data']); - - Str::createUuidsNormally(); - } - - public function testFireProperlyCallsTheJobHandler() - { - $job = $this->getJob(); - - $job->getContainer() - ->shouldReceive('make') - ->once()->with('foo') - ->andReturn($handler = m::mock(stdClass::class)); - - $handler->shouldReceive('fire') - ->once() - ->with($job, ['data']); - - $job->fire(); - } - - public function testDeleteRemovesTheJobFromRedis() - { - $job = $this->getJob(); - - $job->getRedisQueue() - ->shouldReceive('deleteReserved') - ->once() - ->with('default', $job); - - $job->delete(); - } - - public function testReleaseProperlyReleasesJobOntoRedis() - { - $job = $this->getJob(); - - $job->getRedisQueue() - ->shouldReceive('deleteAndRelease') - ->once() - ->with('default', $job, 1); - - $job->release(1); - } - - protected function getJob() - { - return new RedisJob( - m::mock(Container::class), - m::mock(RedisQueue::class), - json_encode(['job' => 'foo', 'data' => ['data'], 'attempts' => 1]), - json_encode(['job' => 'foo', 'data' => ['data'], 'attempts' => 2]), - 'connection-name', - 'default' - ); - } -}