From 7156a490b2a36db714a9d4a0ad784e060dbef9e2 Mon Sep 17 00:00:00 2001
From: Chintan Desai <chintan@wezbyte.com>
Date: Tue, 15 Feb 2022 18:44:20 +0000
Subject: [PATCH] Adds event subscriber for post migration operations.

---
 cdesai_migrate.services.yml                   |  5 +++
 .../DemoPostMigrationSubscriber.php           | 40 +++++++++++++++++++
 2 files changed, 45 insertions(+)
 create mode 100644 cdesai_migrate.services.yml
 create mode 100644 src/EventSubscriber/DemoPostMigrationSubscriber.php

diff --git a/cdesai_migrate.services.yml b/cdesai_migrate.services.yml
new file mode 100644
index 0000000..376a508
--- /dev/null
+++ b/cdesai_migrate.services.yml
@@ -0,0 +1,5 @@
+services:
+  post_migration_subscriber:
+    class: '\Drupal\cdesai_migrate\EventSubscriber\DemoPostMigrationSubscriber'
+    tags:
+      - { name: 'event_subscriber' }
diff --git a/src/EventSubscriber/DemoPostMigrationSubscriber.php b/src/EventSubscriber/DemoPostMigrationSubscriber.php
new file mode 100644
index 0000000..e5fdcb0
--- /dev/null
+++ b/src/EventSubscriber/DemoPostMigrationSubscriber.php
@@ -0,0 +1,40 @@
+<?php
+
+namespace Drupal\cdesai_migrate\EventSubscriber;
+
+use Drupal\migrate\Event\MigrateEvents;
+use Drupal\migrate\Event\MigratePostRowSaveEvent;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+/**
+ * Class PostMigrationSubscriber.
+ *
+ * Run our user flagging after the last node migration is run.
+ *
+ * @package Drupal\YOUR_MODULE
+ */
+class DemoPostMigrationSubscriber implements EventSubscriberInterface {
+
+  /**
+   * Get subscribed events.
+   *
+   * @inheritdoc
+   */
+  public static function getSubscribedEvents(): array {
+    $events[MigrateEvents::POST_ROW_SAVE][] = ['onMigratePostImport'];
+    return $events;
+  }
+
+  /**
+   * Callback for MigrateEvents::POST_ROW_SAVE event.
+   *
+   * @param \Drupal\migrate\Event\MigratePostRowSaveEvent $event
+   *   The import event object.
+   */
+  public function onMigratePostImport(MigratePostRowSaveEvent $event) {
+    if ($event->getMigration()->getBaseId() == 'cdesai_basic_pages') {
+      // CODE REDACTED
+    }
+  }
+
+}