acquia_commercemanager-8.x-1.122/modules/acm/src/Connector/IngestRequestTrait.php

<?php

namespace Drupal\acm\Connector;

use GuzzleHttp\TransferStats;
use GuzzleHttp\Exception\RequestException;

/**
 * Trait IngestRequestTrait.
 *
 * @package Drupal\acm\Connector
 *
 * @ingroup acm
 */
trait IngestRequestTrait {

  /**
   * HTTP (Guzzle) Connector Client Factory.
   *
   * @var ClientFactory
   */
  private $clientFactory;

  /**
   * Debug / Verbose Connection Logging.
   *
   * @var bool
   */
  private $debug;

  /**
   * System / Watchdog Logger.
   *
   * @var LoggerInterface
   */
  private $logger;

  /**
   * TryIngestRequest.
   *
   * Try a simple request with the Guzzle client, adding debug callbacks
   * and catching / logging request exceptions if needed.
   *
   * @param callable $doReq
   *   Request closure, passed client and opts array.
   * @param string $action
   *   Action name for logging.
   * @param string $reskey
   *   Result data key (or NULL).
   *   TODO (malachy): Not used. Consider removal.
   * @param string $skus
   *   List of skus that need to be synced.
   * @param string $acm_uuid
   *   The ACM UUID indicating which Commerce Connector mapping to use.
   */
  protected function tryIngestRequest(callable $doReq, $action, $reskey = NULL, $skus = '', $acm_uuid = "") {

    $client = $this->clientFactory->createClient($acm_uuid);
    $reqOpts = [];

    if (!empty($skus)) {
      $reqOpts['query']['skus'] = $skus;
    }

    $logger = ($this->logger) ?: \Drupal::logger('acm');

    if ($this->debug) {
      $logger->info("Used ACM-UUID " . $acm_uuid . " to build client for " . $action);
      $logger->info(sprintf('%s: Attempting Request.', $action));

      // Log transfer final endpoint and total time in debug mode.
      $reqOpts['on_stats'] =
        function (TransferStats $stats) use ($logger, $action) {
          $code =
            ($stats->hasResponse()) ?
            $stats->getResponse()->getStatusCode() :
            0;

          $logger->info(sprintf(
            '%s: Requested %s in %.4f [%d].',
            $action,
            $stats->getEffectiveUri(),
            $stats->getTransferTime(),
            $code
          ));
        };
    }

    // Make Request.
    try {
      $result = $doReq($client, $reqOpts);
    }
    catch (RequestException $e) {
      $mesg = sprintf(
        '%s: Exception during request: (%d) - %s',
        $action,
        $e->getCode(),
        $e->getMessage()
      );

      $logger->error($mesg);
      throw new ConnectorException($mesg, $e->getCode(), $e);
    }
  }

}