Chris@0: <?php
Chris@0: 
Chris@0: namespace Drupal\migrate\Audit;
Chris@0: 
Chris@0: use Drupal\Core\StringTranslation\StringTranslationTrait;
Chris@0: use Drupal\migrate\Plugin\MigrationInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Audits migrations that create content entities in the destination system.
Chris@0:  */
Chris@0: class IdAuditor implements AuditorInterface {
Chris@0: 
Chris@0:   use StringTranslationTrait;
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function audit(MigrationInterface $migration) {
Chris@0:     // If the migration does not opt into auditing, it passes.
Chris@0:     if (!$migration->isAuditable()) {
Chris@0:       return AuditResult::pass($migration);
Chris@0:     }
Chris@0: 
Chris@0:     $interface = HighestIdInterface::class;
Chris@0: 
Chris@0:     $destination = $migration->getDestinationPlugin();
Chris@0:     if (!$destination instanceof HighestIdInterface) {
Chris@0:       throw new AuditException($migration, "Destination does not implement $interface");
Chris@0:     }
Chris@0: 
Chris@0:     $id_map = $migration->getIdMap();
Chris@0:     if (!$id_map instanceof HighestIdInterface) {
Chris@0:       throw new AuditException($migration, "ID map does not implement $interface");
Chris@0:     }
Chris@0: 
Chris@0:     if ($destination->getHighestId() > $id_map->getHighestId()) {
Chris@0:       return AuditResult::fail($migration, [
Chris@0:         $this->t('The destination system contains data which was not created by a migration.'),
Chris@0:       ]);
Chris@0:     }
Chris@0:     return AuditResult::pass($migration);
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function auditMultiple(array $migrations) {
Chris@0:     $conflicts = [];
Chris@0: 
Chris@0:     foreach ($migrations as $migration) {
Chris@0:       $migration_id = $migration->getPluginId();
Chris@0:       $conflicts[$migration_id] = $this->audit($migration);
Chris@0:     }
Chris@0:     ksort($conflicts);
Chris@0:     return $conflicts;
Chris@0:   }
Chris@0: 
Chris@0: }