Chris@0
|
1 <?php
|
Chris@0
|
2
|
Chris@0
|
3 namespace Drupal\Tests\migrate\Kernel;
|
Chris@0
|
4
|
Chris@0
|
5 use Drupal\migrate\Event\MigratePostRowSaveEvent;
|
Chris@0
|
6 use Drupal\migrate\Plugin\MigrationInterface;
|
Chris@0
|
7 use Drupal\migrate\Event\MigrateEvents;
|
Chris@0
|
8 use Drupal\migrate\MigrateExecutable;
|
Chris@0
|
9 use Drupal\KernelTests\KernelTestBase;
|
Chris@0
|
10
|
Chris@0
|
11 /**
|
Chris@0
|
12 * Tests interruptions triggered during migrations.
|
Chris@0
|
13 *
|
Chris@0
|
14 * @group migrate
|
Chris@0
|
15 */
|
Chris@0
|
16 class MigrateInterruptionTest extends KernelTestBase {
|
Chris@0
|
17
|
Chris@0
|
18 /**
|
Chris@0
|
19 * Modules to enable.
|
Chris@0
|
20 *
|
Chris@0
|
21 * @var array
|
Chris@0
|
22 */
|
Chris@0
|
23 public static $modules = ['migrate', 'migrate_events_test'];
|
Chris@0
|
24
|
Chris@0
|
25 /**
|
Chris@0
|
26 * {@inheritdoc}
|
Chris@0
|
27 */
|
Chris@0
|
28 protected function setUp() {
|
Chris@0
|
29 parent::setUp();
|
Chris@0
|
30 \Drupal::service('event_dispatcher')->addListener(MigrateEvents::POST_ROW_SAVE,
|
Chris@0
|
31 [$this, 'postRowSaveEventRecorder']);
|
Chris@0
|
32 }
|
Chris@0
|
33
|
Chris@0
|
34 /**
|
Chris@0
|
35 * Tests migration interruptions.
|
Chris@0
|
36 */
|
Chris@0
|
37 public function testMigrateEvents() {
|
Chris@0
|
38 // Run a simple little migration, which should trigger one of each event
|
Chris@0
|
39 // other than map_delete.
|
Chris@0
|
40 $definition = [
|
Chris@0
|
41 'migration_tags' => ['Interruption test'],
|
Chris@0
|
42 'source' => [
|
Chris@0
|
43 'plugin' => 'embedded_data',
|
Chris@0
|
44 'data_rows' => [
|
Chris@0
|
45 ['data' => 'dummy value'],
|
Chris@0
|
46 ['data' => 'dummy value2'],
|
Chris@0
|
47 ],
|
Chris@0
|
48 'ids' => [
|
Chris@0
|
49 'data' => ['type' => 'string'],
|
Chris@0
|
50 ],
|
Chris@0
|
51 ],
|
Chris@0
|
52 'process' => ['value' => 'data'],
|
Chris@0
|
53 'destination' => ['plugin' => 'dummy'],
|
Chris@0
|
54 ];
|
Chris@0
|
55
|
Chris@0
|
56 $migration = \Drupal::service('plugin.manager.migration')->createStubMigration($definition);
|
Chris@0
|
57
|
Chris@14
|
58 $executable = new MigrateExecutable($migration);
|
Chris@0
|
59 // When the import runs, the first row imported will trigger an
|
Chris@0
|
60 // interruption.
|
Chris@0
|
61 $result = $executable->import();
|
Chris@0
|
62
|
Chris@0
|
63 $this->assertEqual($result, MigrationInterface::RESULT_INCOMPLETE);
|
Chris@0
|
64
|
Chris@0
|
65 // The status should have been reset to IDLE.
|
Chris@0
|
66 $this->assertEqual($migration->getStatus(), MigrationInterface::STATUS_IDLE);
|
Chris@0
|
67 }
|
Chris@0
|
68
|
Chris@0
|
69 /**
|
Chris@0
|
70 * Reacts to post-row-save event.
|
Chris@0
|
71 *
|
Chris@18
|
72 * @param \Drupal\migrate\Event\MigratePostRowSaveEvent $event
|
Chris@0
|
73 * The migration event.
|
Chris@0
|
74 * @param string $name
|
Chris@0
|
75 * The event name.
|
Chris@0
|
76 */
|
Chris@0
|
77 public function postRowSaveEventRecorder(MigratePostRowSaveEvent $event, $name) {
|
Chris@0
|
78 $event->getMigration()->interruptMigration(MigrationInterface::RESULT_INCOMPLETE);
|
Chris@0
|
79 }
|
Chris@0
|
80
|
Chris@0
|
81 }
|