Spaces:
No application file
No application file
File size: 2,003 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 |
<?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\ActionAccessor;
use Mautic\CampaignBundle\Executioner\Dispatcher\ActionDispatcher;
use Mautic\CampaignBundle\Executioner\Exception\CannotProcessEventException;
use Mautic\CampaignBundle\Executioner\Logger\EventLogger;
use Mautic\CampaignBundle\Executioner\Result\EvaluatedContacts;
class ActionExecutioner implements EventInterface
{
public const TYPE = 'action';
public function __construct(
private ActionDispatcher $dispatcher,
private EventLogger $eventLogger
) {
}
/**
* @throws CannotProcessEventException
* @throws \Mautic\CampaignBundle\Executioner\Dispatcher\Exception\LogNotProcessedException
* @throws \Mautic\CampaignBundle\Executioner\Dispatcher\Exception\LogPassedAndFailedException
*/
public function execute(AbstractEventAccessor $config, ArrayCollection $logs): EvaluatedContacts
{
\assert($config instanceof ActionAccessor);
/** @var LeadEventLog $firstLog */
if (!$firstLog = $logs->first()) {
return new EvaluatedContacts();
}
$event = $firstLog->getEvent();
if (Event::TYPE_ACTION !== $event->getEventType()) {
throw new CannotProcessEventException('Cannot process event ID '.$event->getId().' as an action.');
}
// Execute to process the batch of contacts
$pendingEvent = $this->dispatcher->dispatchEvent($config, $event, $logs);
$passed = $this->eventLogger->extractContactsFromLogs($pendingEvent->getSuccessful());
$failed = $this->eventLogger->extractContactsFromLogs($pendingEvent->getFailures());
return new EvaluatedContacts($passed, $failed);
}
}
|