Tavii\SQSJobQueue\Queue\DummyJob

Complexity

Total Complexity

3

Size/Duplication

Total Lines	26
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	4	1
A	getPrefix()	0	4	1
A	getName()	0	4	1

<?php
namespace Tavii\SQSJobQueue\Queue;

use Phake;
use Aws\Sqs\SqsClient;
use Tavii\SQSJobQueue\Job\Job;
use Tavii\SQSJobQueue\Queue\QueueName;

class QueueTest extends \PHPUnit_Framework_TestCase
{
    private $client;

    public function setUp()
    {
        $this->client = Phake::mock('Aws\Sqs\SqsClient');
    }

    /**
     * @test
     */
    public function キューに保存に保存することができる()
    {
        $name = new QueueName('test');
        $job = Phake::mock('Tavii\SQSJobQueue\Job\Job');
        Phake::when($job)->getJobName()
            ->thenReturn($name);
        Phake::when($job)->getArgs()
            ->thenReturn(array('test','teset2'));

        Phake::when($this->client)->getQueueUrl(array('QueueName' => $name))
            ->thenReturn(array(
                'QueueUrl' => 'test'
            ));


        $queue = new Queue($this->client);
        $queue->send($job);

        Phake::verify($this->client)->getQueueUrl(array('QueueName' => $name->getQueueName()));
        Phake::verify($this->client)->sendMessage($this->isType('array'));
        Phake::verify($job)->getJobName();
        Phake::verify($job)->getArgs();

    }

    /**
     * @test
     */
    public function キューからジョブを取り出すことができる()
    {
        $name = "test_job";
        $args = array(
            'Body' => json_encode(array(
                'className' => 'Tavii\SQSJobQueue\Queue\DummyJob',
                'args' => array('a' => '1' , 'b' => 2)
            ))
        );

        $collection = Phake::mock('Guzzle\Common\Collection');
        Phake::when($collection)->getPath('Messages/*')
            ->thenReturn($args);

        Phake::when($this->client)->getQueueUrl(array('QueueName' => $name))
            ->thenReturn(array(
                'QueueUrl' => 'test'
            ));

        Phake::when($this->client)->receiveMessage(array(
            'QueueUrl' => 'test'
            ))->thenReturn($collection);

        $queue = new Queue($this->client);
        $job = $queue->receive(new QueueName($name));

        $this->assertInstanceOf('Tavii\SQSJobQueue\Message\MessageInterface', $job);
        Phake::verify($collection)->getPath('Messages/*');
        Phake::verify($this->client)->getQueueUrl(array('QueueName' => $name));
        Phake::verify($this->client)->receiveMessage(array('QueueUrl' => 'test'));
    }

    /**
     * @test
     */
    public function キューを削除する()
    {
        $message = Phake::mock('Tavii\SQSJobQueue\Message\Message');
        Phake::when($message)->getMessage()
            ->thenReturn(array(
                'QueueUrl' => '/hoge/fuga',
                'ReceiptHandle' => 'Receipt'
            ));

        Phake::when($this->client)->deleteMessage(array(
            'QueueUrl' => '/hoge/fuga',
            'ReceiptHandle' => 'Receipt',
        ));

        $queue = new Queue($this->client);
        $queue->delete($message);

    }
}

class DummyJob extends Job
{
    /**
     * @param array $args
     * @return booelan

Should the return type not be boolean?

     */
    protected function run()
    {
        return true;
    }

    public function getPrefix()
    {
        return 'queue_test';
    }


    /**
     * @return string
     */
    public function getName()
    {
        return 'test_job';
    }

}