You are here

class EmailSubscriber in Commerce Email 8

Subscribes to Symfony events and maps them to email events.

@todo Optimize performance by implementing an event map in \Drupal::state(). This would allow us to subscribe only to events which have emails defined, and to load only those emails (instead of all of them).

Hierarchy

  • class \Drupal\commerce_email\EventSubscriber\EmailSubscriber implements \Symfony\Component\EventDispatcher\EventSubscriberInterface

Expanded class hierarchy of EmailSubscriber

1 string reference to 'EmailSubscriber'
commerce_email.services.yml in ./commerce_email.services.yml
commerce_email.services.yml
1 service uses EmailSubscriber
commerce_email.email_subscriber in ./commerce_email.services.yml
Drupal\commerce_email\EventSubscriber\EmailSubscriber

File

src/EventSubscriber/EmailSubscriber.php, line 16

Namespace

Drupal\commerce_email\EventSubscriber
View source
class EmailSubscriber implements EventSubscriberInterface {

  /**
   * The email sender.
   *
   * @var \Drupal\commerce_email\EmailSenderInterface
   */
  protected $emailSender;

  /**
   * Constructs a new EmailSubscriber object.
   *
   * @param \Drupal\commerce_email\EmailSenderInterface $email_sender
   *   The email sender.
   */
  public function __construct(EmailSenderInterface $email_sender) {
    $this->emailSender = $email_sender;
  }

  /**
   * {@inheritDoc}
   */
  public static function getSubscribedEvents() {

    // This method could be called early when the container is built, so the
    // email event manager might not be available yet.
    if (!\Drupal::hasService('plugin.manager.commerce_email_event')) {
      return [];
    }

    /** @var \Drupal\Core\Plugin\DefaultPluginManager $email_event_manager */
    $email_event_manager = \Drupal::service('plugin.manager.commerce_email_event');
    $email_events = $email_event_manager
      ->getDefinitions();
    $events = [];
    foreach ($email_events as $definition) {
      $events[$definition['event_name']][] = [
        'onEvent',
      ];
    }
    return $events;
  }

  /**
   * Sends emails associated with the given event.
   *
   * @param \Symfony\Component\EventDispatcher\Event $event
   *   The event.
   * @param string $event_name
   *   The event name.
   */
  public function onEvent(Event $event, $event_name) {
    $email_storage = \Drupal::entityTypeManager()
      ->getStorage('commerce_email');

    /** @var \Drupal\commerce_email\Entity\EmailInterface[] $emails */
    $emails = $email_storage
      ->loadMultiple();
    foreach ($emails as $email) {
      $email_event = $email
        ->getEvent();
      if ($email_event
        ->getEventName() == $event_name) {
        $entity = $email_event
          ->extractEntityFromEvent($event);
        if ($email
          ->applies($entity)) {
          $this->emailSender
            ->send($email, $entity);
        }
      }
    }
  }

}

Members

Namesort descending Modifiers Type Description Overrides
EmailSubscriber::$emailSender protected property The email sender.
EmailSubscriber::getSubscribedEvents public static function Returns an array of event names this subscriber wants to listen to.
EmailSubscriber::onEvent public function Sends emails associated with the given event.
EmailSubscriber::__construct public function Constructs a new EmailSubscriber object.