AnalyticModel::setPipeline() - Code Metrics - Inspection of "Merge branch 'release/1.2.0'" - libgraviton/graviton - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 554f9d...0d589d )

unknown

created 2017-05-19 11:59 UTC

AnalyticModel::setPipeline() A

↳ Parent: AnalyticModel

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
c	0
b	0
f	0
dl	0
loc	4
ccs	0
cts	4
cp	0
rs	10
cc	1
eloc	2
nc	1
nop	1
crap	2

<?php
/**
 * Schema Class for output data.
 */
namespace Graviton\AnalyticsBundle\Model;

use Symfony\Component\Serializer\Exception\InvalidArgumentException;

/**
 * Schema
 *
 * @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 AnalyticModel
{
    protected $collection;
    protected $route;
    protected $aggregate;
    protected $pipeline;
    protected $schema;
    protected $type;
    protected $cacheTime;

    /**
     * String collection
     * @return mixed
     */
    public function getCollection()
    {
        return $this->collection;
    }

    /**
     * Set value of collection
     * @param mixed $collection string name
     * @return void
     */
    public function setCollection($collection)
    {
        $this->collection = $collection;
    }

    /**
     * Route path
     * @return mixed
     */
    public function getRoute()
    {
        return $this->route;
    }

    /**
     * Set path
     * @param mixed $route string route
     * @return void
     */
    public function setRoute($route)
    {
        $this->route = $route;
    }

    /**
     * Mongodb Aggregates
     * @return mixed
     */
    public function getAggregate()
    {
        return $this->aggregate ?: [];
    }

    /**
     * Set mongodb query
     * @param mixed $aggregate object type for query data
     * @return void
     */
    public function setAggregate($aggregate)
    {
        $this->aggregate = $aggregate;
    }

    /**
     * @param mixed $pipeline Data array for query
     * @return void
     */
    public function setPipeline($pipeline)
    {
        $this->pipeline = $pipeline;
    }

    /**
     * Schema for response
     * @return mixed
     */
    public function getSchema()
    {
        return $this->schema;
    }

    /**
     * Schema data
     * @param mixed $schema object schema
     * @return void
     */
    public function setSchema($schema)
    {
        $this->schema = $schema;
    }

    /**
     * Type of response data
     * @return mixed
     */
    public function getType()
    {
        return $this->type;
    }

    /**
     * Type for representation
     * @param mixed $type string view
     * @return void
     */
    public function setType($type)
    {
        $this->type = $type;
    }

    /**
     * Time for this route data to be cached
     * @return mixed

     */
    public function getCacheTime()
    {
        return $this->cacheTime;
    }

    /**
     * Time for this route data to be cached
     * @param integer $cacheTime seconds to be cached
     * @return void
     */
    public function setCacheTime($cacheTime)
    {
        $this->cacheTime = (int) $cacheTime;
    }



    /**
     * Build a output Db Model aggregation pipeline array.
     *
     * @return array
     */
    public function getPipeline()
    {
        $rtnPipeline = [];

        if ($pipeline = $this->pipeline) {
            foreach ($pipeline as $pipe) {
                foreach ($pipe as $op => $query) {
                    $rtnPipeline[] = [
                        $op => $this->parseObjectDates($query)
                    ];
                }
            }
        } elseif ($aggregate = $this->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;
    }
}


1			<?php
2			/**
3			* Schema Class for output data.
4			*/
5			namespace Graviton\AnalyticsBundle\Model;
6
7			use Symfony\Component\Serializer\Exception\InvalidArgumentException;
8
9			/**
10			* Schema
11			*
12			* @author List of contributors <https://github.com/libgraviton/graviton/graphs/contributors>
13			* @license http://opensource.org/licenses/gpl-license.php GNU Public License
14			* @link http://swisscom.ch
15			*/
16			class AnalyticModel
17			{
18			protected $collection;
19			protected $route;
20			protected $aggregate;
21			protected $pipeline;
22			protected $schema;
23			protected $type;
24			protected $cacheTime;
25
26			/**
27			* String collection
28			* @return mixed
29			*/
30			public function getCollection()
31			{
32			return $this->collection;
33			}
34
35			/**
36			* Set value of collection
37			* @param mixed $collection string name
38			* @return void
39			*/
40			public function setCollection($collection)
41			{
42			$this->collection = $collection;
43			}
44
45			/**
46			* Route path
47			* @return mixed
48			*/
49			public function getRoute()
50			{
51			return $this->route;
52			}
53
54			/**
55			* Set path
56			* @param mixed $route string route
57			* @return void
58			*/
59			public function setRoute($route)
60			{
61			$this->route = $route;
62			}
63
64			/**
65			* Mongodb Aggregates
66			* @return mixed
67			*/
68			public function getAggregate()
69			{
70			return $this->aggregate ?: [];
71			}
72
73			/**
74			* Set mongodb query
75			* @param mixed $aggregate object type for query data
76			* @return void
77			*/
78			public function setAggregate($aggregate)
79			{
80			$this->aggregate = $aggregate;
81			}
82
83			/**
84			* @param mixed $pipeline Data array for query
85			* @return void
86			*/
87			public function setPipeline($pipeline)
88			{
89			$this->pipeline = $pipeline;
90			}
91
92			/**
93			* Schema for response
94			* @return mixed
95			*/
96			public function getSchema()
97			{
98			return $this->schema;
99			}
100
101			/**
102			* Schema data
103			* @param mixed $schema object schema
104			* @return void
105			*/
106			public function setSchema($schema)
107			{
108			$this->schema = $schema;
109			}
110
111			/**
112			* Type of response data
113			* @return mixed
114			*/
115			public function getType()
116			{
117			return $this->type;
118			}
119
120			/**
121			* Type for representation
122			* @param mixed $type string view
123			* @return void
124			*/
125			public function setType($type)
126			{
127			$this->type = $type;
128			}
129
130			/**
131			* Time for this route data to be cached
132			* @return mixed
			0 ignored issues – show Documentation introduced 2017-05-02 08:12 UTC by Report Bug Copy Issue Report Consider making the return type a bit more specific; maybe use `integer`. This check looks for the generic type `array` as a return type and suggests a more specific type. This type is inferred from the actual code. Loading history...
133			*/
134			public function getCacheTime()
135			{
136			return $this->cacheTime;
137			}
138
139			/**
140			* Time for this route data to be cached
141			* @param integer $cacheTime seconds to be cached
142			* @return void
143			*/
144			public function setCacheTime($cacheTime)
145			{
146			$this->cacheTime = (int) $cacheTime;
147			}
148
149
150
151			/**
152			* Build a output Db Model aggregation pipeline array.
153			*
154			* @return array
155			*/
156			public function getPipeline()
157			{
158			$rtnPipeline = [];
159
160			if ($pipeline = $this->pipeline) {
161			foreach ($pipeline as $pipe) {
162			foreach ($pipe as $op => $query) {
163			$rtnPipeline[] = [
164			$op => $this->parseObjectDates($query)
165			];
166			}
167			}
168			} elseif ($aggregate = $this->getAggregate()) {
169			foreach ($aggregate as $op => $query) {
170			$rtnPipeline[] = [
171			$op => $this->parseObjectDates($query)
172			];
173			}
174			}
175
176			if (empty($rtnPipeline)) {
177			throw new InvalidArgumentException('Wrong configuration for Aggregation pipeline');
178			}
179
180			return $rtnPipeline;
181			}
182
183			/**
184			* Enabling to possibility to create dtae queries
185			* Will replace PARSE_DATE(date\|format)
186			* sample: PARSE_DATE(-4 years\|Y) -> new DateTime(-4 years)->format(Y) -> 2013
187			*
188			* @param object $query Aggregation query
189			* @return object
190			*/
191			private function parseObjectDates($query)
192			{
193			$string = json_encode($query);
194			preg_match_all('/PARSE_DATE\(([^\)]+)\)/', $string, $matches);
195			if ($matches && array_key_exists(1, $matches) && is_array($matches[1])) {
196			foreach ($matches[0] as $key => $value) {
197			$formatting = explode('\|', $matches[1][$key]);
198			$date = new \DateTime($formatting[0]);
199			$string = str_replace('"'.$value.'"', $date->format($formatting[1]), $string);
200			}
201			$query = json_decode($string);
202			}
203			return $query;
204			}
205			}
206

libgraviton / graviton

Push — master ( 554f9d...0d589d )

AnalyticModel::setPipeline() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like