<?php

namespace Illuminate\Tests\Queue;

use Illuminate\Database\Connection;

use Illuminate\Queue\DatabaseQueue;

use Illuminate\Queue\Queue;

use Mockery as m;

use PHPUnit\Framework\TestCase;

use ReflectionClass;

use stdClass;

class QueueDatabaseQueueUnitTest extends TestCase

{

protected function tearDown(): void

{

m::close();

}

public function testPushProperlyPushesJobOntoDatabase()

{

$queue = $this->getMockBuilder(DatabaseQueue::class)->setMethods(['currentTime'])->setConstructorArgs([$database = m::mock(Connection::class), 'table', 'default'])->getMock();

$queue->expects($this->any())->method('currentTime')->willReturn('time');

$database->shouldReceive('table')->with('table')->andReturn($query = m::mock(stdClass::class));

$query->shouldReceive('insertGetId')->once()->andReturnUsing(function ($array) {

$this->assertSame('default', $array['queue']);

$this->assertEquals(json_encode(['displayName' => 'foo', 'job' => 'foo', 'maxTries' => null, 'delay' => null, 'timeout' => null, 'data' => ['data']]), $array['payload']);

$this->assertEquals(0, $array['attempts']);

$this->assertNull($array['reserved_at']);

$this->assertIsInt($array['available_at']);

});

$queue->push('foo', ['data']);

}

public function testDelayedPushProperlyPushesJobOntoDatabase()

{

$queue = $this->getMockBuilder(

DatabaseQueue::class)->setMethods(

['currentTime'])->setConstructorArgs(

[$database = m::mock(Connection::class), 'table', 'default']

)->getMock();

$queue->expects($this->any())->method('currentTime')->willReturn('time');

$database->shouldReceive('table')->with('table')->andReturn($query = m::mock(stdClass::class));

$query->shouldReceive('insertGetId')->once()->andReturnUsing(function ($array) {

$this->assertSame('default', $array['queue']);

$this->assertEquals(json_encode(['displayName' => 'foo', 'job' => 'foo', 'maxTries' => null, 'delay' => null, 'timeout' => null, 'data' => ['data']]), $array['payload']);

$this->assertEquals(0, $array['attempts']);

$this->assertNull($array['reserved_at']);

$this->assertIsInt($array['available_at']);

});

$queue->later(10, 'foo', ['data']);

}

public function testFailureToCreatePayloadFromObject()

{

$this->expectException('InvalidArgumentException');

$job = new stdClass;

$job->invalid = "\xc3\x28";

$queue = $this->getMockForAbstractClass(Queue::class);

$class = new ReflectionClass(Queue::class);

$createPayload = $class->getMethod('createPayload');

$createPayload->setAccessible(true);

$createPayload->invokeArgs($queue, [

$job,

'queue-name',

]);

}

public function testFailureToCreatePayloadFromArray()

{

$this->expectException('InvalidArgumentException');

$queue = $this->getMockForAbstractClass(Queue::class);

$class = new ReflectionClass(Queue::class);

$createPayload = $class->getMethod('createPayload');

$createPayload->setAccessible(true);

$createPayload->invokeArgs($queue, [

["\xc3\x28"],

'queue-name',

]);

}

public function testBulkBatchPushesOntoDatabase()

{

$database = m::mock(Connection::class);

$queue = $this->getMockBuilder(DatabaseQueue::class)->setMethods(['currentTime', 'availableAt'])->setConstructorArgs([$database, 'table', 'default'])->getMock();

$queue->expects($this->any())->method('currentTime')->willReturn('created');

$queue->expects($this->any())->method('availableAt')->willReturn('available');

$database->shouldReceive('table')->with('table')->andReturn($query = m::mock(stdClass::class));

$query->shouldReceive('insert')->once()->andReturnUsing(function ($records) {

$this->assertEquals([[

'queue' => 'queue',

'payload' => json_encode(['displayName' => 'foo', 'job' => 'foo', 'maxTries' => null, 'delay' => null, 'timeout' => null, 'data' => ['data']]),

'attempts' => 0,

'reserved_at' => null,

'available_at' => 'available',

'created_at' => 'created',

], [

'queue' => 'queue',

'payload' => json_encode(['displayName' => 'bar', 'job' => 'bar', 'maxTries' => null, 'delay' => null, 'timeout' => null, 'data' => ['data']]),

'attempts' => 0,

'reserved_at' => null,

'available_at' => 'available',

'created_at' => 'created',

]], $records);

});

$queue->bulk(['foo', 'bar'], ['data'], 'queue');

}

public function testBuildDatabaseRecordWithPayloadAtTheEnd()

{

$queue = m::mock(DatabaseQueue::class);

$record = $queue->buildDatabaseRecord('queue', 'any_payload', 0);

$this->assertArrayHasKey('payload', $record);

$this->assertArrayHasKey('payload', array_slice($record, -1, 1, true));

}

}