Drupal\DrupalExtension\Context\BatchContext

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	iWaitForTheBatchJobToFinish()	0	4	1
B	thereIsAnItemInTheSystemQueue()	0	22	6

<?php

namespace Drupal\DrupalExtension\Context;

use Behat\MinkExtension\Context\RawMinkContext;

/**
 * Extensions to the Mink Extension.
 */
class BatchContext extends RawMinkContext
{

  /**
   * Wait for the Batch API to finish.
   *
   * Wait until the id="updateprogress" element is gone,
   * or timeout after 3 minutes (180,000 ms).
   *
   * @Given /^I wait for the batch job to finish$/
   */
    public function iWaitForTheBatchJobToFinish()
    {
        $this->getSession()->wait(180000, 'jQuery("#updateprogress").length === 0');
    }

  /**
   * Creates a queue item. Defaults inputs if none are available.
   *
   * Expects the `data` to be a json encoded string.
   *
   * @Given there is an item in the system queue:
   */
    public function thereIsAnItemInTheSystemQueue(TableNode $table)
    {
        // Gather the data.
        $fields = $table->getRowsHash();

        // Default data field separately since this is longish.
        if (empty($fields['data'])) {
            $fields['data'] = json_encode([]);
        }

        // @see SystemQueue::createItem().
        $query = db_insert('queue')
        ->fields(array(
        'name' => $fields['name'] ?: user_password(),
        'data' => serialize(json_decode($fields['data'])),
        'created' => $fields['created'] ?: REQUEST_TIME,
        'expire' => $fields['expire'] ?: 0,
        ));
        if (!$query->execute()) {
            throw new Exception('Unable to create the queue item.');
        }
    }
}