Da\Mailer\Test\Queue\MailQueueTest

Complexity

Total Complexity

3

Size/Duplication

Total Lines	63
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes	2
Bugs	0	Features	1

<?php
class MailQueueTest extends AbstractMySqlDatabaseTestCase
{
    /**
     * @var MailQueue
     */
    private $mailQueuePdo;
    /**
     * @var PdoQueueStoreAdapter
     */
    private $pdoQueueAdapter;

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

    public function testPdoEnqueDequeueAndAcknowledge()
    {
        $mailJob = FixtureHelper::getPdoMailJob();

        $this->assertSame($this->pdoQueueAdapter, $this->mailQueuePdo->init());
        $this->assertEquals(self::getPdoQueueStoreConnection(), $this->mailQueuePdo->getConnection());
        $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());
    }
}