AnalyticModel::setParams() - Code Metrics - Inspection of "first steps to aggregate params" - libgraviton/graviton - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — feature/aggregation-params ( b242d2...331dde )

by Narcotic

created 2018-03-07 16:44 UTC

AnalyticModel::setParams() 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
dl	0
loc	4
ccs	0
cts	4
cp	0
rs	10
c	0
b	0
f	0
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  https://opensource.org/licenses/MIT MIT License
 * @link     http://swisscom.ch
 */
class AnalyticModel
{
    protected $collection;
    protected $route;
    protected $aggregate = [];
    protected $schema;
    protected $type;
    protected $cacheTime;
    protected $params = [];

    /**
     * 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;
    }

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

    /**
     * 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 getAggregate($params = [])
    {
        $aggregate = $this->getParameterizedAggregate($params);

        /*
        $pipeline = [];

        foreach ($aggregate as $op => $query) {
            $pipeline[] = [
                $op => $this->parseObjectDates($query)
            ];
        }
        */

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

        return $aggregate;
    }

    /**
     * get Params
     *
     * @return mixed Params
     */
    public function getParams()
    {
        return $this->params;
    }

    /**
     * set Params
     *
     * @param mixed $params params
     *
     * @return void
     */
    public function setParams($params)
    {
        $this->params = $params;
    }

    /**
     * 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;
    }

    private function getParameterizedAggregate($params)
    {
        $encoded = json_encode($this->aggregate);

        // are there any params?
        if (is_array($params) && !empty($params)) {
            foreach ($params as $name => $value) {
                // replace single standalone values in json
                if (is_int($value) || is_bool($value)) {
                    $encoded = preg_replace('/"\$\{'.$name.'\}"/', $value, $encoded);
                }

                // the balance
                $encoded = preg_replace('/\$\{'.$name.'\}/', $value, $encoded);
            }
        }

        //var_dump($encoded); die;

        return json_decode($encoded, true);
    }
}


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 https://opensource.org/licenses/MIT MIT License
14			* @link http://swisscom.ch
15			*/
16			class AnalyticModel
17			{
18			protected $collection;
19			protected $route;
20			protected $aggregate = [];
21			protected $schema;
22			protected $type;
23			protected $cacheTime;
24			protected $params = [];
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			* Set mongodb query
66			* @param mixed $aggregate object type for query data
67			* @return void
68			*/
69			public function setAggregate($aggregate)
70			{
71			$this->aggregate = $aggregate;
72			}
73
74			/**
75			* Schema for response
76			* @return mixed
77			*/
78			public function getSchema()
79			{
80			return $this->schema;
81			}
82
83			/**
84			* Schema data
85			* @param mixed $schema object schema
86			* @return void
87			*/
88			public function setSchema($schema)
89			{
90			$this->schema = $schema;
91			}
92
93			/**
94			* Type of response data
95			* @return mixed
96			*/
97			public function getType()
98			{
99			return $this->type;
100			}
101
102			/**
103			* Type for representation
104			* @param mixed $type string view
105			* @return void
106			*/
107			public function setType($type)
108			{
109			$this->type = $type;
110			}
111
112			/**
113			* Time for this route data to be cached
114			* @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...
115			*/
116			public function getCacheTime()
117			{
118			return $this->cacheTime;
119			}
120
121			/**
122			* Time for this route data to be cached
123			* @param integer $cacheTime seconds to be cached
124			* @return void
125			*/
126			public function setCacheTime($cacheTime)
127			{
128			$this->cacheTime = (int) $cacheTime;
129			}
130
131			/**
132			* Build a output Db Model aggregation pipeline array.
133			*
134			* @return array
135			*/
136			public function getAggregate($params = [])
137			{
138			$aggregate = $this->getParameterizedAggregate($params);
139
140			/*
141			$pipeline = [];
142
143			foreach ($aggregate as $op => $query) {
144			$pipeline[] = [
145			$op => $this->parseObjectDates($query)
146			];
147			}
148			*/
149
150			if (empty($aggregate)) {
151			throw new InvalidArgumentException('Wrong configuration for Aggregation pipeline');
152			}
153
154			return $aggregate;
155			}
156
157			/**
158			* get Params
159			*
160			* @return mixed Params
161			*/
162			public function getParams()
163			{
164			return $this->params;
165			}
166
167			/**
168			* set Params
169			*
170			* @param mixed $params params
171			*
172			* @return void
173			*/
174			public function setParams($params)
175			{
176			$this->params = $params;
177			}
178
179			/**
180			* Enabling to possibility to create dtae queries
181			* Will replace PARSE_DATE(date\|format)
182			* sample: PARSE_DATE(-4 years\|Y) -> new DateTime(-4 years)->format(Y) -> 2013
183			*
184			* @param object $query Aggregation query
185			* @return object
186			*/
187			private function parseObjectDates($query)
			0 ignored issues – show Unused Code introduced 2018-03-07 16:55 UTC by Report Bug Copy Issue Report This method is not used, and could be removed. Loading history...
188			{
189			$string = json_encode($query);
190			preg_match_all('/PARSE_DATE\(([^\)]+)\)/', $string, $matches);
191			if ($matches && array_key_exists(1, $matches) && is_array($matches[1])) {
192			foreach ($matches[0] as $key => $value) {
193			$formatting = explode('\|', $matches[1][$key]);
194			$date = new \DateTime($formatting[0]);
195			$string = str_replace('"'.$value.'"', $date->format($formatting[1]), $string);
196			}
197			$query = json_decode($string);
198			}
199			return $query;
200			}
201
202			private function getParameterizedAggregate($params)
203			{
204			$encoded = json_encode($this->aggregate);
205
206			// are there any params?
207			if (is_array($params) && !empty($params)) {
208			foreach ($params as $name => $value) {
209			// replace single standalone values in json
210			if (is_int($value) \|\| is_bool($value)) {
211			$encoded = preg_replace('/"\$\{'.$name.'\}"/', $value, $encoded);
212			}
213
214			// the balance
215			$encoded = preg_replace('/\$\{'.$name.'\}/', $value, $encoded);
216			}
217			}
218
219			//var_dump($encoded); die;
220
221			return json_decode($encoded, true);
222			}
223			}
224

libgraviton / graviton

Push — feature/aggregation-params ( b242d2...331dde )

AnalyticModel::setParams() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like