Spaces:
No application file
No application file
File size: 4,504 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
namespace Mautic\CampaignBundle\Executioner\Dispatcher;
use Doctrine\Common\Collections\ArrayCollection;
use Mautic\CampaignBundle\CampaignEvents;
use Mautic\CampaignBundle\Entity\Event;
use Mautic\CampaignBundle\Entity\LeadEventLog;
use Mautic\CampaignBundle\Event\ExecutedBatchEvent;
use Mautic\CampaignBundle\Event\ExecutedEvent;
use Mautic\CampaignBundle\Event\FailedEvent;
use Mautic\CampaignBundle\Event\PendingEvent;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\AbstractEventAccessor;
use Mautic\CampaignBundle\EventCollector\Accessor\Event\ActionAccessor;
use Mautic\CampaignBundle\Executioner\Dispatcher\Exception\LogNotProcessedException;
use Mautic\CampaignBundle\Executioner\Dispatcher\Exception\LogPassedAndFailedException;
use Mautic\CampaignBundle\Executioner\Scheduler\EventScheduler;
use Psr\Log\LoggerInterface;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
class ActionDispatcher
{
public function __construct(
private EventDispatcherInterface $dispatcher,
private LoggerInterface $logger,
private EventScheduler $scheduler,
private LegacyEventDispatcher $legacyDispatcher
) {
}
/**
* @throws LogNotProcessedException
* @throws LogPassedAndFailedException
*/
public function dispatchEvent(ActionAccessor $config, Event $event, ArrayCollection $logs, PendingEvent $pendingEvent = null): PendingEvent
{
if (!$pendingEvent) {
$pendingEvent = new PendingEvent($config, $event, $logs);
}
// this if statement can be removed when legacy dispatcher is removed
if ($customEvent = $config->getBatchEventName()) {
$this->dispatcher->dispatch($pendingEvent, $customEvent);
$success = $pendingEvent->getSuccessful();
$failed = $pendingEvent->getFailures();
$this->validateProcessedLogs($logs, $success, $failed);
if ($success) {
$this->dispatchExecutedEvent($config, $event, $success);
}
if ($failed) {
$this->dispatchFailedEvent($config, $failed);
}
// Dispatch legacy ON_EVENT_EXECUTION event for BC
$this->legacyDispatcher->dispatchExecutionEvents($config, $success, $failed);
}
// Execute BC eventName or callback. Or support case where the listener has been converted to batchEventName but still wants to execute
// eventName for BC support for plugins that could be listening to it's own custom event.
$this->legacyDispatcher->dispatchCustomEvent($config, $logs, $customEvent, $pendingEvent);
return $pendingEvent;
}
private function dispatchExecutedEvent(AbstractEventAccessor $config, Event $event, ArrayCollection $logs): void
{
if (!$logs->count()) {
return;
}
foreach ($logs as $log) {
$this->dispatcher->dispatch(
new ExecutedEvent($config, $log),
CampaignEvents::ON_EVENT_EXECUTED
);
}
$this->dispatcher->dispatch(
new ExecutedBatchEvent($config, $event, $logs),
CampaignEvents::ON_EVENT_EXECUTED_BATCH
);
}
private function dispatchFailedEvent(AbstractEventAccessor $config, ArrayCollection $logs): void
{
if (!$logs->count()) {
return;
}
/** @var LeadEventLog $log */
foreach ($logs as $log) {
$this->logger->debug(
'CAMPAIGN: '.ucfirst($log->getEvent()->getEventType() ?? 'unknown event').' ID# '.$log->getEvent()->getId().' for contact ID# '.$log->getLead()->getId()
);
$this->dispatcher->dispatch(
new FailedEvent($config, $log),
CampaignEvents::ON_EVENT_FAILED
);
}
$this->scheduler->rescheduleFailures($logs);
}
/**
* @throws LogNotProcessedException
* @throws LogPassedAndFailedException
*/
private function validateProcessedLogs(ArrayCollection $pending, ArrayCollection $success, ArrayCollection $failed): void
{
foreach ($pending as $log) {
if (!$success->contains($log) && !$failed->contains($log)) {
throw new LogNotProcessedException($log);
}
if ($success->contains($log) && $failed->contains($log)) {
throw new LogPassedAndFailedException($log);
}
}
}
}
|