Issue #2715807 by Jo Fitzgerald: Migrate D7 redirects to D8

Author: jofitz

migration_templates/d7_path_redirect.yml

@@ -0,0 +1,25 @@
+id: d7_path_redirect
+label: Path Redirect
+migration_tags:
+  - Drupal 7
+source:
+  plugin: d7_path_redirect
+process:
+  rid: rid
+  uid: uid
+  redirect_source/path: source
+  redirect_source/query:
+    plugin: d7_redirect_source_query
+    source: source_options
+  redirect_redirect/uri:
+    plugin: d7_path_redirect
+    source:
+      - redirect
+      - redirect_options
+  language:
+    plugin: default_value
+    source: language
+    default_value: und
+  status_code: status_code
+destination:
+  plugin: entity:redirect

src/Plugin/migrate/process/PathRedirect.php

@@ -44,4 +44,4 @@ public function transform($value, MigrateExecutableInterface $migrate_executable
     return $uri;
   }
 
-}
+}

src/Plugin/migrate/process/d7/PathRedirect.php

@@ -0,0 +1,51 @@
+<?php
+
+/**
+ * @file
+ * Contains \Drupal\redirect\Plugin\migrate\process\d7\PathRedirect.
+ */
+
+namespace Drupal\redirect\Plugin\migrate\process\d7;
+
+use Drupal\migrate\MigrateExecutableInterface;
+use Drupal\migrate\ProcessPluginBase;
+use Drupal\migrate\Row;
+
+/**
+ * @MigrateProcessPlugin(
+ *   id = "d7_path_redirect"
+ * )
+ */
+class PathRedirect extends ProcessPluginBase {
+
+  /**
+   * {@inheritdoc}
+   *
+   * Transform the field as required for an iFrame field.
+   */
+  public function transform($value, MigrateExecutableInterface $migrate_executable, Row $row, $destination_property) {
+
+    // Check if the url begins with http.
+    if (preg_match('#^http#', $value[0])) {
+      // Use it as is.
+      $uri = $value[0];
+    }
+    else {
+      // Make the link internal.
+      $uri = 'internal:/' . $value[0];
+    }
+
+    // Check if there are options.
+    if (!empty($value[1])) {
+      // Check if there is a query.
+      $options = unserialize($value[1]);
+      if (!empty($options['query'])) {
+        // Add it to the end of the url.
+        $uri .= '?' . http_build_query($options['query']);
+      }
+    }
+
+    return $uri;
+  }
+
+}

src/Plugin/migrate/process/d7/RedirectSourceQuery.php

@@ -0,0 +1,41 @@
+<?php
+
+/**
+ * @file
+ * Contains \Drupal\redirect\Plugin\migrate\process\d7\RedirectSourceQuery.
+ */
+
+namespace Drupal\redirect\Plugin\migrate\process\d7;
+
+use Drupal\migrate\MigrateExecutableInterface;
+use Drupal\migrate\ProcessPluginBase;
+use Drupal\migrate\Row;
+
+/**
+ * @MigrateProcessPlugin(
+ *   id = "d7_redirect_source_query"
+ * )
+ */
+class RedirectSourceQuery extends ProcessPluginBase {
+
+  /**
+   * {@inheritdoc}
+   *
+   * Transform the field as required for an iFrame field.
+   */
+  public function transform($value, MigrateExecutableInterface $migrate_executable, Row $row, $destination_property) {
+
+    // Check if there are options.
+    if (!empty($value)) {
+      // Check if there is a query.
+      $options = unserialize($value);
+      if (!empty($options['query'])) {
+        // Add it to the end of the url.
+        return serialize($options['query']);
+      }
+    }
+
+    return NULL;
+  }
+
+}

src/Plugin/migrate/source/d7/PathRedirect.php

@@ -0,0 +1,81 @@
+<?php
+
+/**
+ * @file
+ * Contains \Drupal\redirect\Plugin\migrate\source\d7\PathRedirect.
+ */
+
+namespace Drupal\redirect\Plugin\migrate\source\d7;
+
+use Drupal\migrate\Row;
+use Drupal\migrate_drupal\Plugin\migrate\source\DrupalSqlBase;
+
+/**
+ * Drupal 7 path redirect source from database.
+ *
+ * @MigrateSource(
+ *   id = "d7_path_redirect",
+ *   source_provider = "redirect"
+ * )
+ */
+class PathRedirect extends DrupalSqlBase {
+
+  /**
+   * {@inheritdoc}
+   */
+  public function query() {
+    // Select path redirects.
+    $query = $this->select('redirect', 'p')->fields('p');
+
+    return $query;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function prepareRow(Row $row) {
+    static $default_status_code;
+    if (!isset($default_status_code)) {
+      $default_status_code = unserialize($this->getDatabase()
+        ->select('variable', 'v')
+        ->fields('v', ['value'])
+        ->condition('name', 'redirect_default_status_code')
+        ->execute()
+        ->fetchField());
+    }
+    $current_status_code = $row->getSourceProperty('status_code');
+    $status_code = $current_status_code != 0 ? $current_status_code : $default_status_code;
+    $row->setSourceProperty('status_code', $status_code);
+    return parent::prepareRow($row);
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function fields() {
+    $fields = [
+      'rid' => $this->t('Redirect ID'),
+      'hash' => $this->t('Hash'),
+      'type' => $this->t('Type'),
+      'uid' => $this->t('UID'),
+      'source' => $this->t('Source'),
+      'source_options' => $this->t('Source Options'),
+      'redirect' => $this->t('Redirect'),
+      'redirect_options' => $this->t('Redirect Options'),
+      'language' => $this->t('Language'),
+      'status_code' => $this->t('Status Code'),
+      'count' => $this->t('Count'),
+      'access' => $this->t('Access'),
+    ];
+    return $fields;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function getIds() {
+    $ids['rid']['type'] = 'integer';
+    return $ids;
+  }
+
+}