Da\Mailer\Test\Queue\Backend\Pdo\PdoQueueStoreAdapterTest

Complexity

Total Complexity

4

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	1

<?php
class PdoQueueStoreAdapterTest extends AbstractMySqlDatabaseTestCase
{
    /**
     * @var PdoQueueStoreAdapter
     */
    private $pdoQueueStore;

    protected function setUp()
    {
        parent::setUp();

        $this->pdoQueueStore = new PdoQueueStoreAdapter(self::getPdoQueueStoreConnection());
    }

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

        $this->assertSame($this->pdoQueueStore, $this->pdoQueueStore->init());

        $this->assertTrue($this->pdoQueueStore->enqueue($mailJob));

        $this->assertTrue($this->pdoQueueStore->isEmpty() === false);

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

        $this->assertTrue($this->pdoQueueStore->isEmpty() === true); // message set to 'A' on process

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

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

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

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

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

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

        $this->pdoQueueStore->enqueue($mailJob);
        $this->assertTrue($this->pdoQueueStore->isEmpty() === false);
        $dequedMailJob = $this->pdoQueueStore->dequeue();
        $this->assertTrue($this->pdoQueueStore->isEmpty() === true);
        // enqueue it back to be able to get it
        // we could actually set the time to be processed in the future :)
        // lets simply update the increment
        $dequedMailJob->incrementAttempt();
        $dequedMailJob->setTimeToSend(date('Y-m-d H:i:s', time() + 1));
        $this->assertEquals(1, $dequedMailJob->getAttempt());
        $dequedMailJob->markAsNew();
        $this->pdoQueueStore->ack($dequedMailJob);
        sleep(1);
        $this->assertTrue($this->pdoQueueStore->isEmpty() === false);
    }

    /**
     * @expectedException \BadMethodCallException
     */
    public function testBadMethodCallExceptionOnAck()
    {
        $mailJob = FixtureHelper::getPdoMailJob();
        $this->pdoQueueStore->ack($mailJob);
    }
}