custom/plugins/NewsletterSendinblue/src/Subscriber/MailerSettingsChangeSubscriber.php line 48

Open in your IDE?
  1. <?php
  3. namespace NewsletterSendinblue\Subscriber;
  5. use Exception;
  6. use Monolog\Logger;
  7. use NewsletterSendinblue\NewsletterSendinblue;
  8. use NewsletterSendinblue\Service\ApiClientService;
  9. use NewsletterSendinblue\Service\ConfigService;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class MailerSettingsChangeSubscriber implements EventSubscriberInterface
  14. {
  15.     /**
  16.      * @var ConfigService
  17.      */
  18.     private $configService;
  20.     /**
  21.      * @var ApiClientService
  22.      */
  23.     private $apiClientService;
  25.     /**
  26.      * @var Logger
  27.      */
  28.     private $logger;
  30.     public function __construct(
  31.         ConfigService    $configService,
  32.         ApiClientService $apiClientService,
  33.         Logger           $logger
  34.     )
  35.     {
  36.         $this->configService = $configService;
  37.         $this->apiClientService = $apiClientService;
  38.         $this->logger = $logger;
  39.     }
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             EntityWrittenContainerEvent::class => 'onMailerSettingsChange'
  45.         ];
  46.     }
  48.     public function onMailerSettingsChange(EntityWrittenContainerEvent $event): void
  49.     {
  50.         if ($event->getContext()->hasExtension(NewsletterSendinblue::IGNORE_EVENT)) {
  51.             return;
  52.         }
  54.         try {
  55.             $entityWrittenEvent = $event->getEventByEntityName('system_config');
  56.             if (!$entityWrittenEvent) {
  57.                 return;
  58.             }
  60.             foreach ($entityWrittenEvent->getWriteResults() as $writeResult) {
  61.                 if ($writeResult->getOperation() !== 'update') {
  62.                     continue;
  63.                 }
  64.                 $payload = $writeResult->getPayload();
  65.                 if (empty($payload['configurationKey'])) {
  66.                     return;
  67.                 }
  68.                 $checkConnection = !($payload['configurationKey'] === ConfigService::CONFIG_USER_CONNECTION_ID);
  69.                 $this->configService->setSalesChannelId($payload['salesChannelId'] ?? null, $checkConnection);
  70.                 if (!$this->configService->isSmtpEnabled() || !$this->configService->getSmtpHost()) {
  71.                     continue;
  72.                 }
  73.                 if (($payload['configurationKey'] == ConfigService::CORE_MAILER_HOST_CONFIG
  74.                         && $payload['configurationValue'] !== $this->configService->getSmtpHost())
  75.                     || ($payload['configurationKey'] == ConfigService::CORE_MAILER_AGENT_CONFIG
  76.                         && $payload['configurationValue'] !== ConfigService::CORE_MAILER_AGENT_VALUE)
  77.                 ) {
  78.                     $this->apiClientService->disableSmtp(
  79.                         [ConfigService::CONFIG_API_KEY => $this->configService->getApiKey()],
  80.                         $event->getContext()
  81.                     );
  82.                     $this->configService->setIsSmtpEnabled(false);
  83.                 }
  84.             }
  85.         } catch (Exception $e) {
  86.             $this->logger->addRecord(
  87.                 Logger::ERROR,
  88.                 sprintf('onMailerSettingsChange Error: %s', $e->getMessage())
  89.             );
  90.         }
  91.     }
  92. }