function MigrateExecutable::processRow

Overrides MigrateExecutableInterface::processRow

File

core/modules/migrate/src/MigrateExecutable.php, line 369

Class

MigrateExecutable

Defines a migrate executable class.

Namespace

Code

public function processRow(Row $row, array $process = NULL, $value = NULL) {
    foreach ($this->migration
        ->getProcessPlugins($process) as $destination => $plugins) {
        $multiple = FALSE;
        
        /** @var $plugin \Drupal\migrate\Plugin\MigrateProcessInterface */
        foreach ($plugins as $plugin) {
            $definition = $plugin->getPluginDefinition();
            // Many plugins expect a scalar value but the current value of the
            // pipeline might be multiple scalars (this is set by the previous
            // plugin) and in this case the current value needs to be iterated
            // and each scalar separately transformed.
            if ($multiple && !$definition['handle_multiples']) {
                $new_value = [];
                if (!is_array($value)) {
                    throw new MigrateException(sprintf('Pipeline failed at %s plugin for destination %s: %s received instead of an array,', $plugin->getPluginId(), $destination, $value));
                }
                $break = FALSE;
                foreach ($value as $scalar_value) {
                    try {
                        $new_value[] = $plugin->transform($scalar_value, $this, $row, $destination);
                    } catch (MigrateSkipProcessException $e) {
                        $new_value[] = NULL;
                        $break = TRUE;
                    }
                }
                $value = $new_value;
                if ($break) {
                    break;
                }
            }
            else {
                try {
                    $value = $plugin->transform($value, $this, $row, $destination);
                } catch (MigrateSkipProcessException $e) {
                    $value = NULL;
                    break;
                }
                $multiple = $plugin->multiple();
            }
        }
        // Ensure all values, including nulls, are migrated.
        if ($plugins) {
            if (isset($value)) {
                $row->setDestinationProperty($destination, $value);
            }
            else {
                $row->setEmptyDestinationProperty($destination);
            }
        }
        // Reset the value.
        $value = NULL;
    }
}