function MigrateEventsTest::testMigrateEvents

Tests migration events.

File

core/modules/migrate/tests/src/Kernel/MigrateEventsTest.php, line 58

Class

MigrateEventsTest

Tests events fired on migrations.

Namespace

Code

public function testMigrateEvents() {
    // Run a simple little migration, which should trigger one of each event
    // other than map_delete.
    $definition = [
        'migration_tags' => [
            'Event test',
        ],
        'source' => [
            'plugin' => 'embedded_data',
            'data_rows' => [
                [
                    'data' => 'dummy value',
                ],
            ],
            'ids' => [
                'data' => [
                    'type' => 'string',
                ],
            ],
        ],
        'process' => [
            'value' => 'data',
        ],
        'destination' => [
            'plugin' => 'dummy',
        ],
    ];
    $migration = \Drupal::service('plugin.manager.migration')->createStubMigration($definition);
    $executable = new MigrateExecutable($migration);
    // As the import runs, events will be dispatched, recording the received
    // information in state.
    $executable->import();
    // Validate from the recorded state that the events were received.
    $event = $this->state
        ->get('migrate_events_test.pre_import_event', []);
    $this->assertIdentical($event['event_name'], MigrateEvents::PRE_IMPORT);
    $this->assertIdentical($event['migration']->id(), $migration->id());
    $event = $this->state
        ->get('migrate_events_test.post_import_event', []);
    $this->assertIdentical($event['event_name'], MigrateEvents::POST_IMPORT);
    $this->assertIdentical($event['migration']->id(), $migration->id());
    $event = $this->state
        ->get('migrate_events_test.map_save_event', []);
    $this->assertIdentical($event['event_name'], MigrateEvents::MAP_SAVE);
    // Validating the last row processed.
    $this->assertIdentical($event['fields']['sourceid1'], 'dummy value');
    $this->assertIdentical($event['fields']['destid1'], 'dummy value');
    $this->assertIdentical($event['fields']['source_row_status'], 0);
    $event = $this->state
        ->get('migrate_events_test.map_delete_event', []);
    $this->assertIdentical($event, []);
    $event = $this->state
        ->get('migrate_events_test.pre_row_save_event', []);
    $this->assertIdentical($event['event_name'], MigrateEvents::PRE_ROW_SAVE);
    $this->assertIdentical($event['migration']->id(), $migration->id());
    // Validating the last row processed.
    $this->assertIdentical($event['row']->getSourceProperty('data'), 'dummy value');
    $event = $this->state
        ->get('migrate_events_test.post_row_save_event', []);
    $this->assertIdentical($event['event_name'], MigrateEvents::POST_ROW_SAVE);
    $this->assertIdentical($event['migration']->id(), $migration->id());
    // Validating the last row processed.
    $this->assertIdentical($event['row']->getSourceProperty('data'), 'dummy value');
    $this->assertIdentical($event['destination_id_values']['value'], 'dummy value');
    // Generate a map delete event.
    $migration->getIdMap()
        ->delete([
        'data' => 'dummy value',
    ]);
    $event = $this->state
        ->get('migrate_events_test.map_delete_event', []);
    $this->assertIdentical($event['event_name'], MigrateEvents::MAP_DELETE);
    $this->assertIdentical($event['source_id'], [
        'data' => 'dummy value',
    ]);
}