--- /dev/null
+<?php
+
+namespace Drupal\Tests\migrate_drupal\Kernel\d6;
+
+use Drupal\KernelTests\FileSystemModuleDiscoveryDataProviderTrait;
+use Drupal\migrate\Audit\AuditResult;
+use Drupal\migrate\Audit\IdAuditor;
+use Drupal\node\Entity\Node;
+use Drupal\node\Entity\NodeType;
+use Drupal\Tests\migrate_drupal\Traits\CreateTestContentEntitiesTrait;
+use Drupal\workflows\Entity\Workflow;
+
+/**
+ * Tests the migration auditor for ID conflicts.
+ *
+ * @group migrate_drupal
+ */
+class MigrateDrupal6AuditIdsTest extends MigrateDrupal6TestBase {
+
+ use FileSystemModuleDiscoveryDataProviderTrait;
+ use CreateTestContentEntitiesTrait;
+
+ /**
+ * {@inheritdoc}
+ */
+ protected function setUp() {
+ // Enable all modules.
+ self::$modules = array_keys($this->coreModuleListDataProvider());
+ parent::setUp();
+
+ // Install required entity schemas.
+ $this->installEntitySchemas();
+
+ // Install required schemas.
+ $this->installSchema('book', ['book']);
+ $this->installSchema('dblog', ['watchdog']);
+ $this->installSchema('forum', ['forum_index']);
+ $this->installSchema('node', ['node_access']);
+ $this->installSchema('search', ['search_dataset']);
+ $this->installSchema('system', ['sequences']);
+ $this->installSchema('tracker', ['tracker_node', 'tracker_user']);
+
+ // Enable content moderation for nodes of type page.
+ $this->installEntitySchema('content_moderation_state');
+ $this->installConfig('content_moderation');
+ NodeType::create(['type' => 'page'])->save();
+ $workflow = Workflow::load('editorial');
+ $workflow->getTypePlugin()->addEntityTypeAndBundle('node', 'page');
+ $workflow->save();
+ }
+
+ /**
+ * Tests multiple migrations to the same destination with no ID conflicts.
+ */
+ public function testMultipleMigrationWithoutIdConflicts() {
+ // Create a node of type page.
+ $node = Node::create(['type' => 'page', 'title' => 'foo']);
+ $node->moderation_state->value = 'published';
+ $node->save();
+
+ // Insert data in the d6_node:page migration mappping table to simulate a
+ // previously migrated node.
+ $table_name = $this->getMigration('d6_node:page')->getIdMap()->mapTableName();
+ $this->container->get('database')->insert($table_name)
+ ->fields([
+ 'source_ids_hash' => 1,
+ 'sourceid1' => 1,
+ 'destid1' => 1,
+ ])
+ ->execute();
+
+ // Audit the IDs of the d6_node migrations for the page & article node type.
+ // There should be no conflicts since the highest destination ID should be
+ // equal to the highest migrated ID, as found in the aggregated mapping
+ // tables of the two node migrations.
+ $migrations = [
+ $this->getMigration('d6_node:page'),
+ $this->getMigration('d6_node:article'),
+ ];
+
+ $results = (new IdAuditor())->auditMultiple($migrations);
+ /** @var \Drupal\migrate\Audit\AuditResult $result */
+ foreach ($results as $result) {
+ $this->assertInstanceOf(AuditResult::class, $result);
+ $this->assertTrue($result->passed());
+ }
+ }
+
+ /**
+ * Tests all migrations with no ID conflicts.
+ */
+ public function testAllMigrationsWithNoIdConflicts() {
+ $migrations = $this->container
+ ->get('plugin.manager.migration')
+ ->createInstancesByTag('Drupal 6');
+
+ // Audit all Drupal 6 migrations that support it. There should be no
+ // conflicts since no content has been created.
+ $results = (new IdAuditor())->auditMultiple($migrations);
+ /** @var \Drupal\migrate\Audit\AuditResult $result */
+ foreach ($results as $result) {
+ $this->assertInstanceOf(AuditResult::class, $result);
+ $this->assertTrue($result->passed());
+ }
+ }
+
+ /**
+ * Tests all migrations with ID conflicts.
+ */
+ public function testAllMigrationsWithIdConflicts() {
+ // Get all Drupal 6 migrations.
+ $migrations = $this->container
+ ->get('plugin.manager.migration')
+ ->createInstancesByTag('Drupal 6');
+
+ // Create content.
+ $this->createContent();
+
+ // Audit the IDs of all migrations. There should be conflicts since content
+ // has been created.
+ $conflicts = array_map(
+ function (AuditResult $result) {
+ return $result->passed() ? NULL : $result->getMigration()->getBaseId();
+ },
+ (new IdAuditor())->auditMultiple($migrations)
+ );
+
+ $expected = [
+ 'd6_aggregator_feed',
+ 'd6_aggregator_item',
+ 'd6_comment',
+ 'd6_custom_block',
+ 'd6_file',
+ 'd6_menu_links',
+ 'd6_node',
+ 'd6_node_revision',
+ 'd6_taxonomy_term',
+ 'd6_term_node_revision',
+ 'd6_user',
+ ];
+ $this->assertEmpty(array_diff(array_filter($conflicts), $expected));
+ }
+
+ /**
+ * Tests draft revisions ID conflicts.
+ */
+ public function testDraftRevisionIdConflicts() {
+ // Create a published node of type page.
+ $node = Node::create(['type' => 'page', 'title' => 'foo']);
+ $node->moderation_state->value = 'published';
+ $node->save();
+
+ // Create a draft revision.
+ $node->moderation_state->value = 'draft';
+ $node->setNewRevision(TRUE);
+ $node->save();
+
+ // Insert data in the d6_node_revision:page migration mappping table to
+ // simulate a previously migrated node revison.
+ $table_name = $this->getMigration('d6_node_revision:page')->getIdMap()->mapTableName();
+ $this->container->get('database')->insert($table_name)
+ ->fields([
+ 'source_ids_hash' => 1,
+ 'sourceid1' => 1,
+ 'destid1' => 1,
+ ])
+ ->execute();
+
+ // Audit the IDs of the d6_node_revision migration. There should be
+ // conflicts since a draft revision has been created.
+ /** @var \Drupal\migrate\Audit\AuditResult $result */
+ $result = (new IdAuditor())->audit($this->getMigration('d6_node_revision:page'));
+ $this->assertInstanceOf(AuditResult::class, $result);
+ $this->assertFalse($result->passed());
+ }
+
+ /**
+ * Tests ID conflicts for inaccessible nodes.
+ */
+ public function testNodeGrantsIdConflicts() {
+ // Enable the node_test module to restrict access to page nodes.
+ $this->enableModules(['node_test']);
+
+ // Create a published node of type page.
+ $node = Node::create(['type' => 'page', 'title' => 'foo']);
+ $node->moderation_state->value = 'published';
+ $node->save();
+
+ // Audit the IDs of the d6_node migration. There should be conflicts
+ // even though the new node is not accessible.
+ /** @var \Drupal\migrate\Audit\AuditResult $result */
+ $result = (new IdAuditor())->audit($this->getMigration('d6_node:page'));
+ $this->assertInstanceOf(AuditResult::class, $result);
+ $this->assertFalse($result->passed());
+ }
+
+}
projects / yaffs-website / blobdiff