View source
<?php
namespace Drupal\Tests\views_bulk_operations\Kernel;
use Drupal\KernelTests\KernelTestBase;
use Drupal\simpletest\NodeCreationTrait;
use Drupal\node\Entity\NodeType;
use Drupal\user\Entity\User;
use Drupal\views\Views;
use Drupal\language\Entity\ConfigurableLanguage;
use Drupal\views_bulk_operations\ViewsBulkOperationsBatch;
abstract class ViewsBulkOperationsKernelTestBase extends KernelTestBase {
use NodeCreationTrait {
getNodeByTitle as drupalGetNodeByTitle;
createNode as drupalCreateNode;
}
const TEST_NODES_COUNT = 10;
const VBO_DEFAULTS = [
'list' => [],
'display_id' => 'default',
'preconfiguration' => [],
'batch' => TRUE,
'arguments' => [],
'exposed_input' => [],
'batch_size' => 10,
'relationship_id' => 'none',
];
protected $testNodesTypes;
protected $testNodesData;
protected $vboDataService;
public static $modules = [
'user',
'node',
'field',
'content_translation',
'views_bulk_operations',
'views_bulk_operations_test',
'views',
'filter',
'language',
'text',
'action',
'system',
];
public function setUp() {
parent::setUp();
$this
->installEntitySchema('user');
$this
->installEntitySchema('node');
$this
->installSchema('node', 'node_access');
$this
->installSchema('system', 'sequences');
$this
->installSchema('system', 'key_value_expire');
$user = User::create();
$user
->setPassword('password');
$user
->enforceIsNew();
$user
->setEmail('email');
$user
->setUsername('user_name');
$user
->save();
user_login_finalize($user);
$this
->installConfig([
'system',
'filter',
'views_bulk_operations_test',
'language',
]);
$this->time = $this->container
->get('datetime.time');
$this->vboDataService = $this->container
->get('views_bulk_operations.data');
}
protected function createTestNodes(array $test_node_data) {
$this->testNodesData = [];
foreach ($test_node_data as $type_name => $type_data) {
$type = NodeType::create([
'type' => $type_name,
'name' => $type_name,
]);
$type
->save();
$count_languages = isset($type_data['languages']) ? count($type_data['languages']) : 0;
if ($count_languages) {
for ($i = 0; $i < $count_languages; $i++) {
$language = ConfigurableLanguage::createFromLangcode($type_data['languages'][$i]);
$language
->save();
}
$this->container
->get('content_translation.manager')
->setEnabled('node', $type_name, TRUE);
}
$time = $this->time
->getRequestTime();
if (!isset($type_data['count'])) {
$type_data['count'] = 10;
}
for ($i = 0; $i < $type_data['count']; $i++) {
$time -= $i;
$title = 'Title ' . $i;
$node = $this
->drupalCreateNode([
'type' => $type_name,
'title' => $title,
'sticky' => FALSE,
'created' => $time,
'changed' => $time,
]);
$this->testNodesData[$node
->id()]['en'] = $title;
if ($count_languages) {
$langcode = $type_data['languages'][rand(0, $count_languages - 1)];
$title = 'Translated title ' . $langcode . ' ' . $i;
$translation = $node
->addTranslation($langcode, [
'title' => $title,
]);
$translation
->save();
$this->testNodesData[$node
->id()][$langcode] = $title;
}
}
}
}
protected function initializeView(array $vbo_data) {
if (!($view = Views::getView($vbo_data['view_id']))) {
throw new \Exception('Incorrect view ID provided.');
}
if (!$view
->setDisplay($vbo_data['display_id'])) {
throw new \Exception('Incorrect view display ID provided.');
}
$view->built = FALSE;
$view->executed = FALSE;
return $view;
}
protected function getResultsList(array $vbo_data, array $deltas) {
$vbo_data += static::VBO_DEFAULTS;
$view = $this
->initializeView($vbo_data);
if (!empty($vbo_data['arguments'])) {
$view
->setArguments($vbo_data['arguments']);
}
if (!empty($vbo_data['exposed_input'])) {
$view
->setExposedInput($vbo_data['exposed_input']);
}
$view
->setItemsPerPage(0);
$view
->setCurrentPage(0);
$view
->execute();
$this->vboDataService
->init($view, $view
->getDisplay(), $vbo_data['relationship_id']);
$list = [];
$base_field = $view->storage
->get('base_field');
foreach ($deltas as $delta) {
$entity = $this->vboDataService
->getEntity($view->result[$delta]);
$list[] = [
$view->result[$delta]->{$base_field},
$entity
->language()
->getId(),
$entity
->getEntityTypeId(),
$entity
->id(),
];
}
$view
->destroy();
return $list;
}
protected function executeAction(array $vbo_data) {
$vbo_data += static::VBO_DEFAULTS;
$view = $this
->initializeView($vbo_data);
$view->get_total_rows = TRUE;
$view
->execute();
$this->vboDataService
->init($view, $view
->getDisplay(), $vbo_data['relationship_id']);
$vbo_data['total_results'] = $this->vboDataService
->getTotalResults();
$action_definition = $this->container
->get('plugin.manager.views_bulk_operations_action')
->getDefinition($vbo_data['action_id']);
if (!isset($vbo_data['action_label'])) {
$vbo_data['action_label'] = (string) $action_definition['label'];
}
if (empty($vbo_data['list'])) {
$context = [];
do {
$context['finished'] = 1;
$context['message'] = '';
ViewsBulkOperationsBatch::getList($vbo_data, $context);
} while ($context['finished'] < 1);
$vbo_data = $context['results'];
}
$summary = [
'messages' => [],
];
$context = [];
do {
$context['finished'] = 1;
$context['message'] = '';
ViewsBulkOperationsBatch::operation($vbo_data, $context);
if (!empty($context['message'])) {
$summary['messages'][] = (string) $context['message'];
}
} while ($context['finished'] < 1);
$summary += [
'operations' => array_count_values($context['results']['operations']),
];
return $summary;
}
}