class MigrateRunnerCommands extends DrushCommands implements ConfigAwareInterface (View source)

Migrate runner commands.

Traits

ConfigAwareTrait
ProcessManagerAwareTrait
LoggerAwareTrait
IO
ConfigAwareTrait

Constants

REQ

OPT

EXIT_SUCCESS

EXIT_FAILURE

EXIT_FAILURE_WITH_CLARITY

Properties

protected CommandData|null $commandData from  DrushCommands
protected KeyValueStoreInterface $keyValue

The key-value store service.

protected MigrationPluginManagerInterface|null $migrationPluginManager

Methods

bool
startBrowser(string|null $uri = null, int $sleep = 0, int|null $port = null, string|bool $browser = false)

Starts a background browser/tab for the current site or a specified URL.

static bool
programExists($program)

No description

static string
getEditor(string|null $editor = null)

No description

getConfig()

Replaces same method in ConfigAwareTrait in order to provide a DrushConfig as return type. Helps with IDE completion.

__construct(DateFormatterInterface $dateFormatter, KeyValueFactoryInterface $keyValueFactory)

No description

SymfonyStyle
io()

Override Robo's IO function with our custom style.

DrushLoggerManager|null
logger()

Returns a logger object.

void
printFile(string $file)

Print the contents of a file.

preHook(CommandData $commandData)

Persist commandData for use in primary command callback. Used by 'topic' commands.

printFileTopic(CommandData $commandData)

Print the contents of a file. The path comes from the @topic annotation.

HandlerStack
getStack()

Get a Guzzle handler stack that uses the Drush logger.

create(ContainerInterface $container)

No description

setMigrationPluginManager(MigrationPluginManagerInterface $migrationPluginManager)

Provide a migration plugin manager.

RowsOfFields
status(string|null $migrationIds = null, array $options = ['tag' => self::REQ, 'format' => 'table'])

List all migrations with current status.

int|null
getMigrationSourceRowsCount(MigrationInterface $migration)

Returns the migration source rows count.

int
getMigrationNeedingUpdateCount(MigrationInterface $migration)

Returns the number of items that needs update.

int|null
getMigrationUnprocessedCount(MigrationInterface $migration)

Returns the number of unprocessed items.

int|null
getMigrationImportedCount(MigrationInterface $migration)

Returns the number of imported items.

string
getMigrationLastImportedTime(MigrationInterface $migration)

Returns the last imported date/time if any.

array
padTableRow(array $row, array $fields)

Pads an incomplete table row with empty cells.

void
import(string|null $migrationIds = null, array $options = ['all' => false, 'tag' => self::REQ, 'limit' => self::REQ, 'feedback' => self::REQ, 'idlist' => self::REQ, 'update' => false, 'force' => false, 'execute-dependencies' => false, 'timestamp' => false, 'total' => false, 'progress' => true, 'delete' => false])

Perform one or more migration processes.

void
executeMigration(MigrationInterface $migration, string $migrationId, array $userData)

Executes a single migration.

void
rollback(string|null $migrationIds = null, array $options = ['all' => false, 'tag' => self::REQ, 'feedback' => self::REQ, 'idlist' => self::REQ, 'progress' => true])

Rollback one or more migrations.

void
stop(string $migrationId)

Stop an active migration operation.

void
resetStatus(string $migrationId)

Reset an active migration's status to idle.

RowsOfFields
messages(string $migrationId, array $options = ['idlist' => self::REQ, 'format' => 'table'])

View any messages associated with a migration.

array
preprocessMessageRow(StdClass $row, array $sourceIdKeys)

Preprocesses migrate message rows.

RowsOfFields
fieldsSource(string $migrationId, $options = ['format' => 'table'])

List the fields available for mapping in a source.

array
getMigrationList(string|null $migrationIds, string|null $tags)

Retrieves a list of active migrations.

MigrateMessageInterface
getMigrateMessage()

Returns the migrate message logger.

array
getSourceIdKeys(MigrateIdMapInterface $idMap)

Get the source ID keys.

CommandError|null
validateMigrationId(CommandData $commandData)

Validates a migration ID is valid.

Details

bool startBrowser(string|null $uri = null, int $sleep = 0, int|null $port = null, string|bool $browser = false)

Starts a background browser/tab for the current site or a specified URL.

Uses a non-blocking Process call, so Drush execution will continue.

Parameters

string|null $uri

Optional URI or site path to open in browser. If omitted, or if a site path is specified, the current site home page uri will be prepended if the site's hostname resolves.

int $sleep
int|null $port
string|bool $browser

Return Value

bool

if browser was opened. FALSE if browser was disabled by the user or a default browser could not be found.

static bool programExists($program)

No description

Parameters

$program

Return Value

bool

static string getEditor(string|null $editor = null)

No description

Parameters

string|null $editor

Return Value

string

DrushConfig getConfig()

Replaces same method in ConfigAwareTrait in order to provide a DrushConfig as return type. Helps with IDE completion.

__construct(DateFormatterInterface $dateFormatter, KeyValueFactoryInterface $keyValueFactory)

No description

Parameters

DateFormatterInterface $dateFormatter
KeyValueFactoryInterface $keyValueFactory

protected SymfonyStyle io()

Override Robo's IO function with our custom style.

Return Value

SymfonyStyle

protected DrushLoggerManager|null logger()

Returns a logger object.

Return Value

DrushLoggerManager|null

protected void printFile(string $file)

Print the contents of a file.

Parameters

string $file

Full path to a file.

Return Value

void

preHook(CommandData $commandData)

Persist commandData for use in primary command callback. Used by 'topic' commands.

Parameters

CommandData $commandData

protected printFileTopic(CommandData $commandData)

Print the contents of a file. The path comes from the @topic annotation.

Parameters

CommandData $commandData

Full path to a file.

protected HandlerStack getStack()

Get a Guzzle handler stack that uses the Drush logger.

static MigrateRunnerCommands create(ContainerInterface $container)

No description

Parameters

ContainerInterface $container

Return Value

MigrateRunnerCommands

setMigrationPluginManager(MigrationPluginManagerInterface $migrationPluginManager)

Provide a migration plugin manager.

Parameters

MigrationPluginManagerInterface $migrationPluginManager

RowsOfFields status(string|null $migrationIds = null, array $options = ['tag' => self::REQ, 'format' => 'table'])

List all migrations with current status.

Parameters

string|null $migrationIds
array $options

Return Value

RowsOfFields

protected int|null getMigrationSourceRowsCount(MigrationInterface $migration)

Returns the migration source rows count.

Parameters

MigrationInterface $migration

The migration plugin instance.

Return Value

int|null

The migration source rows count or null if the source is uncountable or the source count couldn't be retrieved.

protected int getMigrationNeedingUpdateCount(MigrationInterface $migration)

Returns the number of items that needs update.

Parameters

MigrationInterface $migration

The migration plugin instance.

Return Value

int

The number of items that needs update.

protected int|null getMigrationUnprocessedCount(MigrationInterface $migration)

Returns the number of unprocessed items.

Parameters

MigrationInterface $migration

The migration plugin instance.

Return Value

int|null

The number of unprocessed items or null if it cannot be determined.

protected int|null getMigrationImportedCount(MigrationInterface $migration)

Returns the number of imported items.

Parameters

MigrationInterface $migration

The migration plugin instance.

Return Value

int|null

The number of imported items or null if it cannot be determined.

protected string getMigrationLastImportedTime(MigrationInterface $migration)

Returns the last imported date/time if any.

Parameters

MigrationInterface $migration

The migration plugin instance.

Return Value

string

The last imported date/time if any.

protected array padTableRow(array $row, array $fields)

Pads an incomplete table row with empty cells.

Parameters

array $row

The row to be prepared.

array $fields

The table columns.

Return Value

array

The complete table row.

void import(string|null $migrationIds = null, array $options = ['all' => false, 'tag' => self::REQ, 'limit' => self::REQ, 'feedback' => self::REQ, 'idlist' => self::REQ, 'update' => false, 'force' => false, 'execute-dependencies' => false, 'timestamp' => false, 'total' => false, 'progress' => true, 'delete' => false])

Perform one or more migration processes.

Parameters

string|null $migrationIds
array $options

Return Value

void

Exceptions

Exception

protected void executeMigration(MigrationInterface $migration, string $migrationId, array $userData)

Executes a single migration.

If the --execute-dependencies option was given, the migration's dependencies will also be executed first.

Parameters

MigrationInterface $migration

The migration to execute.

string $migrationId

The migration ID (not used, just an artifact of array_walk()).

array $userData

Additional data passed to the callback.

Return Value

void

Exceptions

Exception

void rollback(string|null $migrationIds = null, array $options = ['all' => false, 'tag' => self::REQ, 'feedback' => self::REQ, 'idlist' => self::REQ, 'progress' => true])

Rollback one or more migrations.

Parameters

string|null $migrationIds
array $options

Return Value

void

Exceptions

Exception

void stop(string $migrationId)

Stop an active migration operation.

Parameters

string $migrationId

Return Value

void

Exceptions

PluginException

void resetStatus(string $migrationId)

Reset an active migration's status to idle.

Parameters

string $migrationId

Return Value

void

Exceptions

PluginException

RowsOfFields messages(string $migrationId, array $options = ['idlist' => self::REQ, 'format' => 'table'])

View any messages associated with a migration.

Parameters

string $migrationId
array $options

Return Value

RowsOfFields

Exceptions

PluginException

protected array preprocessMessageRow(StdClass $row, array $sourceIdKeys)

Preprocesses migrate message rows.

Given an item inside the list generated by MigrateIdMapInterface::getMessages(), prepare it for display.

Parameters

StdClass $row

A message to process.

array $sourceIdKeys

The source IDs keys, for reference.

Return Value

array

See also

\Drupal\migrate\Plugin\MigrateIdMapInterface::getMessages()

RowsOfFields fieldsSource(string $migrationId, $options = ['format' => 'table'])

List the fields available for mapping in a source.

Parameters

string $migrationId
$options

Return Value

RowsOfFields

Exceptions

PluginException

protected array getMigrationList(string|null $migrationIds, string|null $tags)

Retrieves a list of active migrations.

Parameters

string|null $migrationIds

A comma-separated list of migration IDs. If omitted, will return all migrations.

string|null $tags

A comma separated list of tags.

Return Value

array

An array keyed by migration tag, each value containing an array of migrations or an empty array if no migrations match the input criteria.

Exceptions

PluginException

protected MigrateMessageInterface getMigrateMessage()

Returns the migrate message logger.

Return Value

MigrateMessageInterface

The migrate message logger.

protected array getSourceIdKeys(MigrateIdMapInterface $idMap)

Get the source ID keys.

Parameters

MigrateIdMapInterface $idMap

The migration ID map.

Return Value

array

The source ID keys.

CommandError|null validateMigrationId(CommandData $commandData)

Validates a migration ID is valid.

If the argument to be validated is not named migrationId, pass the argument name as the value of the annotation.

Parameters

CommandData $commandData

Return Value

CommandError|null