Da\Mailer\Test\Queue\MailQueueTest

Complexity

Total Complexity

3

Size/Duplication

Total Lines	60
Duplicated Lines	38.33 %

Coupling/Cohesion

Components	1
Dependencies	8

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	6	1
A	testPdoEnqueDequeueAndAcknowledge()	23	23	1
A	testPdoEnqueDequeueWithCypher()	0	20	1

<?php
namespace Da\Mailer\Test\Queue;

use Da\Mailer\Model\MailMessage;
use Da\Mailer\Queue\Backend\Pdo\PdoMailJob;
use Da\Mailer\Queue\Backend\Pdo\PdoQueueStoreAdapter;
use Da\Mailer\Security\Cypher;
use Da\Mailer\Test\AbstractMySqlDatabaseTestCase;
use Da\Mailer\Test\Fixture\FixtureHelper;
use Da\Mailer\Queue\MailQueue;

class MailQueueTest extends AbstractMySqlDatabaseTestCase
{
    /**
     * @var MailQueue
     */
    private $mailQueuePdo;
    private $pdoQueueAdapter;

    protected function setUp()
    {
        parent::setUp();
        $this->pdoQueueAdapter = new PdoQueueStoreAdapter(self::getPdoQueueStoreConnection());
        $this->mailQueuePdo = new MailQueue($this->pdoQueueAdapter);
    }

    public function testPdoEnqueDequeueAndAcknowledge()

This method seems to be duplicated in your project.

    {
        $mailJob = FixtureHelper::getMailJob();

        $this->assertSame($this->pdoQueueAdapter, $this->mailQueuePdo->init());
        $this->assertTrue($this->mailQueuePdo->enqueue($mailJob));
        $this->assertTrue($this->mailQueuePdo->isEmpty() === false);

        $mailJob = $this->mailQueuePdo->dequeue();

        $this->assertTrue($this->mailQueuePdo->isEmpty() === true);

        $this->assertTrue(!empty($mailJob->getMessage()));

        $dequeuedMailMessage = MailMessage::fromArray(json_decode($mailJob->getMessage(), true));

        $this->assertEquals(FixtureHelper::getMailMessage(), $dequeuedMailMessage);

        $mailJob->markAsCompleted();
        $this->mailQueuePdo->ack($mailJob);

        $this->assertTrue($this->mailQueuePdo->dequeue() === null);
    }

    public function testPdoEnqueDequeueWithCypher()
    {
        $mailMessage = FixtureHelper::getMailMessage();
        $mailJob = new PdoMailJob(['message' => $mailMessage]);
        $cypher = new Cypher('I find your lack of faith disturbing.');

        $this->mailQueuePdo->setCypher($cypher);
        $this->assertSame($cypher, $this->mailQueuePdo->getCypher());

        $this->mailQueuePdo->init();

        $this->assertTrue($this->mailQueuePdo->enqueue($mailJob));
        $this->assertTrue($this->mailQueuePdo->isEmpty() === false);

        $dequeuedMailJob = $this->mailQueuePdo->dequeue();

        $this->assertTrue($dequeuedMailJob->isNewRecord() === false);
        $this->assertEquals($mailMessage, $dequeuedMailJob->getMessage());

    }
}