1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
<?php
namespace Illuminate\Tests\Queue;
use Aws\Sqs\SqsClient;
use Illuminate\Container\Container;
use Illuminate\Queue\Jobs\SqsJob;
use Illuminate\Queue\SqsQueue;
use Mockery as m;
use PHPUnit\Framework\TestCase;
use stdClass;
class QueueSqsJobTest extends TestCase
{
protected function setUp(): void
{
$this->key = 'AMAZONSQSKEY';
$this->secret = 'AmAz0n+SqSsEcReT+aLpHaNuM3R1CsTr1nG';
$this->service = 'sqs';
$this->region = 'someregion';
$this->account = '1234567891011';
$this->queueName = 'emails';
$this->baseUrl = 'https://sqs.someregion.amazonaws.com';
$this->releaseDelay = 0;
// This is how the modified getQueue builds the queueUrl
$this->queueUrl = $this->baseUrl.'/'.$this->account.'/'.$this->queueName;
// Get a mock of the SqsClient
$this->mockedSqsClient = $this->getMockBuilder(SqsClient::class)
->setMethods(['deleteMessage'])
->disableOriginalConstructor()
->getMock();
// Use Mockery to mock the IoC Container
$this->mockedContainer = m::mock(Container::class);
$this->mockedJob = 'foo';
$this->mockedData = ['data'];
$this->mockedPayload = json_encode(['job' => $this->mockedJob, 'data' => $this->mockedData, 'attempts' => 1]);
$this->mockedMessageId = 'e3cd03ee-59a3-4ad8-b0aa-ee2e3808ac81';
$this->mockedReceiptHandle = '0NNAq8PwvXuWv5gMtS9DJ8qEdyiUwbAjpp45w2m6M4SJ1Y+PxCh7R930NRB8ylSacEmoSnW18bgd4nK\/O6ctE+VFVul4eD23mA07vVoSnPI4F\/voI1eNCp6Iax0ktGmhlNVzBwaZHEr91BRtqTRM3QKd2ASF8u+IQaSwyl\/DGK+P1+dqUOodvOVtExJwdyDLy1glZVgm85Yw9Jf5yZEEErqRwzYz\/qSigdvW4sm2l7e4phRol\/+IjMtovOyH\/ukueYdlVbQ4OshQLENhUKe7RNN5i6bE\/e5x9bnPhfj2gbM';
$this->mockedJobData = [
'Body' => $this->mockedPayload,
'MD5OfBody' => md5($this->mockedPayload),
'ReceiptHandle' => $this->mockedReceiptHandle,
'MessageId' => $this->mockedMessageId,
'Attributes' => ['ApproximateReceiveCount' => 1],
];
}
protected function tearDown(): void
{
m::close();
}
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 testDeleteRemovesTheJobFromSqs()
{
$this->mockedSqsClient = $this->getMockBuilder(SqsClient::class)
->setMethods(['deleteMessage'])
->disableOriginalConstructor()
->getMock();
$queue = $this->getMockBuilder(SqsQueue::class)->setMethods(['getQueue'])->setConstructorArgs([$this->mockedSqsClient, $this->queueName, $this->account])->getMock();
$queue->setContainer($this->mockedContainer);
$job = $this->getJob();
$job->getSqs()->expects($this->once())->method('deleteMessage')->with(['QueueUrl' => $this->queueUrl, 'ReceiptHandle' => $this->mockedReceiptHandle]);
$job->delete();
}
public function testReleaseProperlyReleasesTheJobOntoSqs()
{
$this->mockedSqsClient = $this->getMockBuilder(SqsClient::class)
->setMethods(['changeMessageVisibility'])
->disableOriginalConstructor()
->getMock();
$queue = $this->getMockBuilder(SqsQueue::class)->setMethods(['getQueue'])->setConstructorArgs([$this->mockedSqsClient, $this->queueName, $this->account])->getMock();
$queue->setContainer($this->mockedContainer);
$job = $this->getJob();
$job->getSqs()->expects($this->once())->method('changeMessageVisibility')->with(['QueueUrl' => $this->queueUrl, 'ReceiptHandle' => $this->mockedReceiptHandle, 'VisibilityTimeout' => $this->releaseDelay]);
$job->release($this->releaseDelay);
$this->assertTrue($job->isReleased());
}
protected function getJob()
{
return new SqsJob(
$this->mockedContainer,
$this->mockedSqsClient,
$this->mockedJobData,
'connection-name',
$this->queueUrl
);
}
}
|
