Spaces:
No application file
No application file
File size: 2,332 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 |
<?php
namespace Mautic\CampaignBundle\Executioner\Event;
use Doctrine\Common\Collections\ArrayCollection;
use Mautic\CampaignBundle\Entity\Event;
use Mautic\CampaignBundle\Entity\LeadEventLog;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\AbstractEventAccessor;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\ConditionAccessor;
use Mautic\CampaignBundle\Executioner\Dispatcher\ConditionDispatcher;
use Mautic\CampaignBundle\Executioner\Exception\CannotProcessEventException;
use Mautic\CampaignBundle\Executioner\Exception\ConditionFailedException;
use Mautic\CampaignBundle\Executioner\Result\EvaluatedContacts;
class ConditionExecutioner implements EventInterface
{
public const TYPE = 'condition';
public function __construct(
private ConditionDispatcher $dispatcher
) {
}
/**
* @throws CannotProcessEventException
*/
public function execute(AbstractEventAccessor $config, ArrayCollection $logs): EvaluatedContacts
{
\assert($config instanceof ConditionAccessor);
$evaluatedContacts = new EvaluatedContacts();
/** @var LeadEventLog $log */
foreach ($logs as $log) {
try {
/* @var ConditionAccessor $config */
$this->dispatchEvent($config, $log);
$evaluatedContacts->pass($log->getLead());
} catch (ConditionFailedException) {
$evaluatedContacts->fail($log->getLead());
$log->setNonActionPathTaken(true);
}
// Unschedule the condition and update date triggered timestamp
$log->setDateTriggered(new \DateTime());
}
return $evaluatedContacts;
}
/**
* @throws CannotProcessEventException
* @throws ConditionFailedException
*/
private function dispatchEvent(ConditionAccessor $config, LeadEventLog $log): void
{
if (Event::TYPE_CONDITION !== $log->getEvent()->getEventType()) {
throw new CannotProcessEventException('Cannot process event ID '.$log->getEvent()->getId().' as a condition.');
}
$conditionEvent = $this->dispatcher->dispatchEvent($config, $log);
if (!$conditionEvent->wasConditionSatisfied()) {
throw new ConditionFailedException('evaluation failed');
}
}
}
|