class ContentHubInternalRequest in Acquia Content Hub 8

Provides a method to do internal sub-requests to obtain an entity CDF.

Hierarchy

• class \Drupal\acquia_contenthub\ContentHubInternalRequest

2 files declare their use of ContentHubInternalRequest

ContentHubEntityExportController.php in src/Controller/ContentHubEntityExportController.php

ContentHubInternalRequestTest.php in tests/src/Unit/ContentHubInternalRequestTest.php

1 string reference to 'ContentHubInternalRequest'

acquia_contenthub.services.yml in ./acquia_contenthub.services.yml

acquia_contenthub.services.yml

1 service uses ContentHubInternalRequest

acquia_contenthub.internal_request in ./acquia_contenthub.services.yml

Drupal\acquia_contenthub\ContentHubInternalRequest

File

src/ContentHubInternalRequest.php, line 19

Namespace

Drupal\acquia_contenthub

class ContentHubInternalRequest {

  /**
   * Logger.
   *
   * @var \Drupal\Core\Logger\LoggerChannelFactoryInterface
   */
  protected $loggerFactory;

  /**
   * The Basic HTTP Kernel to make requests.
   *
   * @var \Symfony\Component\HttpKernel\HttpKernelInterface
   */
  protected $kernel;

  /**
   * Content Hub Subscription.
   *
   * @var \Drupal\acquia_contenthub\ContentHubSubscription
   */
  protected $contentHubSubscription;

  /**
   * The account switcher service.
   *
   * @var \Drupal\Core\Session\AccountSwitcherInterface
   */
  protected $accountSwitcher;

  /**
   * The renderer.
   *
   * @var \Drupal\acquia_contenthub\Session\ContentHubUserSession
   */
  protected $renderUser;

  /**
   * The Request Stack Service.
   *
   * @var \Symfony\Component\HttpFoundation\RequestStack
   */
  protected $requestStack;

  /**
   * Public Constructor.
   *
   * @param \Symfony\Component\HttpKernel\HttpKernelInterface $kernel
   *   The HttpKernel.
   * @param \Drupal\acquia_contenthub\ContentHubSubscription $contenthub_subscription
   *   The Content Hub Subscription.
   * @param \Drupal\Core\Session\AccountSwitcherInterface $account_switcher
   *   The Account Switcher Service.
   * @param \Drupal\Core\Config\ConfigFactoryInterface $config_factory
   *   The config factory.
   * @param \Drupal\Core\Logger\LoggerChannelFactoryInterface $logger_factory
   *   The logger factory.
   * @param \Symfony\Component\HttpFoundation\RequestStack $request_stack
   *   The Request Stack.
   */
  public function __construct(HttpKernelInterface $kernel, ContentHubSubscription $contenthub_subscription, AccountSwitcherInterface $account_switcher, ConfigFactoryInterface $config_factory, LoggerChannelFactoryInterface $logger_factory, RequestStack $request_stack) {
    $this->kernel = $kernel;
    $this->contentHubSubscription = $contenthub_subscription;
    $this->accountSwitcher = $account_switcher;
    $this->loggerFactory = $logger_factory;
    $this->renderUser = new ContentHubUserSession($config_factory
      ->get('acquia_contenthub.entity_config')
      ->get('user_role'));
    $this->requestStack = $request_stack;
  }

  /**
   * Implements the static interface create method.
   */
  public static function create(ContainerInterface $container) {
    return new static($container
      ->get('http_kernel.basic'), $container
      ->get('acquia_contenthub.acquia_contenthub_subscription'), $container
      ->get('account_switcher'), $container
      ->get('config.factory'), $container
      ->get('logger.factory'), $container
      ->get('request_stack'));
  }

  /**
   * Makes an internal HMAC-authenticated request to the site to obtain CDF.
   *
   * @param string $entity_type
   *   The Entity type.
   * @param string $entity_id
   *   The Entity ID.
   * @param bool $include_references
   *   Whether to include referenced entities in the CDF.
   *
   * @return array
   *   The CDF array.
   */
  public function getEntityCdfByInternalRequest($entity_type, $entity_id, $include_references = TRUE) {
    global $base_path;

    // Creating a fake user account to give as context to the normalization.
    $this->accountSwitcher
      ->switchTo($this->renderUser);
    try {
      $params = [
        'entity_type' => $entity_type,
        'entity_id' => $entity_id,
        $entity_type => $entity_id,
        '_format' => 'acquia_contenthub_cdf',
      ];
      if ($include_references) {
        $params['include_references'] = 'true';
      }
      $url = Url::fromRoute('acquia_contenthub.entity.' . $entity_type . '.GET.acquia_contenthub_cdf', $params)
        ->toString();
      $url = str_replace($base_path, '/', $url);

      // Creating an internal HMAC-signed request.
      $master_request = $this->requestStack
        ->getCurrentRequest();
      $request = Request::create($url, 'GET', [], $master_request->cookies
        ->all(), [], $master_request->server
        ->all());
      $request = $this->contentHubSubscription
        ->setHmacAuthorization($request, TRUE);

      /** @var \Drupal\Core\Render\HtmlResponse $response */
      $response = $this->kernel
        ->handle($request, HttpKernelInterface::SUB_REQUEST);
      $entity_cdf_json = $response
        ->getContent();
      $bulk_cdf = Json::decode($entity_cdf_json);
    } catch (\Exception $e) {

      // Do nothing, route does not exist, just log a message about it.
      $this->loggerFactory
        ->get('acquia_contenthub')
        ->debug('Exception: %msg', [
        '%msg' => $e
          ->getMessage(),
      ]);
      $bulk_cdf = [];
    }
    $this->accountSwitcher
      ->switchBack();

    // Test to make sure CDF returned an entities array.
    if (isset($bulk_cdf['message'])) {
      $this->loggerFactory
        ->get('acquia_contenthub')
        ->debug('Exception: %msg', [
        '%msg' => $bulk_cdf['message'],
      ]);
      $bulk_cdf = [];
    }

    // Return CDF.
    return empty($bulk_cdf) ? [
      'entities' => [],
    ] : $bulk_cdf;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
ContentHubInternalRequest::$accountSwitcher	protected	property	The account switcher service.
ContentHubInternalRequest::$contentHubSubscription	protected	property	Content Hub Subscription.
ContentHubInternalRequest::$kernel	protected	property	The Basic HTTP Kernel to make requests.
ContentHubInternalRequest::$loggerFactory	protected	property	Logger.
ContentHubInternalRequest::$renderUser	protected	property	The renderer.
ContentHubInternalRequest::$requestStack	protected	property	The Request Stack Service.
ContentHubInternalRequest::create	public static	function	Implements the static interface create method.
ContentHubInternalRequest::getEntityCdfByInternalRequest	public	function	Makes an internal HMAC-authenticated request to the site to obtain CDF.
ContentHubInternalRequest::__construct	public	function	Public Constructor.