Spaces:
No application file
No application file
File size: 1,679 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 |
<?php
namespace Mautic\CampaignBundle\Tests\Event;
use Doctrine\Common\Collections\ArrayCollection;
use Mautic\CampaignBundle\Entity\Event;
use Mautic\CampaignBundle\Entity\LeadEventLog;
use Mautic\CampaignBundle\Event\PendingEvent;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\ActionAccessor;
use Mautic\LeadBundle\Entity\Lead;
use PHPUnit\Framework\Assert;
final class PendingEventTest extends \PHPUnit\Framework\TestCase
{
public function testFailAndPassRemainingWithError(): void
{
$event = new Event();
$contact = new Lead();
$logA = new LeadEventLog();
$logB = new LeadEventLog();
$interval = new \DateInterval('PT10M');
$logA->setLead($contact); // Will fail.
$logB->setLead($contact); // Will pass with error.
$pendingEvent = new PendingEvent(new ActionAccessor([]), $event, new ArrayCollection([$logA, $logB]));
$pendingEvent->fail($logA, 'reason A', $interval);
$pendingEvent->passRemainingWithError('Error B');
$failedLogs = $pendingEvent->getFailures();
$successLogs = $pendingEvent->getSuccessful();
Assert::assertCount(1, $failedLogs);
Assert::assertCount(1, $successLogs);
Assert::AssertSame($logA, $failedLogs->current());
Assert::AssertSame($logB, $successLogs->current());
Assert::AssertSame($interval, $logA->getRescheduleInterval());
Assert::AssertSame(['failed' => 1, 'reason' => 'reason A'], $logA->getMetadata());
Assert::AssertSame(['failed' => 1, 'reason' => 'Error B'], $logB->getMetadata());
Assert::AssertNull($logB->getRescheduleInterval());
}
}
|