custom/plugins/rapi1Connector/src/Subscribers/UpdatedCustomerAddressEntitySubscriber.php line 22

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Rapidmail\Shopware\Subscribers;
  7. use Shopware\Core\Checkout\Customer\CustomerEvents;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  11. class UpdatedCustomerAddressEntitySubscriber extends UpdatedCustomerRelatedEntitySubscriber
  12. {
  13.     public const SUBSCRIBED_TO_ENTITY_NAME = 'customer_address';
  15.     public static function getSubscribedEvents(): array
  16.     {
  17.         return [
  18.             CustomerEvents::CUSTOMER_ADDRESS_WRITTEN_EVENT => 'onWrittenAddress',
  19.         ];
  20.     }
  22.     public function onWrittenAddress(EntityWrittenEvent $event): void
  23.     {
  24.         $context = $event->getContext();
  25.         $writeResult = $event->getWriteResults()[0] ?? null;
  27.         if (!($writeResult instanceof EntityWriteResult)) {
  28.             return;
  29.         }
  31.         $payload = $writeResult->getPayload();
  33.         if ($this->isAllowed($event, $payload)) {
  34.             $this->updateCustomer(
  35.                 $this->getCustomerId($payload),
  36.                 $context
  37.             );
  38.         }
  39.     }
  41.     protected function isAllowed(EntityWrittenEvent $event, ?array $data): bool
  42.     {
  43.         return (
  44.             $event->getEntityName() === self::SUBSCRIBED_TO_ENTITY_NAME &&
  45.             is_array($data) &&
  46.             !empty($this->getCustomerId($data))
  47.         );
  48.     }
  50.     private function getCustomerId(array $data): ?string
  51.     {
  52.         return (!empty($data['customerId'])) ? $data['customerId'] : null;
  53.     }
  54. }