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

Add method for processing end of sending for completed tasks

Browse Source 
[MAILPOET-5881]
This commit is contained in:
Rostislav Wolny
2024-05-30 15:25:26 +02:00
committed by Aschepikov
parent 1111bac58b
commit 55ae6264cc
1 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
mailpoet/lib/Cron/Workers/SendingQueue/SendingQueue.php
View File

@@ -334,13 +334,11 @@ class SendingQueue {
'after queue chunk processing',
['newsletter_id' => $newsletter->getId(), 'task_id' => $task->getId()]
);
// In case we finished end sending properly before enforcing sending and execution limits
// The limit enforcing throws and exception and the sending end wouldn't be processed properly (stats notification, newsletter marked as sent etc.)
if ($task->getStatus() === ScheduledTaskEntity::STATUS_COMPLETED) {
$this->loggerFactory->getLogger(LoggerFactory::TOPIC_NEWSLETTERS)->info(
'completed newsletter sending',
['newsletter_id' => $newsletter->getId(), 'task_id' => $task->getId()]
);
$this->newsletterTask->markNewsletterAsSent($newsletter);
$this->statsNotificationsScheduler->schedule($newsletter);
$this->endSending($task, $newsletter);
return;
}
$this->enforceSendingAndExecutionLimits($timer);
} else {
@@ -641,4 +639,16 @@ class SendingQueue {
$this->scheduledTasksRepository->remove($task);
$this->scheduledTasksRepository->flush();
}
private function endSending(ScheduledTaskEntity $task, NewsletterEntity $newsletter): void {
// Task is completed let's do all the stuff for the completed task
if ($task->getStatus() === ScheduledTaskEntity::STATUS_COMPLETED) {
$this->loggerFactory->getLogger(LoggerFactory::TOPIC_NEWSLETTERS)->info(
'completed newsletter sending',
['newsletter_id' => $newsletter->getId(), 'task_id' => $task->getId()]
);
$this->newsletterTask->markNewsletterAsSent($newsletter);
$this->statsNotificationsScheduler->schedule($newsletter);
}
}
}