Add migration manager, which will clean up migrations records in orde…

…r to keep everything in clean state.

modules/newsroom_connector_country/newsroom_connector_country.module

@@ -0,0 +1,19 @@
+<?php
+
+/**
+ * @file
+ * Provides newsroom_connector_country functionality.
+ */
+
+use Drupal\newsroom_connector_country\Plugin\newsroom\NewsroomCountryNewsroomProcessor;
+
+/**
+ * Implements hook_entity_delete().
+ */
+function newsroom_connector_country_taxonomy_term_delete(Drupal\Core\Entity\EntityInterface $entity) {
+  if ($entity->bundle() == 'newsroom_country') {
+    // Clean up migrations.
+    \Drupal::service('newsroom_connector.migration_manager')->cleanUpMigrations(NewsroomCountryNewsroomProcessor::MIGRATION_COUNTRY, $entity);
+  }
+}
+

modules/newsroom_connector_country/src/Plugin/newsroom/NewsroomCountryNewsroomProcessor.php

@@ -22,4 +22,6 @@
  */
 class NewsroomCountryNewsroomProcessor extends NewsroomProcessorBase {
 
+  const MIGRATION_COUNTRY = 'newsroom_country';
+
 }

modules/newsroom_connector_item/newsroom_connector_item.module

@@ -1,12 +1,18 @@
 <?php
 
+/**
+ * @file
+ * Provides newsroom_connector_item functionality.
+ */
+
 use Drupal\migrate\Plugin\MigrationInterface;
 use Drupal\migrate\Plugin\MigrateSourceInterface;
 use Drupal\migrate\Row;
 use Drupal\Core\Link;
 use Drupal\Core\Entity\EntityInterface;
 use Drupal\Core\Entity\Display\EntityViewDisplayInterface;
 use Drupal\Core\Url;
+use Drupal\newsroom_connector_item\Plugin\newsroom\NewsroomItemNewsroomProcessor;
 
 /**
  * Implements hook_migrate_prepare_row().
@@ -138,9 +144,22 @@ function newsroom_connector_item_node_view(
 /**
  * Implements hook_entity_delete().
  */
-function newsroom_connector_item_node_delete(Drupal\Core\Entity\EntityInterface $entity) {
+function newsroom_connector_item_node_delete(EntityInterface $entity) {
   if ($entity->bundle() == 'newsroom_item') {
-    if ($media = \Drupal::service('entity_type.manager')->getStorage('media')->load($entity->field_newsroom_image->target_id)) {
+
+    // Clean up migrations.
+    $migration_manager = \Drupal::service('newsroom_connector.migration_manager');
+    $migration_manager->cleanUpMigrations(NewsroomItemNewsroomProcessor::MIGRATION_ITEM, $entity);
+
+    // Remove media.
+    if ($media = $entity->field_newsroom_image->entity) {
+
+      // Clean up migrations.
+      $migration_manager->cleanUpMigrations(NewsroomItemNewsroomProcessor::MIGRATION_ITEM_IMAGE_MEDIA, $media);
+      if ($file = $media->field_media_image_newsroom->entity) {
+        $migration_manager->cleanUpMigrations(NewsroomItemNewsroomProcessor::MIGRATION_ITEM_IMAGE, $file);
+      }
+
       $media->delete();
     }
   }

modules/newsroom_connector_item/src/Plugin/newsroom/NewsroomItemNewsroomProcessor.php

@@ -24,4 +24,8 @@
  */
 class NewsroomItemNewsroomProcessor extends NewsroomProcessorBase {
 
+  // Newsroom item importers.
+  const MIGRATION_ITEM = 'newsroom_item';
+  const MIGRATION_ITEM_IMAGE_MEDIA = 'newsroom_item_image_media';
+  const MIGRATION_ITEM_IMAGE = 'newsroom_item_image';
 }

modules/newsroom_connector_media/newsroom_connector_media.module

@@ -5,7 +5,7 @@
  */
 function newsroom_connector_media_media_delete(Drupal\Core\Entity\EntityInterface $entity) {
   if ($entity->bundle() == 'newsroom_image') {
-    if ($file = \Drupal::service('entity_type.manager')->getStorage('file')->load($entity->field_media_image_newsroom->target_id)) {
+    if ($file = $entity->field_media_image_newsroom->entity) {
       $file->delete();
     }
   }

modules/newsroom_connector_service/newsroom_connector_service.module

@@ -1,11 +1,26 @@
 <?php
 
+/**
+ * @file
+ * Provides newsroom_connector_service functionality.
+ */
+
+use Drupal\newsroom_connector_service\Plugin\newsroom\NewsroomServiceNewsroomProcessor;
+
 /**
  * Implements hook_entity_delete().
  */
 function newsroom_connector_service_taxonomy_term_delete(Drupal\Core\Entity\EntityInterface $entity) {
   if ($entity->bundle() == 'newsroom_service') {
-    if ($media = \Drupal::service('entity_type.manager')->getStorage('media')->load($entity->field_newsroom_service_image->target_id)) {
+    // Clean up migrations.
+    $migration_manager = \Drupal::service('newsroom_connector.migration_manager');
+    $migration_manager->cleanUpMigrations(NewsroomServiceNewsroomProcessor::MIGRATION_SERVICE, $entity);
+
+    if ($media = $entity->field_newsroom_service_image->entity) {
+      $migration_manager->cleanUpMigrations(NewsroomServiceNewsroomProcessor::MIGRATION_SERVICE_IMAGE_MEDIA, $media);
+      if ($file = $media->field_media_image_newsroom->entity) {
+        $migration_manager->cleanUpMigrations(NewsroomServiceNewsroomProcessor::MIGRATION_SERVICE_IMAGE, $file);
+      }
       $media->delete();
     }
   }

modules/newsroom_connector_service/src/Plugin/newsroom/NewsroomServiceNewsroomProcessor.php

@@ -24,4 +24,8 @@
  */
 class NewsroomServiceNewsroomProcessor extends NewsroomProcessorBase {
 
+  const MIGRATION_SERVICE = 'newsroom_service';
+  const MIGRATION_SERVICE_IMAGE_MEDIA = 'newsroom_service_logo_media';
+  const MIGRATION_SERVICE_IMAGE = 'newsroom_service_logo';
+
 }

modules/newsroom_connector_team_responsible/newsroom_connector_team_responsible.module

@@ -0,0 +1,19 @@
+<?php
+
+/**
+ * @file
+ * Provides newsroom_connector_team_responsible functionality.
+ */
+
+use Drupal\newsroom_connector_team_responsible\Plugin\newsroom\NewsroomTeamResponsibleNewsroomProcessor;
+
+/**
+ * Implements hook_entity_delete().
+ */
+function newsroom_connector_team_responsible_taxonomy_term_delete(Drupal\Core\Entity\EntityInterface $entity) {
+  if ($entity->bundle() == 'newsroom_team_responsible') {
+    // Clean up migrations.
+    \Drupal::service('newsroom_connector.migration_manager')->cleanUpMigrations(NewsroomTeamResponsibleNewsroomProcessor::MIGRATION_TEAM_RESPONSIBLE, $entity);
+  }
+}
+

modules/newsroom_connector_team_responsible/src/Plugin/newsroom/NewsroomTeamResponsibleNewsroomProcessor.php

@@ -22,4 +22,5 @@
  */
 class NewsroomTeamResponsibleNewsroomProcessor extends NewsroomProcessorBase {
 
+  const MIGRATION_TEAM_RESPONSIBLE = 'team_responsible';
 }

modules/newsroom_connector_topic/newsroom_connector_topic.module

@@ -0,0 +1,19 @@
+<?php
+
+/**
+ * @file
+ * Provides newsroom_connector_topic functionality.
+ */
+
+use Drupal\newsroom_connector_topic\Plugin\newsroom\NewsroomTopicNewsroomProcessor;
+
+/**
+ * Implements hook_entity_delete().
+ */
+function newsroom_connector_topic_taxonomy_term_delete(Drupal\Core\Entity\EntityInterface $entity) {
+  if ($entity->bundle() == 'newsroom_topic') {
+    // Clean up migrations.
+    \Drupal::service('newsroom_connector.migration_manager')->cleanUpMigrations(NewsroomTopicNewsroomProcessor::MIGRATION_TOPIC, $entity);
+  }
+}
+

modules/newsroom_connector_topic/src/Plugin/newsroom/NewsroomTopicNewsroomProcessor.php

@@ -22,4 +22,6 @@
  */
 class NewsroomTopicNewsroomProcessor extends NewsroomProcessorBase {
 
+  const MIGRATION_TOPIC = 'newsroom_topic';
+
 }

modules/newsroom_connector_type/newsroom_connector_type.module

@@ -5,16 +5,14 @@
  * Provides newsroom_connector_type functionality.
  */
 
-use Drupal\Core\Routing\RouteMatchInterface;
+use Drupal\newsroom_connector_type\Plugin\newsroom\NewsroomTypeNewsroomProcessor;
 
 /**
- * Implements hook_help().
+ * Implements hook_entity_delete().
  */
-function newsroom_connector_type_help($route_name, RouteMatchInterface $route_match) {
-  if ($route_name == 'help.page.token') {
-    $output = '<h3>' . t('About') . '</h3>';
-    $output .= '<p>' . t('The <a href=":project">Newsroom Connector Type</a> module provides a newsroom item taxonomy vocabulary and importer for it. This module is part of newsroom connector') . '</p>';
-    $output .= '<dl>';
-    return $output;
+function newsroom_connector_type_taxonomy_term_delete(Drupal\Core\Entity\EntityInterface $entity) {
+  if ($entity->bundle() == 'newsroom_type') {
+    // Clean up migrations.
+    \Drupal::service('newsroom_connector.migration_manager')->cleanUpMigrations(NewsroomTypeNewsroomProcessor::MIGRATION_TYPE, $entity);
   }
 }

modules/newsroom_connector_type/src/Plugin/newsroom/NewsroomTypeNewsroomProcessor.php

@@ -22,4 +22,6 @@
  */
 class NewsroomTypeNewsroomProcessor extends NewsroomProcessorBase {
 
+  // Newsroom type importer.
+  const MIGRATION_TYPE = 'newsroom_type';
 }

newsroom_connector.services.yml

@@ -4,6 +4,10 @@ services:
     arguments: ['@config.factory']
     class: Drupal\newsroom_connector\UniverseManager
 
+  newsroom_connector.migration_manager:
+    arguments: [ '@plugin.manager.migration', '@language_manager' ]
+    class: Drupal\newsroom_connector\MigrationManager
+
   newsroom_connector.plugin.manager.newsroom_processor:
     class: Drupal\newsroom_connector\Plugin\NewsroomProcessorManager
     parent: default_plugin_manager

src/MigrationManager.php

@@ -0,0 +1,87 @@
+<?php
+
+namespace Drupal\newsroom_connector;
+
+use Drupal\Core\Entity\ContentEntityInterface;
+use Drupal\Core\Language\LanguageManagerInterface;
+use Drupal\migrate\Plugin\MigrationPluginManager;
+
+class MigrationManager implements MigrationManagerInterface {
+
+  /**
+   * Migration plugin manager service.
+   *
+   * @var \Drupal\migrate\Plugin\MigrationPluginManager
+   */
+  protected $migrationPluginManager;
+
+  /**
+   * @var \Drupal\Core\Language\LanguageManagerInterface
+   */
+  protected $languageManager;
+
+  /**
+   * {@inheritdoc}
+   */
+  public function __construct(MigrationPluginManager $migrationPluginManager, LanguageManagerInterface $languageManager) {
+    $this->migrationPluginManager = $migrationPluginManager;
+    $this->languageManager = $languageManager;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function cleanUpMigrations($migration_id, ContentEntityInterface $entity) {
+    $id = $entity->getEntityType()->getKey('id');
+    $destination_keys = [];
+    $destination_keys[$id] = $entity->id();
+    $this->deleteDestination($migration_id, $destination_keys);
+
+    // Run cleanup for translations' migrations.
+    $languages = $this->languageManager->getLanguages();
+    foreach ($languages as $language) {
+      $destination_keys['langcode'] = $language->getId();
+      $this->deleteDestination($this->getTranslationMigrationId($migration_id, $language->getId()), $destination_keys);
+    }
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function normalizeLanguage($language_id) {
+    // For languages pt-pt, we take the first part only.
+    if (strpos($language_id, '-') !== FALSE) {
+      $parts = explode('-', $language_id);
+      $language_id = $parts[0];
+    }
+
+    return $language_id;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function getTranslationMigrationId($migration_id, $language_id) {
+    $language_id = $this->normalizeLanguage($language_id);
+    return "{$migration_id}_translations:{$language_id}";
+  }
+
+  /**
+   * Delete migration records based on keys.
+   *
+   * @param string $migration_id
+   *  Migration id.
+   * @param array $destination_keys
+   *  Destination keys.
+   */
+  protected function deleteDestination($migration_id, array $destination_keys) {
+    $migration = $this->migrationPluginManager->createInstance($migration_id);
+    if (empty($migration)) {
+      return;
+    }
+    /** @var \Drupal\migrate\Plugin\MigrateIdMapInterface $id_map */
+    $id_map = $migration->getIdMap();
+    $id_map->deleteDestination($destination_keys);
+  }
+
+}

src/MigrationManagerInterface.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Drupal\newsroom_connector;
+
+use Drupal\Core\Entity\ContentEntityInterface;
+
+interface MigrationManagerInterface {
+
+  /**
+   * Clean migration records for a deleted entity.
+   *
+   * @param string $migration_id
+   *   Migration id
+   * @param \Drupal\Core\Entity\ContentEntityInterface $entity
+   *   Deleted entity.
+   */
+  public function cleanUpMigrations($migration_id, ContentEntityInterface $entity);
+
+  /**
+   * Normalize language to newsroom format.
+   *
+   * @param string $language_id
+   *   Language id.
+   * @return string
+   *   Normalized language.
+   */
+  public function normalizeLanguage($language_id);
+
+  /**
+   * Get migration id for translations.
+   *
+   * @param string $migration_id
+   *   Plugin id
+   * @param string $language_id
+   *   Language id.
+   *
+   * @return string
+   *   Translation migration id.
+   */
+  public function getTranslationMigrationId($migration_id, $language_id);
+
+}