Spaces:
No application file
No application file
File size: 3,952 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 |
<?php
declare(strict_types=1);
namespace Mautic\EmailBundle\Tests\Entity;
use Mautic\CoreBundle\Test\MauticMysqlTestCase;
use Mautic\EmailBundle\Entity\Email;
use Mautic\EmailBundle\Entity\Stat;
use Mautic\LeadBundle\Entity\Lead;
use Mautic\LeadBundle\Entity\LeadList;
use Mautic\LeadBundle\Entity\ListLead;
use Mautic\LeadBundle\Model\LeadModel;
use PHPUnit\Framework\Assert;
/**
* This test ensures that the pending query will work even if a contact was deleted between batches.
* After the refactoring from NOT EXISTS to NOT IN the single deleted contact could cause the
* pending query to find no contacts due to null value in the lead_id column.
*/
class PendingQueryFunctionalTest extends MauticMysqlTestCase
{
public function testDelayedSends(): void
{
$emailRepository = $this->em->getRepository(Email::class);
$contactCount = 4;
$oneBatchCount = $contactCount / 2;
$contacts = $this->generateContacts($contactCount);
$batch1 = array_slice($contacts, 0, $oneBatchCount);
$segment = $this->createSegment();
$email = $this->createEmail($segment);
$this->addContactsToSegment($contacts, $segment);
Assert::assertSame($contactCount, (int) $emailRepository->getEmailPendingLeads($email->getId(), null, null, true));
$this->emulateEmailSend($email, $batch1);
Assert::assertSame($oneBatchCount, (int) $emailRepository->getEmailPendingLeads($email->getId(), null, null, true));
$this->em->remove($batch1[0]);
$this->em->flush();
// The pending count must be the same even if one of the email_stat records has lead_id = null.
Assert::assertSame($oneBatchCount, (int) $emailRepository->getEmailPendingLeads($email->getId(), null, null, true));
}
/**
* @return Lead[]
*/
private function generateContacts(int $howMany): array
{
$contacts = [];
for ($i = 0; $i < $howMany; ++$i) {
$contact = new Lead();
$contact->setEmail("test{$i}@some.email");
$contacts[] = $contact;
}
$contactModel = static::getContainer()->get('mautic.lead.model.lead');
\assert($contactModel instanceof LeadModel);
$contactModel->saveEntities($contacts);
return $contacts;
}
private function createSegment(): LeadList
{
$segment = new LeadList();
$segment->setName('Segment A');
$segment->setPublicName('Segment A');
$segment->setAlias('segment-a');
$this->em->persist($segment);
$this->em->flush();
return $segment;
}
/**
* @param Lead[] $contacts
*/
private function addContactsToSegment(array $contacts, LeadList $segment): void
{
foreach ($contacts as $contact) {
$reference = new ListLead();
$reference->setLead($contact);
$reference->setList($segment);
$reference->setDateAdded(new \DateTime());
$this->em->persist($reference);
}
$this->em->flush();
}
private function createEmail(LeadList $segment): Email
{
$email = new Email();
$email->setName('Email A');
$email->setSubject('Email A Subject');
$email->setEmailType('list');
$email->addList($segment);
$this->em->persist($email);
$this->em->flush();
return $email;
}
/**
* @param Lead[] $contacts
*/
private function emulateEmailSend(Email $email, array $contacts): void
{
foreach ($contacts as $contact) {
$emailStat = new Stat();
$emailStat->setEmail($email);
$emailStat->setEmailAddress($contact->getEmail());
$emailStat->setLead($contact);
$emailStat->setDateSent(new \DateTime());
$this->em->persist($emailStat);
}
$this->em->flush();
}
}
|