class ReExport in Acquia Content Hub 8.2

Re-exports an entity and all its dependencies on a webhook request.

@package Drupal\acquia_contenthub_preview\EventSubscriber\HandleWebhook

Hierarchy

• class \Drupal\acquia_contenthub_publisher\EventSubscriber\HandleWebhook\ReExport implements \Symfony\Component\EventDispatcher\EventSubscriberInterface uses HandleWebhookTrait

1 file declares its use of ReExport

ReExportTest.php in modules/acquia_contenthub_publisher/tests/src/Kernel/EventSubscriber/HandleWebhook/ReExportTest.php

1 string reference to 'ReExport'

acquia_contenthub_publisher.services.yml in modules/acquia_contenthub_publisher/acquia_contenthub_publisher.services.yml

modules/acquia_contenthub_publisher/acquia_contenthub_publisher.services.yml

1 service uses ReExport

acquia_contenthub_publisher.handle_webhook.re_export in modules/acquia_contenthub_publisher/acquia_contenthub_publisher.services.yml

Drupal\acquia_contenthub_publisher\EventSubscriber\HandleWebhook\ReExport

File

modules/acquia_contenthub_publisher/src/EventSubscriber/HandleWebhook/ReExport.php, line 17

Namespace

Drupal\acquia_contenthub_publisher\EventSubscriber\HandleWebhook

class ReExport implements EventSubscriberInterface {
  use HandleWebhookTrait;

  /**
   * The Publisher Actions Service.
   *
   * @var \Drupal\acquia_contenthub_publisher\PublisherActions
   */
  protected $publisherActions;

  /**
   * The stream wrapper manager.
   *
   * @var \Drupal\Core\Entity\EntityRepositoryInterface
   */
  protected $entityRepository;

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

  /**
   * ReExport constructor.
   *
   * @param \Drupal\acquia_contenthub_publisher\PublisherActions $publisher_actions
   *   The Publisher Actions Service.
   * @param \Drupal\Core\Entity\EntityRepositoryInterface $entity_repository
   *   The Entity Repository service.
   * @param \Drupal\Core\Logger\LoggerChannelFactoryInterface $logger_factory
   *   The logger factory.
   */
  public function __construct(PublisherActions $publisher_actions, EntityRepositoryInterface $entity_repository, LoggerChannelFactoryInterface $logger_factory) {
    $this->publisherActions = $publisher_actions;
    $this->entityRepository = $entity_repository;
    $this->channel = $logger_factory
      ->get('acquia_contenthub_publisher');
  }

  /**
   * {@inheritdoc}
   */
  public static function getSubscribedEvents() {
    $events[AcquiaContentHubEvents::HANDLE_WEBHOOK][] = [
      'onHandleWebhook',
      1000,
    ];
    return $events;
  }

  /**
   * Handles webhook events.
   *
   * @param \Drupal\acquia_contenthub\Event\HandleWebhookEvent $event
   *   The HandleWebhookEvent object.
   *
   * @throws \Exception
   */
  public function onHandleWebhook(HandleWebhookEvent $event) : void {
    $payload = $event
      ->getPayload();
    $client = $event
      ->getClient();
    $settings = $client
      ->getSettings();
    $client_uuid = $settings
      ->getUuid();
    if ('successful' !== $payload['status'] || empty($payload['uuid']) || 'republish' !== $payload['crud'] || $payload['initiator'] === $client_uuid || empty($payload['cdf'])) {
      return;
    }

    // Obtaining Entity from Webhook message.
    $uuid = $payload['cdf']['uuid'];
    $type = $payload['cdf']['type'];
    $dependencies = $payload['cdf']['dependencies'] ?? [];
    try {
      $entity = $this->entityRepository
        ->loadEntityByUuid($type, $uuid);
    } catch (\Exception $exception) {
      $entity = FALSE;
    }
    if (!$entity) {
      $body = sprintf('The entity "%s:%s" could not be found and thus cannot be re-exported from a webhook request by origin = %s.', $type, $uuid, $payload['initiator']);
      $this->channel
        ->error($body);
      $response = $this
        ->getResponse($event, $body, 404);
    }
    else {
      $this->publisherActions
        ->reExportEntityFull($entity, $dependencies);
      $body = sprintf('Entity "%s/%s" successfully enqueued for export from webhook UUID = %s by origin = %s.', $type, $uuid, $payload['uuid'], $payload['initiator']);
      $this->channel
        ->info($body);
      $response = $this
        ->getResponse($event, $body, 200);
    }
    $event
      ->setResponse($response);
    $event
      ->stopPropagation();
  }

}

Members

Name	Modifiers	Type	Description	Overrides
HandleWebhookTrait::getResponse	protected	function	Handles webhook response.
ReExport::$channel	protected	property	The acquia_contenthub_moderation logger channel.
ReExport::$entityRepository	protected	property	The stream wrapper manager.
ReExport::$publisherActions	protected	property	The Publisher Actions Service.
ReExport::getSubscribedEvents	public static	function	Returns an array of event names this subscriber wants to listen to.
ReExport::onHandleWebhook	public	function	Handles webhook events.
ReExport::__construct	public	function	ReExport constructor.