Spaces:
No application file
No application file
| namespace Mautic\EmailBundle\MonitoredEmail\Processor; | |
| use Mautic\EmailBundle\Mailer\Transport\UnsubscriptionProcessorInterface; | |
| use Mautic\EmailBundle\MonitoredEmail\Exception\UnsubscriptionNotFound; | |
| use Mautic\EmailBundle\MonitoredEmail\Message; | |
| use Mautic\EmailBundle\MonitoredEmail\Processor\Unsubscription\Parser; | |
| use Mautic\EmailBundle\MonitoredEmail\Search\ContactFinder; | |
| use Mautic\LeadBundle\Entity\DoNotContact; | |
| use Mautic\LeadBundle\Model\DoNotContact as DoNotContactModel; | |
| use Psr\Log\LoggerInterface; | |
| use Symfony\Component\Mailer\Transport\TransportInterface; | |
| use Symfony\Contracts\Translation\TranslatorInterface; | |
| class Unsubscribe implements ProcessorInterface | |
| { | |
| private ?Message $message = null; | |
| public function __construct( | |
| private TransportInterface $transport, | |
| private ContactFinder $contactFinder, | |
| private TranslatorInterface $translator, | |
| private LoggerInterface $logger, | |
| private DoNotContactModel $doNotContact | |
| ) { | |
| } | |
| public function process(Message $message): bool | |
| { | |
| $this->message = $message; | |
| $this->logger->debug('MONITORED EMAIL: Processing message ID '.$this->message->id.' for an unsubscription'); | |
| $unsubscription = false; | |
| // Does the transport have special handling like Amazon SNS | |
| if ($this->transport instanceof UnsubscriptionProcessorInterface) { | |
| try { | |
| $unsubscription = $this->transport->processUnsubscription($this->message); | |
| } catch (UnsubscriptionNotFound) { | |
| // Attempt to parse a unsubscription the standard way | |
| } | |
| } | |
| if (!$unsubscription) { | |
| try { | |
| $parser = new Parser($message); | |
| $unsubscription = $parser->parse(); | |
| } catch (UnsubscriptionNotFound) { | |
| // No stat found so bail as we won't consider this a reply | |
| $this->logger->debug('MONITORED EMAIL: Unsubscription email was not found'); | |
| return false; | |
| } | |
| } | |
| $searchResult = $this->contactFinder->find($unsubscription->getContactEmail(), $unsubscription->getUnsubscriptionAddress()); | |
| if (!$contacts = $searchResult->getContacts()) { | |
| // No contacts found so bail | |
| return false; | |
| } | |
| $stat = $searchResult->getStat(); | |
| $channel = 'email'; | |
| if ($stat && $email = $stat->getEmail()) { | |
| // We know the email ID so set it to append to the the DNC record | |
| $channel = ['email' => $email->getId()]; | |
| } | |
| $comments = $this->translator->trans('mautic.email.bounce.reason.unsubscribed'); | |
| foreach ($contacts as $contact) { | |
| $this->doNotContact->addDncForContact($contact->getId(), $channel, DoNotContact::UNSUBSCRIBED, $comments); | |
| } | |
| return true; | |
| } | |
| } | |