Graviton\AnalyticsBundle\Manager\AnalyticsManager

Complexity

Total Complexity

15

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getData()	0	15	2
C	buildPipeline()	0	26	7
B	parseObjectDates()	0	14	5

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

namespace Graviton\AnalyticsBundle\Manager;

use Doctrine\ODM\MongoDB\DocumentManager;
use Graviton\AnalyticsBundle\Model\AnalyticModel;
use Symfony\Component\Serializer\Exception\InvalidArgumentException;

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

    /**
     * AnalyticsManager constructor.
     * @param DocumentManager $documentManager Db manager and query control
     */
    public function __construct(DocumentManager $documentManager)
    {
        $this->documentManager = $documentManager;
    }

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

        // Build aggregation pipeline
        $pipeline = $this->buildPipeline($model);

        $iterator = $collection->aggregate($pipeline);
        if ('object' === $model->getType()) {
            return $iterator->getSingleResult();
        }
        return $iterator->toArray();
    }

    /**
     * Build a output Db Model aggregation pipeline array.
     *
     * @param AnalyticModel $model Object class
     * @return array
     */
    private function buildPipeline(AnalyticModel $model)
    {
        $rtnPipeline = [];

        if ($pipeline = $model->getPipeline()) {
            foreach ($pipeline as $pipe) {
                foreach ($pipe as $op => $query) {
                    $rtnPipeline[] = [
                        $op => $this->parseObjectDates($query)
                    ];
                }
            }
        } elseif ($aggregate = $model->getAggregate()) {
            foreach ($aggregate as $op => $query) {
                $rtnPipeline[] = [
                    $op => $this->parseObjectDates($query)
                ];
            }
        }

        if (empty($rtnPipeline)) {
            throw new  InvalidArgumentException('Wrong configuration for Aggregation pipeline');
        }

        return $rtnPipeline;
    }

    /**
     * Enabling to possibility to create dtae queries
     * Will replace PARSE_DATE(date|format)
     * sample: PARSE_DATE(-4 years|Y) -> new DateTime(-4 years)->format(Y) -> 2013
     *
     * @param object $query Aggregation query
     * @return object
     */
    private function parseObjectDates($query)
    {
        $string = json_encode($query);
        preg_match_all('/PARSE_DATE\(([^\)]+)\)/', $string, $matches);
        if ($matches && array_key_exists(1, $matches) && is_array($matches[1])) {
            foreach ($matches[0] as $key => $value) {
                $formatting = explode('|', $matches[1][$key]);
                $date = new \DateTime($formatting[0]);
                $string = str_replace('"'.$value.'"', $date->format($formatting[1]), $string);
            }
            $query = json_decode($string);
        }
        return $query;
    }
}