class DefaultExchangerImporter in Commerce Exchanger 8

Class DefaultExchangerImporter.

@package Drupal\commerce_exchanger

Hierarchy

• class \Drupal\commerce_exchanger\DefaultExchangerImporter implements ExchangerImporterInterface

1 string reference to 'DefaultExchangerImporter'

commerce_exchanger.services.yml in ./commerce_exchanger.services.yml

commerce_exchanger.services.yml

1 service uses DefaultExchangerImporter

commerce_exchanger.import in ./commerce_exchanger.services.yml

Drupal\commerce_exchanger\DefaultExchangerImporter

File

src/DefaultExchangerImporter.php, line 15

Namespace

Drupal\commerce_exchanger

class DefaultExchangerImporter implements ExchangerImporterInterface {

  /**
   * Entity type manager.
   *
   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
   */
  protected $entityTypeManager;

  /**
   * List of providers.
   *
   * @var \Drupal\commerce_exchanger\Entity\ExchangeRatesInterface[]
   */
  protected $providers;

  /**
   * Drupal state.
   *
   * @var \Drupal\Core\State\StateInterface
   */
  protected $state;

  /**
   * DefaultExchangerImporter constructor.
   *
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
   *   Drupal entity manager.
   * @param \Drupal\Core\State\StateInterface $state
   *   Drupal state handler.
   */
  public function __construct(EntityTypeManagerInterface $entity_type_manager, StateInterface $state) {
    $this->providers = $entity_type_manager
      ->getStorage('commerce_exchange_rates')
      ->loadByProperties([
      'status' => TRUE,
    ]);
    $this->state = $state;
  }

  /**
   * {@inheritdoc}
   */
  public function run($force = FALSE) {
    foreach ($this->providers as $provider) {
      assert($provider instanceof ExchangeRatesInterface);
      $plugin = $provider
        ->getPlugin();
      if ($plugin instanceof ExchangerProviderRemoteInterface) {
        $last_update = $this->state
          ->get('commerce_exchanger.' . $provider
          ->id() . ' .last_update_time');
        $cron_setup = $provider
          ->getPluginConfiguration()['cron'] ?? 1;
        $cron_schedule = time() - 24 / $cron_setup * 60 * 60;

        // Exclude manual plugins. Check either time or force import.
        if ($force || $last_update < $cron_schedule) {
          $plugin
            ->import();

          // Update last imported time.
          $this->state
            ->set('commerce_exchanger.' . $provider
            ->id() . ' .last_update_time', time());
        }
      }
    }
  }

}

Members

Name	Modifiers	Type	Description	Overrides
DefaultExchangerImporter::$entityTypeManager	protected	property	Entity type manager.
DefaultExchangerImporter::$providers	protected	property	List of providers.
DefaultExchangerImporter::$state	protected	property	Drupal state.
DefaultExchangerImporter::run	public	function	Triggers importing exchange rates. Overrides ExchangerImporterInterface::run
DefaultExchangerImporter::__construct	public	function	DefaultExchangerImporter constructor.