src/MessageHandler/SendCampaignHandler.php line 59

Open in your IDE?
  1. <?php
  3. namespace App\MessageHandler;
  5. use App\Entity\Task;
  6. use App\Message\SendCampaignMessage;
  7. use App\Service\Api\Api;
  8. use App\Service\Api\Tasks;
  9. use App\Service\Campaign\Sender\SendgridSender;
  10. use Doctrine\ORM\EntityManagerInterface;
  11. use Psr\Container\ContainerInterface;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpKernel\KernelEvents;
  15. use Symfony\Component\Messenger\Event\WorkerMessageFailedEvent;
  16. use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
  17. use Symfony\Contracts\Service\ServiceSubscriberInterface;
  19. class SendCampaignHandler implements MessageHandlerInterface, ServiceSubscriberInterface, EventSubscriberInterface {
  21. /**
  22. * @var EntityManagerInterface
  23. */
  24. private $em;
  25. /**
  26. * @var ContainerInterface
  27. */
  28. private $locator;
  29. /**
  30. * @var Api
  31. */
  32. private $api;
  33. private $logger;
  35. public function __construct(EntityManagerInterface $em, ContainerInterface $locator, LoggerInterface $logger, Api $api)
  36. {
  37. $this->em = $em;
  38. $this->locator = $locator;
  39. $this->api = $api;
  40. $this->logger = $logger;
  41. }
  43. static function getSubscribedServices()
  44. {
  45. return [
  46. SendgridSender::class
  47. ];
  48. }
  50. static function getSubscribedEvents()
  51. {
  52. return [
  53. WorkerMessageFailedEvent::class => [
  54. ['handleFailed', 10]
  55. ]
  56. ];
  57. }
  59. public function handleFailed(WorkerMessageFailedEvent $event)
  60. {
  61. print_r($event->getReceiverName());
  62. }
  64. public function __invoke(SendCampaignMessage $message)
  65. {
  66. $campaignEmail = $message->getCampaignEmail();
  67. $campaignId = $message->getCampaignId();
  69. $sender_class = $message->getSenderClass(); // App\Service\Campaign\Sender\SenderInterface
  70. $sender = $this->locator->get($sender_class);
  72. // Send batch
  73. $sender->sendCampaign($campaignEmail);
  75. $this->logger->debug('Batch Executed, attempting task update if task', [
  76. 'task_id' => $message->getTaskId(),
  77. 'contacts' => count($campaignEmail->getContacts())
  78. ]);
  80. // Update task if we have one
  81. if($message->getTaskId()){
  82. $task = $this->em->find(Task::class, $message->getTaskId());
  83. try{
  84. $this->logger->debug('Batch Executed, attempting task update', [
  85. 'task_id' => $task->getId(),
  86. 'contacts' => count($campaignEmail->getContacts())
  87. ]);
  89. $this->api->get(Tasks::class)->increaseProgress($task, count($campaignEmail->getContacts()));
  90. } catch (\Exception $e){
  91. $this->logger->error('Error updating task progress: '.$e->getMessage(), [
  92. 'task_id' => $task->getId(),
  93. 'contacts' => count($campaignEmail->getContacts())
  94. ]);
  95. }
  96. }
  98. }
  100. }