class AppCredentialEventSubscriber in Apigee Edge 8

Events for an API Product being added to an app already exist.

This event subscriber is a proxy for Apigee Edge app credential events.

Hierarchy

• class \Drupal\apigee_edge_actions\EventSubscriber\AppCredentialEventSubscriber implements \Symfony\Component\EventDispatcher\EventSubscriberInterface

1 string reference to 'AppCredentialEventSubscriber'

apigee_edge_actions.services.yml in modules/apigee_edge_actions/apigee_edge_actions.services.yml

modules/apigee_edge_actions/apigee_edge_actions.services.yml

1 service uses AppCredentialEventSubscriber

apigee_edge_actions.events_subscriber in modules/apigee_edge_actions/apigee_edge_actions.services.yml

Drupal\apigee_edge_actions\EventSubscriber\AppCredentialEventSubscriber

File

modules/apigee_edge_actions/src/EventSubscriber/AppCredentialEventSubscriber.php, line 40

Namespace

Drupal\apigee_edge_actions\EventSubscriber

class AppCredentialEventSubscriber implements EventSubscriberInterface {

  /**
   * The entity type manager.
   *
   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
   */
  protected $entityTypeManger;

  /**
   * The event dispatcher.
   *
   * @var \Symfony\Component\EventDispatcher\EventDispatcherInterface
   */
  protected $eventDispatcher;

  /**
   * The logger channel.
   *
   * @var \Drupal\Core\Logger\LoggerChannelInterface
   */
  protected $logger;

  /**
   * The current user.
   *
   * @var \Drupal\Core\Session\AccountInterface
   */
  protected $currentUser;

  /**
   * AppCredentialEventSubscriber constructor.
   *
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
   *   The entity type manager.
   * @param \Symfony\Component\EventDispatcher\EventDispatcherInterface $event_dispatcher
   *   The event dispatcher.
   * @param \Drupal\Core\Session\AccountInterface $current_user
   *   The current user.
   * @param \Drupal\Core\Logger\LoggerChannelInterface $logger
   *   The logger channel.
   */
  public function __construct(EntityTypeManagerInterface $entity_type_manager, EventDispatcherInterface $event_dispatcher, AccountInterface $current_user, LoggerChannelInterface $logger) {
    $this->entityTypeManger = $entity_type_manager;
    $this->logger = $logger;
    $this->eventDispatcher = $event_dispatcher;
    $this->currentUser = $current_user;
  }

  /**
   * Responds to add product events.
   *
   * @param \Drupal\apigee_edge\Event\AppCredentialAddApiProductEvent $event
   *   The app credential add product event.
   */
  public function onAddProduct(AppCredentialAddApiProductEvent $event) {
    $this
      ->dispatchRulesEvent('apigee_edge_actions_entity_add_product:developer_app', $event, $event
      ->getNewProducts());
  }

  /**
   * Responds to remove product events.
   *
   * @param \Drupal\apigee_edge\Event\AppCredentialDeleteApiProductEvent $event
   *   The app credential remove product event.
   */
  public function onRemoveProduct(AppCredentialDeleteApiProductEvent $event) {
    $this
      ->dispatchRulesEvent('apigee_edge_actions_entity_remove_product:developer_app', $event, [
      $event
        ->getApiProduct(),
    ]);
  }

  /**
   * {@inheritdoc}
   */
  public static function getSubscribedEvents() {
    return [
      AppCredentialAddApiProductEvent::EVENT_NAME => [
        'onAddProduct',
        100,
      ],
      AppCredentialDeleteApiProductEvent::EVENT_NAME => [
        'onRemoveProduct',
        100,
      ],
    ];
  }

  /**
   * Helper to dispatch a corresponding rules event for an api credential event.
   *
   * @param string $rules_event_name
   *   The name of the rules event.
   * @param \Symfony\Component\EventDispatcher\Event $event
   *   The api credential event.
   * @param array $api_products
   *   An array of api products.
   */
  protected function dispatchRulesEvent(string $rules_event_name, Event $event, array $api_products) {
    try {
      $app = $this
        ->getAppByName($event
        ->getAppName(), $event
        ->getOwnerId(), $event
        ->getAppType());
      $app_type = "{$event->getAppType()}_app";
      if ('developer_app' == $app_type) {

        // For developer apps, get the Drupal account from the app owner.

        /** @var \Drupal\apigee_edge\Entity\Storage\DeveloperStorageInterface $developer_storage */

        /** @var \Drupal\apigee_edge\Entity\Developer $owner */
        $developer_storage = $this->entityTypeManger
          ->getStorage($event
          ->getAppType());
        $owner = $developer_storage
          ->load($event
          ->getOwnerId());
        $developer = user_load_by_mail($owner
          ->getEmail());
      }
      else {

        // For team apps, default to the current user.
        $developer = $this->entityTypeManger
          ->getStorage('user')
          ->load($this->currentUser
          ->id());
      }
      foreach ($api_products as $product) {

        /** @var \Drupal\apigee_edge\Entity\ApiProductInterface $api_product */
        $api_product = $this->entityTypeManger
          ->getStorage('api_product')
          ->load($product);
        $this->eventDispatcher
          ->dispatch($rules_event_name, new EdgeEntityEventEdge($app, [
          $app_type => $app,
          'developer' => $developer,
          'api_product_name' => $api_product
            ->getName(),
          'api_product_display_name' => $api_product
            ->getDisplayName(),
        ]));
      }
    } catch (PluginException $exception) {
      $this->logger
        ->error($exception
        ->getMessage());
    }
  }

  /**
   * Helper to load an app by name.
   *
   * @param string $name
   *   The name of the app.
   * @param string $owner_id
   *   The developer or team.
   * @param string $app_type
   *   The type of the app.
   *
   * @return \Drupal\apigee_edge\Entity\AppInterface|null
   *   The app with the provided name or null.
   */
  protected function getAppByName(string $name, string $owner_id, string $app_type) : ?AppInterface {

    /* @var \Drupal\apigee_edge\Entity\AppInterface $appClass */
    $appClass = $this->entityTypeManger
      ->getStorage("{$app_type}_app")
      ->getEntityType()
      ->getClass();
    try {
      if ($app_type == 'developer') {

        /* @var \Drupal\apigee_edge\Entity\Controller\DeveloperAppControllerFactoryInterface $controller */
        $controller = \Drupal::service('apigee_edge.controller.developer_app_controller_factory');
        $edge_app = $controller
          ->developerAppController($owner_id)
          ->load($name);
      }
      else {

        /* @var \Drupal\apigee_edge_teams\Entity\Controller\TeamAppControllerFactory $controller */
        $controller = \Drupal::service('apigee_edge_teams.controller.team_app_controller_factory');
        $edge_app = $controller
          ->teamAppController($owner_id)
          ->load($name);
      }
      $app = $appClass::createFrom($edge_app);
      return $app;
    } catch (PluginException $exception) {
      $this->logger
        ->error($exception);
    }
    return NULL;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
AppCredentialEventSubscriber::$currentUser	protected	property	The current user.
AppCredentialEventSubscriber::$entityTypeManger	protected	property	The entity type manager.
AppCredentialEventSubscriber::$eventDispatcher	protected	property	The event dispatcher.
AppCredentialEventSubscriber::$logger	protected	property	The logger channel.
AppCredentialEventSubscriber::dispatchRulesEvent	protected	function	Helper to dispatch a corresponding rules event for an api credential event.
AppCredentialEventSubscriber::getAppByName	protected	function	Helper to load an app by name.
AppCredentialEventSubscriber::getSubscribedEvents	public static	function	Returns an array of event names this subscriber wants to listen to.
AppCredentialEventSubscriber::onAddProduct	public	function	Responds to add product events.
AppCredentialEventSubscriber::onRemoveProduct	public	function	Responds to remove product events.
AppCredentialEventSubscriber::__construct	public	function	AppCredentialEventSubscriber constructor.