View source
<?php
namespace Drupal\Tests\migrate\Functional\process;
use Drupal\migrate\MigrateExecutable;
use Drupal\migrate\Plugin\MigrateIdMapInterface;
use Drupal\migrate\Plugin\MigrationInterface;
use Drupal\Tests\BrowserTestBase;
class DownloadFunctionalTest extends BrowserTestBase {
protected static $modules = [
'migrate',
'file',
];
protected $defaultTheme = 'stark';
public function testExceptionThrow() {
$invalid_url = "{$this->baseUrl}/not-existent-404";
$valid_url = "{$this->baseUrl}/core/misc/favicon.ico";
$definition = [
'source' => [
'plugin' => 'embedded_data',
'data_rows' => [
[
'url' => $invalid_url,
'uri' => 'public://first.txt',
],
[
'url' => $valid_url,
'uri' => 'public://second.ico',
],
],
'ids' => [
'url' => [
'type' => 'string',
],
],
],
'process' => [
'uri' => [
'plugin' => 'download',
'source' => [
'url',
'uri',
],
],
],
'destination' => [
'plugin' => 'entity:file',
],
];
$migration = \Drupal::service('plugin.manager.migration')
->createStubMigration($definition);
$executable = new MigrateExecutable($migration);
$result = $executable
->import();
$this
->assertEquals(MigrationInterface::RESULT_COMPLETED, $result);
$id_map_plugin = $migration
->getIdMap();
$map_row = $id_map_plugin
->getRowBySource([
'url' => $invalid_url,
]);
$this
->assertEquals(MigrateIdMapInterface::STATUS_FAILED, $map_row['source_row_status']);
$this
->assertNull($map_row['destid1']);
$messages = $id_map_plugin
->getMessages([
'url' => $invalid_url,
])
->fetchAll();
$this
->assertCount(1, $messages);
$message = reset($messages);
$id = $migration
->getPluginId();
$this
->assertStringContainsString("{$id}:uri:download:", $message->message);
$this
->assertStringContainsString($invalid_url, $message->message);
$this
->assertEquals(MigrationInterface::MESSAGE_ERROR, $message->level);
$map_row = $id_map_plugin
->getRowBySource([
'url' => $valid_url,
]);
$this
->assertEquals(MigrateIdMapInterface::STATUS_IMPORTED, $map_row['source_row_status']);
$this
->assertEquals(1, $map_row['destid1']);
}
}