blax-software
/
laravel-websockets
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wip coverage & namings

This commit is contained in:
Alex Renoki 2020-09-26 10:59:49 +03:00
parent d0b4f46aec
commit 391c5f7799
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
tests/AsyncRedisQueueTest.php
View File

@ -2,7 +2,7 @@
namespace BeyondCode\LaravelWebSockets\Test; namespace BeyondCode\LaravelWebSockets\Test;
use BeyondCode\LaravelWebSockets\Queue\AsyncRedisQueue; use BeyondCode\LaravelWebSockets\Queue\AsyncRedisConnector;
use Illuminate\Queue\Queue; use Illuminate\Queue\Queue;
use Illuminate\Support\InteractsWithTime; use Illuminate\Support\InteractsWithTime;
use Mockery as m; use Mockery as m;
@ -27,9 +27,13 @@ class AsyncRedisQueueTest extends TestCase
$this->runOnlyOnRedisReplication(); $this->runOnlyOnRedisReplication();
$this->queue = new AsyncRedisQueue( $connector = new AsyncRedisConnector($this->app['redis'], 'default');
$this->app['redis'], 'default', null, 60, null
); $this->queue = $connector->connect([
'queue' => 'default',
'retry_after' => 60,
'block_for' => null,
]);
$this->queue->setContainer($this->app); $this->queue->setContainer($this->app);
} }
@ -44,7 +48,7 @@ class AsyncRedisQueueTest extends TestCase
m::close(); m::close();
} }
public function test_expired_jobs_are_popped() public function test_expired_jobs_are_pushed_with_async_and_popped_with_sync()
{ {
$jobs = [ $jobs = [
new RedisQueueIntegrationTestJob(0), new RedisQueueIntegrationTestJob(0),
@ -75,7 +79,7 @@ class AsyncRedisQueueTest extends TestCase
$this->assertEquals(3, $this->app['redis']->connection()->zcard('queues:default:reserved')); $this->assertEquals(3, $this->app['redis']->connection()->zcard('queues:default:reserved'));
} }
public function test_release_job() public function test_jobs_are_pushed_with_async_and_released_with_sync()
{ {
$this->queue->push( $this->queue->push(
$job = new RedisQueueIntegrationTestJob(30) $job = new RedisQueueIntegrationTestJob(30)
@ -114,7 +118,7 @@ class AsyncRedisQueueTest extends TestCase
$this->assertNull($this->queue->pop()); $this->assertNull($this->queue->pop());
} }
public function test_delete_job() public function test_jobs_are_pushed_with_async_and_deleted_with_sync()
{ {
$this->queue->push( $this->queue->push(
$job = new RedisQueueIntegrationTestJob(30) $job = new RedisQueueIntegrationTestJob(30)
@ -136,7 +140,7 @@ class AsyncRedisQueueTest extends TestCase
$this->assertNull($this->queue->pop()); $this->assertNull($this->queue->pop());
} }
public function test_clear_job() public function test_jobs_are_pushed_with_async_and_cleared_with_sync()
{ {
if (! method_exists($this->queue, 'clear')) { if (! method_exists($this->queue, 'clear')) {
$this->markTestSkipped('The Queue has no clear() method to test.'); $this->markTestSkipped('The Queue has no clear() method to test.');
@ -157,7 +161,7 @@ class AsyncRedisQueueTest extends TestCase
$this->assertEquals(0, $this->queue->size()); $this->assertEquals(0, $this->queue->size());
} }
public function test_size_job() public function test_jobs_are_pushed_with_async_and_size_reflects_in_async_size()
{ {
$this->queue->size()->then(function ($count) { $this->queue->size()->then(function ($count) {
$this->assertEquals(0, $count); $this->assertEquals(0, $count);