View source
<?php
namespace Drupal\migrate\Tests;
use Drupal\migrate\Entity\Migration;
use Drupal\migrate\Row;
use Drupal\simpletest\KernelTestBase;
class MigrateEmbeddedDataTest extends KernelTestBase {
public static $modules = [
'migrate',
];
public function testEmbeddedData() {
$data_rows = [
[
'key' => '1',
'field1' => 'f1value1',
'field2' => 'f2value1',
],
[
'key' => '2',
'field1' => 'f1value2',
'field2' => 'f2value2',
],
];
$ids = [
'key' => [
'type' => 'integer',
],
];
$config = [
'id' => 'sample_data',
'migration_tags' => [
'Embedded data test',
],
'source' => [
'plugin' => 'embedded_data',
'data_rows' => $data_rows,
'ids' => $ids,
],
'process' => [],
'destination' => [
'plugin' => 'null',
],
];
$migration = Migration::create($config);
$source = $migration
->getSourcePlugin();
$results = [];
foreach ($source as $row) {
$data_row = $row
->getSource();
unset($data_row['plugin']);
unset($data_row['data_rows']);
unset($data_row['ids']);
$results[] = $data_row;
}
$this
->assertIdentical($results, $data_rows);
$this
->assertIdentical($source
->count(), count($data_rows));
$this
->assertIdentical($source
->getIds(), $ids);
$expected_fields = [
'key' => 'key',
'field1' => 'field1',
'field2' => 'field2',
];
$this
->assertIdentical($source
->fields(), $expected_fields);
}
}