function Migration::getProcessPlugins

Overrides MigrationInterface::getProcessPlugins

File

core/modules/migrate/src/Plugin/Migration.php, line 402

Class

Migration

Defines the Migration plugin.

Namespace

Code

public function getProcessPlugins(?array $process = NULL) {
    $process = isset($process) ? $this->getProcessNormalized($process) : $this->getProcess();
    $index = serialize($process);
    if (!isset($this->processPlugins[$index])) {
        $this->processPlugins[$index] = [];
        foreach ($process as $property => $configurations) {
            $this->processPlugins[$index][$property] = [];
            foreach ($configurations as $configuration) {
                if (isset($configuration['source'])) {
                    $this->processPlugins[$index][$property][] = $this->processPluginManager
                        ->createInstance('get', $configuration, $this);
                }
                // Get is already handled.
                if ($configuration['plugin'] != 'get') {
                    $this->processPlugins[$index][$property][] = $this->processPluginManager
                        ->createInstance($configuration['plugin'], $configuration, $this);
                }
                if (!$this->processPlugins[$index][$property]) {
                    throw new MigrateException("Invalid process configuration for {$property}");
                }
            }
        }
    }
    return $this->processPlugins[$index];
}