PHPProm\Storage\MongoDB

Complexity

Total Complexity

7

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	storeMeasurement()	0	8	1
A	incrementMeasurement()	0	12	2
A	getMeasurements()	0	18	3

<?php

/*
 * This file is part of the PHPProm package.
 *
 * (c) Philip Lehmann-Böhm <philip@philiplb.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace PHPProm\Storage;

/**
 * Class MongoDB
 * Storage implementation using MongoDB.
 * @package PHPProm\Storage
 */
class MongoDB extends AbstractStorage {

    /**
     * @var \MongoDB\Driver\Manager
     * The MongoDB Driver Manager.
     */
    protected $mongoDBManager;

    /**
     * @var string
     * The database name for the data.
     */
    protected $database;

    /**
     * @var string
     * The collection name for the data.
     */
    protected $collection;

    /**
     * MongoDB constructor.
     *
     * @param string $host
     * a mongodb:// connection URI
     * @param string $database
     * the database to use, defaults to "phppromdb"
     * @param string $collection
     * the collection to use, defaults to "measurements"
     * @param array $options
     * connection string options, defaults to []
     * @param array $driverOptions
     * any driver-specific options not included in MongoDB connection spec, defaults to []
     */
    public function __construct($host, $database = 'phppromdb', $collection = 'measurements', array $options = [], array $driverOptions = []) {
        parent::__construct();
        $this->mongoDBManager = new \MongoDB\Driver\Manager($host, $options, $driverOptions);
        $this->database = $database;

Equals sign not aligned with surrounding assignments; expected 7 spaces but found 1 space

        $this->collection = $collection;

Equals sign not aligned with surrounding assignments; expected 5 spaces but found 1 space

    }

    /**
     * {@inheritdoc}
     */
    public function storeMeasurement($metric, $key, $value) {
        $bulkWrite = new \MongoDB\Driver\BulkWrite;
        $document = ['key' => $metric.':'.$key, 'value' => $value];

Equals sign not aligned with surrounding assignments; expected 2 spaces but found 1 space

        $filter = ['key' => $metric.':'.$key];

Equals sign not aligned with surrounding assignments; expected 4 spaces but found 1 space

        $bulkWrite->update($filter, $document, ['upsert' => true]);
        $writeConcern = new \MongoDB\Driver\WriteConcern(\MongoDB\Driver\WriteConcern::MAJORITY, 1000);
        $this->mongoDBManager->executeBulkWrite($this->database.'.'.$this->collection, $bulkWrite, $writeConcern);
    }

    /**
     * {@inheritdoc}
     */
    public function incrementMeasurement($metric, $key) {
        $filter = ['key' => $metric.':'.$key];

Equals sign not aligned with surrounding assignments; expected 2 spaces but found 1 space

        $options = ['limit' => 1];
        $query = new \MongoDB\Driver\Query($filter, $options);

Equals sign not aligned with surrounding assignments; expected 3 spaces but found 1 space

        $results = $this->mongoDBManager->executeQuery($this->database.'.'.$this->collection, $query);
        $value = 1;

Equals sign not aligned with surrounding assignments; expected 3 spaces but found 1 space

        foreach ($results as $result) {
            $value += $result->value;
            break;
        }
        $this->storeMeasurement($metric, $key, $value);
    }

    /**
     * {@inheritdoc}
     */
    public function getMeasurements($metric, array $keys, $defaultValue = 'Nan') {
        $prefixedKeys = array_map(function($key) use ($metric) {
            return $metric.':'.$key;
        }, $keys);

        $measurements = [];
        foreach ($keys as $key) {
            $measurements[$key] = $defaultValue;
        }
        $filter = ['key' => ['$in' => $prefixedKeys]];

Equals sign not aligned with surrounding assignments; expected 2 spaces but found 1 space

        $query = new \MongoDB\Driver\Query($filter);

Equals sign not aligned with surrounding assignments; expected 3 spaces but found 1 space

        $results = $this->mongoDBManager->executeQuery($this->database.'.'.$this->collection, $query);
        foreach ($results as $result) {
            $unprefixedKey                = substr($result->key, strlen($metric) + 1);
            $measurements[$unprefixedKey] = (float)$result->value;
        }
        return $measurements;
    }
}