Graviton\AnalyticsBundle\Manager\AnalyticsManager

Complexity

Total Complexity

7

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	getData()	0	16	2
A	convertDates()	0	12	4

<?php
/**
 * Database manager and query manager
 */

namespace Graviton\AnalyticsBundle\Manager;

use Doctrine\ODM\MongoDB\DocumentManager;
use Graviton\AnalyticsBundle\Model\AnalyticModel;
use Graviton\DocumentBundle\Service\DateConverter;

/**
 * Manager for data layer single responsibility
 *
 * @author   List of contributors <https://github.com/libgraviton/graviton/graphs/contributors>
 * @license  https://opensource.org/licenses/MIT MIT License
 * @link     http://swisscom.ch
 */
class AnalyticsManager
{
    /**
     * @var DocumentManager
     */
    private $documentManager;

    /**
     * @var string
     */
    private $databaseName;

    /**
     * @var DateConverter
     */
    private $dateConverter;

    /**
     * AnalyticsManager constructor.
     * @param DocumentManager $documentManager Db manager and query control
     * @param string          $databaseName    Db string name
     * @param DateConverter   $dateConverter   date converter
     */
    public function __construct(
        DocumentManager $documentManager,
        $databaseName,
        DateConverter $dateConverter
    ) {
        $this->documentManager = $documentManager;
        $this->databaseName = $databaseName;
        $this->dateConverter = $dateConverter;
    }

    /**
     * Query db based on definition
     * Another option is to use: $collection->createAggregationBuilder();
     *
     * @param AnalyticModel $model  Definition
     * @param array         $params data params
     *
     * @return array|object
     */
    public function getData(AnalyticModel $model, $params = [])
    {
        $conn = $this->documentManager->getConnection();
        $collection = $conn->selectCollection($this->databaseName, $model->getCollection());

        // Build aggregation pipeline
        $pipeline = $model->getAggregate($params);

        $iterator = $collection->aggregate($pipeline, ['cursor' => true]);

        if ('object' === $model->getType()) {
            return $this->convertDates($iterator->getSingleResult());
        }

        return array_map([$this, 'convertDates'], $iterator->toArray());
    }

    /**
     * convert date representations in the returned output.. as we are not typed here, we don't
     * know what to expect..
     *
     * @param array $data data
     *
     * @return array data with formatted dates
     */
    private function convertDates(array $data)
    {
        foreach ($data as $key => $val) {
            if (is_array($val)) {
                $data[$key] = $this->convertDates($val);
            }
            if ($val instanceof \MongoDate) {
                $data[$key] = $this->dateConverter->formatDateTime($val->toDateTime());
            }
        }
        return $data;
    }
}