Drupal\mongodb\Queue\MongodbQueue

Complexity

Total Complexity

13

Size/Duplication

Total Lines	160
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	createItem()	0	10	2
A	doCreateItem()	0	13	1
A	numberOfItems()	0	11	2
A	claimItem()	0	12	1
A	releaseItem()	0	11	1
A	deleteItem()	0	13	2
A	createQueue()	0	7	1
A	deleteQueue()	0	8	2

<?php
declare(strict_types = 1);

namespace Drupal\mongodb\Queue;

use Drupal\Core\Queue\QueueInterface;
use Drupal\mongodb\MongoDb;
use MongoDB\Database;

/**
 * Mongodb queue implementation.
 *
 * @ingroup queue
 */
class MongodbQueue implements QueueInterface {

  /**
   * The queue storage.
   *
   * @var \MongoDB\Database
   */
  protected $database;

  /**
   * The collection name for the queue.
   *
   * @var \MongoDB\Collection[] $collection
   */
  protected $collection;

  /**
   * Constructs a \Drupal\mongodb\Queue\MongodbQueue object.
   *
   * @param string $name
   *   The name of the queue.
   * @param array $settings
   *   Array of Mongodb-related settings for this queue.
   * @param \MongoDB\Database $database
   *   The database object.
   */
  public function __construct($name, $settings, Database $database) {
    $this->name = $name;
    $this->database = $database;
    $this->collection = $this->database

It seems like $this->database->selectCollection($name) of type object<MongoDB\Collection> is incompatible with the declared type array<integer,object<MongoDB\Collection>> of property $collection.

      ->selectCollection($name);
  }

  /**
   * {@inheritdoc}
   */
  public function createItem($data) {
    try {
      $id = $this->doCreateItem($data);
    }
    catch (\Exception $e) {
        throw $e;
    }

    return $id;
  }

  /**
   * Adds a queue item and store it directly to the queue.
   *
   * @param $data
   *   Arbitrary data to be associated with the new task in the queue.
   *
   * @return
   *   A unique ID if the item was successfully created and was (best effort)
   *   added to the queue, otherwise FALSE. We don't guarantee the item was
   *   committed to disk etc, but as far as we know, the item is now in the
   *   queue.
   */
  protected function doCreateItem($data) {

    $item = [
      'name' => $this->name,
      'data' => $data,
      'expire' => 0,
      'created' => time(),
    ];

    $result = $this->collection->insertOne($item);

The method insertOne cannot be called on $this->collection (of type array<integer,object<MongoDB\Collection>>).

    return $result->getInsertedId();
  }

  /**
   * {@inheritdoc}
   */
  public function numberOfItems() {

The return type could not be reliably inferred; please add a @return annotation.

    try {
      return (int) MongoDb::countCollection($this->collection);

$this->collection is of type array<integer,object<MongoDB\Collection>>, but the function expects a object<MongoDB\Collection>.

    }
    catch (\Exception $e) {
      throw $e;
      // If there is no collection there cannot be any items.
      return 0;

return 0; does not seem to be reachable.

    }
  }

  /**
   * {@inheritdoc}
   */
  public function claimItem($lease_time = 30) {

The return type could not be reliably inferred; please add a @return annotation.

    $newobj = [
      'expire' => time() + $lease_time,
    ];
    return $this->collection->findOneAndUpdate(

The method findOneAndUpdate cannot be called on $this->collection (of type array<integer,object<MongoDB\Collection>>).

      [],
      [ '$set' => $newobj ],
      [ 'sort' => ['created' => 1],]
    );


  }

  /**
   * {@inheritdoc}
   */
  public function releaseItem($item) {

The return type could not be reliably inferred; please add a @return annotation.

    return $this->collection

The method updateOne cannot be called on $this->collection (of type array<integer,object<MongoDB\Collection>>).

      ->updateOne(
        ['_id' => $item->_id],
        ['$set' =>
          [
            'expire' => 0
          ],
        ]
      );
  }

  /**
   * {@inheritdoc}
   */
  public function deleteItem($item) {
    try {
      $this->collection

The method deleteOne cannot be called on $this->collection (of type array<integer,object<MongoDB\Collection>>).

        ->deleteOne(
          [
            '_id' => $item->_id
          ]
        );
    }
    catch (\Exception $e) {
      throw $e;
    }
  }

  /**
   * {@inheritdoc}
   */
  public function createQueue() {
    // Create the index.
    $this->collection->createIndex([

The method createIndex cannot be called on $this->collection (of type array<integer,object<MongoDB\Collection>>).

      'expire' => 1,
      'created' => 1
    ]);
  }

  /**
   * {@inheritdoc}
   */
  public function deleteQueue() {
    try {
      $this->collection->drop();

The method drop cannot be called on $this->collection (of type array<integer,object<MongoDB\Collection>>).

    }
    catch (\Exception $e) {
      throw $e;
    }
  }

}