You are here

public function ContentHubImportQueueByFilter::process in Acquia Content Hub 8.2

Define batch process which handles the creation of import queues.

Parameters

array $filter_uuids: Array of cloud filter uuids.

File

modules/acquia_contenthub_subscriber/src/ContentHubImportQueueByFilter.php, line 52

Class

ContentHubImportQueueByFilter
Implements an Import Queue for entites based on custom filters.

Namespace

Drupal\acquia_contenthub_subscriber

Code

public function process(array $filter_uuids) {
  $batch = [
    'title' => $this
      ->t('Process all entities to be queued for import'),
    'operations' => [],
    'finished' => [
      [
        $this,
        'batchFinished',
      ],
      [],
    ],
  ];
  foreach ($filter_uuids as $filter_uuid) {
    $data = new \stdClass();
    $data->filter_uuid = $filter_uuid;
    $this->filterQueue
      ->createItem($data);
    $batch['operations'][] = [
      [
        $this,
        'batchProcess',
      ],
      [],
    ];
  }
  batch_set($batch);
}