Cavemanon/piratepoet
7
Fork 0
Code Pull Requests Actions Releases 16 Activity

Extract subject loading before automation processing loop

Browse Source 
[MAILPOET-4946]
This commit is contained in:
Jan Jakes
2023-03-31 11:37:45 +02:00
committed by Aschepikov
parent 70dbfc28b7
commit 54f5addca9
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
mailpoet/lib/Automation/Engine/Control/TriggerHandler.php
View File

@ -64,19 +64,19 @@ class TriggerHandler {
return; return;
} }
// ensure subjects are registered and loadable
$subjects = $this->subjectTransformerHandler->getAllSubjects($subjects); $subjects = $this->subjectTransformerHandler->getAllSubjects($subjects);
$subjectEntries = $this->subjectLoader->getSubjectsEntries($subjects);
foreach ($subjectEntries as $entry) {
$entry->getPayload();
}
foreach ($automations as $automation) { foreach ($automations as $automation) {
$step = $automation->getTrigger($trigger->getKey()); $step = $automation->getTrigger($trigger->getKey());
if (!$step) { if (!$step) {
throw Exceptions::automationTriggerNotFound($automation->getId(), $trigger->getKey()); throw Exceptions::automationTriggerNotFound($automation->getId(), $trigger->getKey());
} }
// ensure subjects are registered and loadable
$subjectEntries = $this->subjectLoader->getSubjectsEntries($subjects);
foreach ($subjectEntries as $entry) {
$entry->getPayload();
}
$automationRun = new AutomationRun($automation->getId(), $automation->getVersionId(), $trigger->getKey(), $subjects); $automationRun = new AutomationRun($automation->getId(), $automation->getVersionId(), $trigger->getKey(), $subjects);
$stepRunArgs = new StepRunArgs($automation, $automationRun, $step, $subjectEntries); $stepRunArgs = new StepRunArgs($automation, $automationRun, $step, $subjectEntries);
$createAutomationRun = $trigger->isTriggeredBy($stepRunArgs); $createAutomationRun = $trigger->isTriggeredBy($stepRunArgs);