function CronQueueTest::testQueueWorkerManagerSafeguard

Test safeguard against invalid annotations in QueueWorkerManager.

File

core/modules/system/tests/src/Kernel/System/CronQueueTest.php, line 302

Class

CronQueueTest

Tests the Cron Queue runner.

Namespace

Code

public function testQueueWorkerManagerSafeguard() : void {
  $queue_worker_manager = $this->container
    ->get('plugin.manager.queue_worker');
  $plugin_id = 'test_plugin_id';
  // Ensure if no cron annotation is provided, none is added.
  $definition = [];
  $queue_worker_manager->processDefinition($definition, $plugin_id);
  $this->assertArrayNotHasKey('cron', $definition);
  // Ensure if an empty cron annotation is provided, the default lease time is
  // added.
  $definition = [
    'cron' => [],
  ];
  $queue_worker_manager->processDefinition($definition, $plugin_id);
  $this->assertArrayHasKey('time', $definition['cron']);
  $this->assertEquals(QueueWorkerManagerInterface::DEFAULT_QUEUE_CRON_TIME, $definition['cron']['time']);
  // Ensure if an invalid lease time (less-than 1 second) is provided, it is
  // overridden with the default lease time.
  $definition = [
    'cron' => [
      'time' => 0,
    ],
  ];
  $queue_worker_manager->processDefinition($definition, $plugin_id);
  $this->assertEquals(QueueWorkerManagerInterface::DEFAULT_QUEUE_CRON_TIME, $definition['cron']['time']);
  $definition = [
    'cron' => [
      'time' => -1,
    ],
  ];
  $queue_worker_manager->processDefinition($definition, $plugin_id);
  $this->assertEquals(QueueWorkerManagerInterface::DEFAULT_QUEUE_CRON_TIME, $definition['cron']['time']);
}