function MigrateExecutable::import

Overrides MigrateExecutableInterface::import

File

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

Class

MigrateExecutable

Defines a migrate executable class.

Namespace

Code

public function import() {
    // Only begin the import operation if the migration is currently idle.
    if ($this->migration
        ->getStatus() !== MigrationInterface::STATUS_IDLE) {
        $this->message
            ->display($this->t('Migration @id is busy with another operation: @status', [
            '@id' => $this->migration
                ->id(),
            '@status' => $this->t($this->migration
                ->getStatusLabel()),
        ]), 'error');
        return MigrationInterface::RESULT_FAILED;
    }
    $this->getEventDispatcher()
        ->dispatch(new MigrateImportEvent($this->migration, $this->message), MigrateEvents::PRE_IMPORT);
    // Knock off migration if the requirements haven't been met.
    try {
        $this->migration
            ->checkRequirements();
    } catch (RequirementsException $e) {
        $this->message
            ->display($this->t('Migration @id did not meet the requirements. @message', [
            '@id' => $this->migration
                ->id(),
            '@message' => $e->getMessage(),
        ]), 'error');
        return MigrationInterface::RESULT_FAILED;
    }
    $this->migration
        ->setStatus(MigrationInterface::STATUS_IMPORTING);
    $source = $this->getSource();
    try {
        $source->rewind();
    } catch (\Exception $e) {
        $this->message
            ->display($this->t('Migration failed with source plugin exception: @e in @file line @line', [
            '@e' => $e->getMessage(),
            '@file' => $e->getFile(),
            '@line' => $e->getLine(),
        ]), 'error');
        $this->migration
            ->setStatus(MigrationInterface::STATUS_IDLE);
        return MigrationInterface::RESULT_FAILED;
    }
    // Get the process pipeline.
    $pipeline = FALSE;
    if ($source->valid()) {
        try {
            $pipeline = $this->migration
                ->getProcessPlugins();
        } catch (MigrateException $e) {
            $row = $source->current();
            $this->sourceIdValues = $row->getSourceIdValues();
            $this->getIdMap()
                ->saveIdMapping($row, [], $e->getStatus());
            $this->saveMessage($e->getMessage(), $e->getLevel());
        }
    }
    $return = MigrationInterface::RESULT_COMPLETED;
    if ($pipeline) {
        $id_map = $this->getIdMap();
        $destination = $this->migration
            ->getDestinationPlugin();
        while ($source->valid()) {
            $row = $source->current();
            $this->sourceIdValues = $row->getSourceIdValues();
            try {
                foreach ($pipeline as $destination_property_name => $plugins) {
                    $this->processPipeline($row, $destination_property_name, $plugins, NULL);
                }
                $save = TRUE;
            } catch (MigrateException $e) {
                $this->getIdMap()
                    ->saveIdMapping($row, [], $e->getStatus());
                $msg = sprintf("%s:%s:%s", $this->migration
                    ->getPluginId(), $destination_property_name, $e->getMessage());
                $this->saveMessage($msg, $e->getLevel());
                $save = FALSE;
            } catch (MigrateSkipRowException $e) {
                if ($e->getSaveToMap()) {
                    $id_map->saveIdMapping($row, [], MigrateIdMapInterface::STATUS_IGNORED);
                }
                if ($message = trim($e->getMessage())) {
                    $msg = sprintf("%s:%s: %s", $this->migration
                        ->getPluginId(), $destination_property_name, $message);
                    $this->saveMessage($msg, MigrationInterface::MESSAGE_INFORMATIONAL);
                }
                $save = FALSE;
            }
            if ($save) {
                try {
                    $this->getEventDispatcher()
                        ->dispatch(new MigratePreRowSaveEvent($this->migration, $this->message, $row), MigrateEvents::PRE_ROW_SAVE);
                    $destination_ids = $id_map->lookupDestinationIds($this->sourceIdValues);
                    $destination_id_values = $destination_ids ? reset($destination_ids) : [];
                    $destination_id_values = $destination->import($row, $destination_id_values);
                    $this->getEventDispatcher()
                        ->dispatch(new MigratePostRowSaveEvent($this->migration, $this->message, $row, $destination_id_values), MigrateEvents::POST_ROW_SAVE);
                    if ($destination_id_values) {
                        // We do not save an idMap entry for config.
                        if ($destination_id_values !== TRUE) {
                            $id_map->saveIdMapping($row, $destination_id_values, $this->sourceRowStatus, $destination->rollbackAction());
                        }
                    }
                    else {
                        $id_map->saveIdMapping($row, [], MigrateIdMapInterface::STATUS_FAILED);
                        if (!$id_map->messageCount()) {
                            $message = $this->t('New object was not saved, no error provided');
                            $this->saveMessage($message);
                            $this->message
                                ->display($message);
                        }
                    }
                } catch (MigrateException $e) {
                    $this->getIdMap()
                        ->saveIdMapping($row, [], $e->getStatus());
                    $this->saveMessage($e->getMessage(), $e->getLevel());
                } catch (\Exception $e) {
                    $this->getIdMap()
                        ->saveIdMapping($row, [], MigrateIdMapInterface::STATUS_FAILED);
                    $this->handleException($e);
                }
            }
            $this->sourceRowStatus = MigrateIdMapInterface::STATUS_IMPORTED;
            // Check for memory exhaustion.
            if (($return = $this->checkStatus()) != MigrationInterface::RESULT_COMPLETED) {
                break;
            }
            // If anyone has requested we stop, return the requested result.
            if ($this->migration
                ->getStatus() == MigrationInterface::STATUS_STOPPING) {
                $return = $this->migration
                    ->getInterruptionResult();
                $this->migration
                    ->clearInterruptionResult();
                break;
            }
            try {
                $source->next();
            } catch (\Exception $e) {
                $this->message
                    ->display($this->t('Migration failed with source plugin exception: @e in @file line @line', [
                    '@e' => $e->getMessage(),
                    '@file' => $e->getFile(),
                    '@line' => $e->getLine(),
                ]), 'error');
                $this->migration
                    ->setStatus(MigrationInterface::STATUS_IDLE);
                return MigrationInterface::RESULT_FAILED;
            }
        }
    }
    $this->getEventDispatcher()
        ->dispatch(new MigrateImportEvent($this->migration, $this->message), MigrateEvents::POST_IMPORT);
    $this->migration
        ->setStatus(MigrationInterface::STATUS_IDLE);
    return $return;
}