<?php

use Mockery as m;

use Aws\Sqs\SqsClient;

class QueueSqsJobTest extends PHPUnit_Framework_TestCase

{

public function setUp()

{

$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('Aws\Sqs\SqsClient')

->setMethods(['deleteMessage'])

->disableOriginalConstructor()

->getMock();

// Use Mockery to mock the IoC Container

$this->mockedContainer = m::mock('Illuminate\Container\Container');

$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], ];

}

public function tearDown()

{

m::close();

}

public function testFireProperlyCallsTheJobHandler()

{

$job = $this->getJob();

$job->getContainer()->shouldReceive('make')->once()->with('foo')->andReturn($handler = m::mock('StdClass'));

$handler->shouldReceive('fire')->once()->with($job, ['data']);

$job->fire();

}

public function testDeleteRemovesTheJobFromSqs()

{

$this->mockedSqsClient = $this->getMockBuilder('Aws\Sqs\SqsClient')

->setMethods(['deleteMessage'])

->disableOriginalConstructor()

->getMock();

$queue = $this->getMockBuilder('Illuminate\Queue\SqsQueue')->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('Aws\Sqs\SqsClient')

->setMethods(['changeMessageVisibility'])

->disableOriginalConstructor()

->getMock();

$queue = $this->getMockBuilder('Illuminate\Queue\SqsQueue')->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 Illuminate\Queue\Jobs\SqsJob(

$this->mockedContainer,

$this->mockedSqsClient,

$this->queueUrl,

$this->mockedJobData

);

}

}