marketo_ma-8.x-2.x-dev/modules/marketo_ma_webform/marketo_ma_webform.module

<?php

/**
 * @file
 * Sends webform submissions to Marketo MA.
 */

use Drupal\migrate\Plugin\MigrationInterface;
use Drupal\migrate\Row;
use Drupal\webform_migrate\Plugin\migrate\source\d7\D7Webform;

/**
 * Implements hook_theme().
 */
function marketo_ma_webform_theme() {
  $info = [
    'webform_handler_marketo_ma_summary' => [
      'variables' => [
        'settings' => NULL,
        'handler' => [],
      ],
    ],
  ];
  return $info;
}

/**
 * Implements hook_migrate_MIGRATION_ID_prepare_row().
 */
function marketo_ma_webform_migrate_upgrade_d7_webform_prepare_row(Row $row, D7Webform $source, MigrationInterface $migration) {
  static $map = [];
  $nid = $row->getSourceProperty('nid');
  try {
    $results = $source->getDatabase()->query('SELECT options, form_key, marketo_ma_key FROM {marketo_ma_webform} INNER JOIN {marketo_ma_webform_component} USING(nid) INNER JOIN {webform_component} USING(nid,cid) WHERE nid = :nid', [':nid' => $nid]);
  }
  catch (\Exception $e) {
    return;
  }
  $settings = [];
  if (!$map) {
    // D7 didn't have REST support so map from SOAP to REST.
    foreach (\Drupal::service('marketo_ma')->getAvailableFields() as $restField => $data) {
      $map[$data['soapName']] = $restField;
    }
  }
  foreach ($results->fetchAll(\PDO::FETCH_ASSOC) as $result) {
    if (!isset($settings['formid'])) {
      $options = unserialize($result['options'], ['allowed_classes' => FALSE]);
      $settings['formid'] = $options['formid'];
    }
    $settings['marketo_ma_mapping'][$result['form_key']] = $map[$result['marketo_ma_key']];
  }
  $handlers = $row->getSourceProperty('handlers');
  $handlers['marketo_ma'] = [
    'id' => 'marketo_ma',
    'label' => 'Marketo MA',
    'handler_id' => 'marketo_ma',
    'status' => TRUE,
    'conditions' => [],
    'weight' => 0,
    'settings' => $settings,
  ];
  $row->setSourceProperty('handlers', $handlers);
}