Chris@0: <?php
Chris@0: 
Chris@0: /**
Chris@0:  * @file
Chris@0:  * Install, update, and uninstall functions for migrate_plus.
Chris@0:  */
Chris@0: 
Chris@0: /**
Chris@0:  * Converts 8.0.x core migration entities to 8.1.x migrate_plus entities.
Chris@0:  */
Chris@0: function migrate_plus_update_8100() {
Chris@0:   // We cannot use the configration entity system directly, because the entity
Chris@0:   // type migrate.migration.* no longer exists - we must directly manipulate
Chris@0:   // the config table.
Chris@0:   $database = \Drupal::database();
Chris@0:   $migration_config = $database->select('config', 'c')
Chris@0:     ->fields('c', ['name', 'data'])
Chris@0:     ->condition('name', 'migrate.migration.%', 'LIKE')
Chris@0:     ->execute();
Chris@0:   foreach ($migration_config as $migration) {
Chris@0:     $data = unserialize($migration->data);
Chris@0:     if (isset($data['third_party_settings']['migrate_plus']['migration_group'])) {
Chris@0:       $data['migration_group'] = $data['third_party_settings']['migrate_plus']['migration_group'];
Chris@0:       unset($data['third_party_settings']['migrate_plus']);
Chris@0:       if (empty($data['third_party_settings'])) {
Chris@0:         unset($data['third_party_settings']);
Chris@0:       }
Chris@0:       $new_name = str_replace('migrate.migration.', 'migrate_plus.migration.', $migration->name);
Chris@0:       $database->update('config')
Chris@0:         ->fields([
Chris@0:           'name' => $new_name,
Chris@0:           'data' => serialize($data),
Chris@0:         ])
Chris@0:         ->condition('name', $migration->name)
Chris@0:         ->execute();
Chris@0:     }
Chris@0:   }
Chris@0: }