diff --git a/tests/src/Kernel/Form/DatasetBatchOperationsTest.php b/tests/src/Kernel/Form/DatasetBatchOperationsTest.php index c88143c..3d13800 100644 --- a/tests/src/Kernel/Form/DatasetBatchOperationsTest.php +++ b/tests/src/Kernel/Form/DatasetBatchOperationsTest.php @@ -27,6 +27,7 @@ class DatasetBatchOperationsTest extends DatasetKernelTestBase { $batch = DatasetBatchOperations::batchForDataset($dataset); $this->assertEquals([ [[DatasetBatchOperations::class, 'operationValidate'], [$dataset->id()]], + [[DatasetBatchOperations::class, 'operationQueueItem'], [$dataset->id()]], [[DatasetBatchOperations::class, 'operationIndex'], [$dataset->id()]], ], $batch['operations']); } @@ -70,6 +71,24 @@ CSV; $this->assertEquals('Skipped indexing dataset, validation errors exist.', (string) $context['message']); } + /** + * Tests queue operation. + */ + public function testQueuingValid(): void { + $dataset = $this->createTestDataset([ + 'status' => DatasetInterface::STATUS_PENDING_INDEX, + ]); + $queue = \Drupal::queue('data_pipelines_index:' . $dataset->id()); + // Clear any previous operations. + $queue->deleteQueue(); + $context = [ + 'results' => [], + ]; + DatasetBatchOperations::operationQueueItem((int) $dataset->id(), $context); + $this->assertEquals('Data is successfully queued for indexing.', (string) $context['message']); + $this->assertEquals(1, $queue->numberOfItems()); + } + /** * Tests index operation. */