function acquia_contenthub_subscriber_update_82003 in Acquia Content Hub 8.2

Converts 1.x import queues to 2.x import queues.

File

modules/acquia_contenthub_subscriber/acquia_contenthub_subscriber.install, line 110

Acquia Content Hub - Subscriber module install file.

Code

function acquia_contenthub_subscriber_update_82003() {
  $database = \Drupal::database();
  $queue_items = $database
    ->select('queue', 'q')
    ->fields('q', [
    'data',
    'item_id',
  ])
    ->condition('name', 'acquia_contenthub_import_queue')
    ->execute()
    ->fetchAll();
  if (!$queue_items) {
    return;
  }
  $exp_queue = \Drupal::queue('acquia_contenthub_subscriber_import');
  $uuids = '';
  foreach ($queue_items as $item) {
    $data = unserialize($item->data);
    foreach ($data->data as $entity_data) {
      $uuid = _acquia_contenthub_subscriber_get_entity_uuid($entity_data);
      $uuids = empty($uuids) ? $uuid : $uuids . ", {$uuid}";
    }
  }
  if (empty($uuids)) {
    return;
  }
  $new = new \stdClass();
  $new->uuids = $uuids;
  $exp_queue
    ->createItem($new);
  $database
    ->delete('queue')
    ->condition('name', 'acquia_contenthub_import_queue')
    ->execute();
}