quivers-8.x-1.x-dev/src/QuiversMiddlewareService.php

<?php

namespace Drupal\quivers;

use Drupal\Core\Config\ConfigFactoryInterface;
use Drupal\Component\Serialization\Json;
use GuzzleHttp\Exception\BadResponseException;

/**
 * Quivers Middleware Service.
 */
class QuiversMiddlewareService {

  /**
   * The Quivers Settings configuration.
   *
   * @var \Drupal\Core\Config\ImmutableConfig
   */
  protected $quiversConfig;

  /**
   * The client.
   *
   * @var \GuzzleHttp\Client
   */
  protected $quiversMiddlewareClient;

  /**
   * Constructs a new QuiversMiddlewareService object.
   *
   * @param \Drupal\quivers\ClientFactory $client_factory
   *   The client.
   * @param \Drupal\Core\Config\ConfigFactoryInterface $config_factory
   *   The configuration factory.
   */
  public function __construct(ClientFactory $client_factory, ConfigFactoryInterface $config_factory) {
    $this->quiversConfig = $config_factory->get('quivers.settings');
    $this->quiversMiddlewareClient = $client_factory->createMiddlewareInstance($this->quiversConfig->get());
  }

  /**
   * Create Quivers Middleware Profile.
   *
   * @param array $values
   *   Quivers Settings Form array values.
   */
  public function profileCreate(array $values) {
    $request_data = [
      "client_type" => "Drupal",
      "base_url" => $values['drupal_api_base_url'],
      "business_refid" => $values['business_refid'],
      "api_key" => $values['quivers_api_key'],
      "client_id" => $values['client_id'],
      "client_secret" => $values['client_secret'],
      "refresh_token" => $values['refresh_token'],
      "client_upc_key" => $values['upc_field'],
    ];

    $response = $this->quiversMiddlewareClient->post('profile/create',
      ['json' => $request_data,'http_errors' => false]
    );
    $response_data = Json::decode($response->getBody()->getContents());
    return $response_data;
  }

  /**
   * Update Quivers Middleware Profile.
   *
   * @param array $values
   *   Quivers Tax Settings Form array values.
   */
  public function profileUpdate(array $values) {
    $marketplaces = $values['marketplaces'];
    $marketplaces_request_data = [];

    foreach ($marketplaces as $key => $marketplace) {
      if (!$marketplace['quivers_marketplace_id']) {
        continue;
      }
      $data = [];
      $data['store_id'] = $marketplace['store_id'];
      $data['marketplace_id'] = $marketplace['quivers_marketplace_id'];
      $claimingdata = [];
      foreach($marketplace['quivers_claiming_group_ids'] as $claiminggroup) {
        $claiminggroup =  str_replace(' ', '', $claiminggroup);
        array_push ($claimingdata ,$claiminggroup);
      }
      $data['claiming_group_ids'] =$claimingdata;
      array_push($marketplaces_request_data, $data);
    }

    $request_data = [
      "marketplaces" => $marketplaces_request_data,
    ];
    $headers = [
      'uuid' => $this->quiversConfig->get('middleware_profile_id'),
    ];
  
    $this->quiversMiddlewareClient->post(
      'profile/update/marketplaces', [
        'headers' => $headers,
        'json' => $request_data,
      ]
    );
 
  }

  /**
   * Verify Quivers Profile Status.
   *
   * @param array $values
   *   Quivers Settings Database array values.
   * @param bool $tax_settings_status
   *   true or false.
   */
  public function verifyProfileStatus(array $values, bool $tax_settings_status) {
    $request_data = [
      "business_refid" => $values['business_refid'],
      "api_key" => $values['quivers_api_key'],
      "client_type" => "Drupal"
    ];

    try {
      $response = $this->quiversMiddlewareClient->post(
        'profile/status',
        ['json' => $request_data]
      );
    }
    catch (BadResponseException $e) {
      return "Quivers Connection Status: Not Connected.";
    }
    catch (\Exception $e) {
      return "Unable to verify your connection status. Please try again later.";
    }

    $response_data = Json::decode($response->getBody()->getContents());
    if ($tax_settings_status && ($response_data["tax_settings_added"] != "true")) {
      return "Quivers Connection Status: Not Connected. Please re-save page to verify settings";
    }
    if (!$tax_settings_status && $response_data["is_active"] != "true") {
      return "Quivers Connection Status: Not Connected.";
    }

    return NULL;

  }

}