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

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