function acquia_contenthub_publisher_update_82001 in Acquia Content Hub 8.2

Converts 1.x export queues to 2.x export queues.

File

modules/acquia_contenthub_publisher/acquia_contenthub_publisher.install, line 78

Acquia Content Hub - Publisher module install file.

Code

function acquia_contenthub_publisher_update_82001() {
  $database = \Drupal::database();
  $queue_items = $database
    ->select('queue', 'q')
    ->fields('q', [
    'data',
    'item_id',
  ])
    ->condition('name', 'acquia_contenthub_export_queue')
    ->execute()
    ->fetchAll();
  if (!$queue_items) {
    return;
  }
  $exp_queue = \Drupal::queue('acquia_contenthub_publish_export');
  foreach ($queue_items as $item) {
    $data = unserialize($item->data);
    foreach ($data->data as $entity_data) {
      $new = new \stdClass();
      $new->type = $entity_data['entity_type'];
      $new->uuid = $entity_data['entity_uuid'];
      $exp_queue
        ->createItem($new);
    }
  }
  $database
    ->delete('queue')
    ->condition('name', 'acquia_contenthub_export_queue')
    ->execute();
}