AshPowell\APAnalytics\APAnalytics::show()

Complexity

Conditions	16
Paths	580

Size

Total Lines	90
Code Lines	49

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function show($collection, $interval = 'count', $timeframe = null, $filters = null)
    {
        $start          = $timeframe ? array_get($timeframe, 'start') : null;
        $end            = $timeframe ? array_get($timeframe, 'end') : null;
        $matchArray     = [];
        $filters        = json_decode($filters);
        $intervalFormat = '%Y-%m-%dT%H';
        $aggregate      = [];

        $model = $this->namespace.studly_case(str_singular($collection)).'Analytic';

        if (! class_exists($model)) {
            throw new InvalidArgumentException("Model {$model} does not exist.");
        }

        if ($filters) {
            foreach ($filters as $filter) {
                $propertyValue = $filter->property_value;

                if (is_numeric($propertyValue)) {
                    $propertyValue = (int) $propertyValue;
                }

                $matchArray = array_merge($matchArray, [$filter->property_name => $propertyValue]);
            }
        }

        abort_unless($this->canViewAnalytic($matchArray, auth()->user()), 403, 'You dont have permission to view these analytics');

        if ($start) {
            $matchArray['created_at']['$gte'] = mongoTime($start);
        }

        if ($end) {
            $matchArray['created_at']['$lt'] = mongoTime($end);
        }

        if ($matchArray) {
            $aggregate[] = ['$match' => $matchArray];
        }

        if ($interval != 'count') {
            if ($interval == 'daily') {
                $intervalFormat = '%Y-%m-%d';
            }

            if ($interval == 'weekly') {
                $intervalFormat = '%Y-%U';
            }

            if ($interval == 'monthly') {
                $intervalFormat = '%Y-%m';
            }

            $aggregate[] =  [
                '$group' => [
                    '_id' => [
                        '$dateToString' => ['date' => '$created_at', 'format' => $intervalFormat],
                    ],
                    'count' => [
                        '$sum' => 1,
                    ],
                    'created_at' => [
                        '$first' => '$created_at',
                    ],
                ],
            ];

            $aggregate[] = ['$sort' => ['created_at' => 1]];

            $aggregate[] = [
                '$project' => [
                    '_id'        => 0,
                    'created_at' => 1,
                    'count'      => 1,
                ],
            ];
        }

        $data = $model::raw(function ($collection) use ($matchArray, $interval, $aggregate) {
            if ($interval == 'count') {
                return $collection->count($matchArray);
            }

            if ($aggregate) {
                return $collection->aggregate($aggregate, ['allowDiskUse' => true]);
            }
        });

        return $data;
    }