Interpreter::callFunction() - Code Metrics - Inspection of "ContextAwareUqlFunction to provide context to uql..." - netdudes/DataSourceryBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( f7f008...2d0f6c )

unknown

created 2016-07-15 11:41 UTC

Interpreter::callFunction() A

↳ Parent: Interpreter

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	3
Bugs	0	Features	0

Metric	Value
c	3
b	0
f	0
dl	0
loc	12
rs	9.4285
cc	2
eloc	8
nc	2
nop	1

<?php
namespace Netdudes\DataSourceryBundle\UQL;

use Netdudes\DataSourceryBundle\DataSource\Configuration\Field;
use Netdudes\DataSourceryBundle\DataSource\Configuration\FieldInterface;
use Netdudes\DataSourceryBundle\DataSource\DataSourceInterface;
use Netdudes\DataSourceryBundle\Extension\ContextAwareUqlFunction;
use Netdudes\DataSourceryBundle\Extension\ContextFactory;
use Netdudes\DataSourceryBundle\Extension\Exception\FunctionNotFoundException;
use Netdudes\DataSourceryBundle\Extension\UqlExtensionContainer;
use Netdudes\DataSourceryBundle\Extension\UqlFunctionInterface;
use Netdudes\DataSourceryBundle\Query\Filter;
use Netdudes\DataSourceryBundle\Query\FilterCondition;
use Netdudes\DataSourceryBundle\Query\FilterConditionFactory;
use Netdudes\DataSourceryBundle\UQL\AST\ASTArray;
use Netdudes\DataSourceryBundle\UQL\AST\ASTAssertion;
use Netdudes\DataSourceryBundle\UQL\AST\ASTFunctionCall;
use Netdudes\DataSourceryBundle\UQL\AST\ASTGroup;
use Netdudes\DataSourceryBundle\UQL\Exception\UQLInterpreterException;

/**
 * Class Interpreter
 *
 * The Interpreter transforms the generic Abstract Syntax Tree into Filters
 */
class Interpreter
{
    /**
     * @var UqlExtensionContainer
     */
    private $extensionContainer;

    /**
     * @var DataSourceInterface
     */
    private $dataSource;

    /**
     * @var array
     */
    private $dataSourceElements;

    /**
     * @var bool
     */
    private $caseSensitive;

    /**
     * @var FilterConditionFactory
     */
    private $filterConditionFactory;

    /**
     * @var ContextFactory
     */
    private $contextFactory;

    /**
     * Constructor needs the columns descriptor to figure out appropriate filtering methods
     * and translate identifiers.
     *
     * @param UqlExtensionContainer  $extensionContainer
     * @param DataSourceInterface    $dataSource
     * @param FilterConditionFactory $filterConditionFactory
     * @param ContextFactory         $contextFactory
     * @param bool                   $caseSensitive
     */
    public function __construct(
        UqlExtensionContainer $extensionContainer,
        DataSourceInterface $dataSource,
        FilterConditionFactory $filterConditionFactory,
        ContextFactory $contextFactory,
        $caseSensitive = true
    ) {
        $this->extensionContainer = $extensionContainer;
        $this->dataSource = $dataSource;
        $this->filterConditionFactory = $filterConditionFactory;
        $this->contextFactory = $contextFactory;
        $this->caseSensitive = $caseSensitive;

        // Cache an array of data sources (name => object pairs) for reference during the interpretation
        $this->dataSourceElements = array_combine(
            array_map(
                function (FieldInterface $element) use ($caseSensitive) {
                    return $caseSensitive ? $element->getUniqueName() : strtolower($element->getUniqueName());
                },
                $this->dataSource->getFields()
            ),
            $this->dataSource->getFields()
        );
    }

    /**
     * Generate the filter objects corresponding to a UQL string.
     *
     * @param string $uql
     *
     * @return Filter
     */
    public function interpret($uql)
    {
        if (empty(trim($uql))) {
            return new Filter();
        }

        $parser = new Parser();
        $AST = $parser->parse($uql);

        return $this->buildFilter($AST);
    }

    /**
     * Helper method: matches filtering operators to valid UQL operators
     * in order to do Filter to UQL transformations
     *
     * @param string $method
     *
     * @throws UQLInterpreterException
     * @return string
     */
    public static function methodToUQLOperator($method)
    {
        $translationMap = [
            FilterCondition::METHOD_STRING_EQ => "=",
            FilterCondition::METHOD_STRING_LIKE => "~",
            FilterCondition::METHOD_STRING_NEQ => "!=",
            FilterCondition::METHOD_NUMERIC_GT => ">",
            FilterCondition::METHOD_NUMERIC_GTE => ">=",
            FilterCondition::METHOD_NUMERIC_EQ => "=",
            FilterCondition::METHOD_NUMERIC_LTE => "<=",
            FilterCondition::METHOD_NUMERIC_LT => "<",
            FilterCondition::METHOD_NUMERIC_NEQ => "!=",
            FilterCondition::METHOD_IN => "IN",
            FilterCondition::METHOD_BOOLEAN => "is",
            FilterCondition::METHOD_IS_NULL => "is null",
            FilterCondition::METHOD_DATETIME_GT => "after",
            FilterCondition::METHOD_DATETIME_GTE => "after or at",
            FilterCondition::METHOD_DATETIME_EQ => "at",
            FilterCondition::METHOD_DATETIME_LTE => "before or at",
            FilterCondition::METHOD_DATETIME_LT => "before",
            FilterCondition::METHOD_DATETIME_NEQ => "not at",
        ];

        if (isset($translationMap[$method])) {
            return $translationMap[$method];
        }

        throw new UQLInterpreterException("Can't translate filtering method '$method'' into a valid UQL operator");
    }

    /**
     * Transforms a subtree of the AST into a concrete filter definition.
     * This function recursively builds all sub-trees.
     *
     * @param ASTGroup|ASTAssertion|mixed $astSubtree
     *
     * TODO: This looks like it should not be public (it is only used in tests).
     * We could move it and it's dependencies to its own class so that it can be tested
     *
     * @return Filter
     * @throws \Exception
     */
    public function buildFilter($astSubtree)
    {
        if ($astSubtree instanceof ASTGroup) {
            return $this->buildFilterFromASTGroup($astSubtree);
        }

        if ($astSubtree instanceof ASTAssertion) {
            $filterCondition = $this->buildFilterConditionFromASTAssertion($astSubtree);
            // Single filter. Wrap into dummy filter collection for consistency.
            $filter = new Filter();
            $filter[] = $filterCondition;

            return $filter;
        }

        throw new UQLInterpreterException('Unexpected Abstract Syntax Tree element');
    }

    /**
     * Translate <operator> tokens into Filter Methods.
     *
     * @param string         $token
     * @param FieldInterface $dataSourceElement
     *
     * @throws UQLInterpreterException
     * @return mixed
     */
    public function translateOperator($token, FieldInterface $dataSourceElement)
    {
        $translationTable = [
            "T_OP_LT" => [
                FilterCondition::METHOD_NUMERIC_LT,
                FilterCondition::METHOD_DATETIME_LT,
            ],
            "T_OP_LTE" => [
                FilterCondition::METHOD_NUMERIC_LTE,
                FilterCondition::METHOD_DATETIME_LTE,
            ],
            "T_OP_EQ" => [
                FilterCondition::METHOD_NUMERIC_EQ,
                FilterCondition::METHOD_STRING_EQ,
                FilterCondition::METHOD_DATETIME_EQ,
                FilterCondition::METHOD_BOOLEAN,
            ],
            "T_OP_GTE" => [
                FilterCondition::METHOD_NUMERIC_GTE,
                FilterCondition::METHOD_DATETIME_GTE,
            ],
            "T_OP_GT" => [
                FilterCondition::METHOD_NUMERIC_GT,
                FilterCondition::METHOD_DATETIME_GT,
            ],
            "T_OP_NEQ" => [
                FilterCondition::METHOD_NUMERIC_NEQ,
                FilterCondition::METHOD_STRING_NEQ,
                FilterCondition::METHOD_DATETIME_NEQ,
            ],
            "T_OP_LIKE" => [
                FilterCondition::METHOD_STRING_LIKE,
            ],
            "T_OP_IN" => [
                FilterCondition::METHOD_IN,
            ],
        ];

        if (!isset($translationTable[$token])) {
            throw new UQLInterpreterException('Unable to translate token ' . $token . ' to a valid filtering method. Unknown token.');
        }
        $possibleMethods = $translationTable[$token];

        // See if any of the methods is the default of the data type
        $dataType = $dataSourceElement->getDataType();
        foreach ($possibleMethods as $possibleMethod) {
            if ($possibleMethod === $dataType->getDefaultFilterMethod()) {
                return $possibleMethod;
            }
        }

        // Else, just accept the first one in the available methods
        foreach ($possibleMethods as $possibleMethod) {
            if (in_array($possibleMethod, $dataType->getAvailableFilterMethods())) {
                return $possibleMethod;
            }
        }

        throw new UQLInterpreterException('Unable to translate token ' . $token . ' to a valid filtering method. No methods are valid for the data type "' . $dataType->getName() . '" for data element "' . $dataSourceElement->getUniqueName() . '"');
    }

    /**
     * Translate Lexer <logic> tokens into Filter Condition Types.
     *
     * @param $token
     *
     * @return string
     * @throws \Exception
     */
    private function translateLogic($token)
    {
        $translationTable = [
            "T_LOGIC_AND" => Filter::CONDITION_TYPE_AND,
            "T_LOGIC_OR" => Filter::CONDITION_TYPE_OR,
            "T_LOGIC_XOR" => Filter::CONDITION_TYPE_XOR,
        ];

        if (isset($translationTable[$token])) {
            return $translationTable[$token];
        }

        throw new \Exception('Unable to translate token ' . $token . ' to a valid filter condition type.');
    }

    /**
     * Trim and clean up the value to be set in the filter.
     *
     * @param mixed $value
     *
     * @return mixed
     */
    private function parseValue($value)
    {
        if (is_bool($value)) {
            return $value ? "1" : "0";
        }

        return trim($value, "\"'");
    }

    /**
     * @param ASTFunctionCall $functionCall
     *
     * @return mixed
     * @throws FunctionNotFoundException
     * @throws UQLInterpreterException
     */
    private function callFunction(ASTFunctionCall $functionCall)
    {
        $functionName = $functionCall->getFunctionName();
        $function = $this->extensionContainer->getFunction($functionName);
        $arguments = $this->getFunctionArguments($functionCall, $function);

        try {
            return $function->call($arguments);
        } catch (\Exception $e) {
            throw new UQLInterpreterException("The execution of function '$functionName' failed. Please check the arguments are valid. (" . $e->getMessage() . ")");
        }
    }

    /**
     * @param array $elements
     *
     * @return array
     */
    private function parseArray($elements)
    {
        $array = [];
        foreach ($elements as $element) {
            $array[] = $this->parseValue($element);
        }

        return $array;
    }

    /**
     * @param string $identifier
     *
     * @return Field
     * @throws UQLInterpreterException
     */
    private function matchDataSourceElement($identifier)
    {
        if (!$this->caseSensitive) {
            $identifier = strtolower($identifier);
        }

        if (!isset($this->dataSourceElements[$identifier])) {
            throw new UQLInterpreterException('Unknown filtering element "' . $identifier . '"');
        }

        return $this->dataSourceElements[$identifier];
    }

    /**
     * @param ASTAssertion $astSubtree
     *
     * @throws UQLInterpreterException
     *
     * @return array|mixed
     */
    private function getValue(ASTAssertion $astSubtree)
    {
        if ($astSubtree->getValue() instanceof ASTFunctionCall) {
            return $this->callFunction($astSubtree->getValue());
        }

        if ($astSubtree->getOperator() == 'T_OP_IN') {
            if (!($astSubtree->getValue() instanceof ASTArray)) {
                throw new UQLInterpreterException('Only arrays are valid arguments for IN statements');
            }

            return $this->parseArray($astSubtree->getValue()->getElements());
        }

        return $this->parseValue($astSubtree->getValue());
    }

    /**
     * @param ASTAssertion $astSubtree
     *
     * @throws UQLInterpreterException
     *
     * @return FilterCondition
     */
    private function buildFilterConditionFromASTAssertion(ASTAssertion $astSubtree)
    {
        $field = $this->matchDataSourceElement($astSubtree->getIdentifier());
        $method = $this->translateOperator($astSubtree->getOperator(), $field);
        $value = $this->getValue($astSubtree);

        return $this->filterConditionFactory->create($field, $method, $value);
    }

    /**
     * @param ASTGroup $astSubtree
     *
     * @throws UQLInterpreterException
     * @throws \Exception
     *
     * @return Filter
     */
    private function buildFilterFromASTGroup(ASTGroup $astSubtree)
    {
        $filter = new Filter();
        $condition = $this->translateLogic($astSubtree->getLogic());
        $filter->setConditionType($condition);
        foreach ($astSubtree->getElements() as $element) {
            if ($element instanceof ASTGroup) {
                $filter[] = $this->buildFilterFromASTGroup($element);
            }
            if ($element instanceof ASTAssertion) {
                $filter[] = $this->buildFilterConditionFromASTAssertion($element);
            }
        }

        return $filter;
    }

    /**
     * @param ASTFunctionCall      $functionCall
     * @param UqlFunctionInterface $function
     *
     * @return array
     */
    private function getFunctionArguments(ASTFunctionCall $functionCall, $function)
    {
        $arguments = $functionCall->getArguments();

        if ($function instanceof ContextAwareUqlFunction) {
            $context = $this->contextFactory->create($this->dataSource->getEntityClass());
            array_unshift($arguments, $context);
        }

        return $arguments;
    }
}


1			<?php
2			namespace Netdudes\DataSourceryBundle\UQL;
3
4			use Netdudes\DataSourceryBundle\DataSource\Configuration\Field;
5			use Netdudes\DataSourceryBundle\DataSource\Configuration\FieldInterface;
6			use Netdudes\DataSourceryBundle\DataSource\DataSourceInterface;
7			use Netdudes\DataSourceryBundle\Extension\ContextAwareUqlFunction;
8			use Netdudes\DataSourceryBundle\Extension\ContextFactory;
9			use Netdudes\DataSourceryBundle\Extension\Exception\FunctionNotFoundException;
10			use Netdudes\DataSourceryBundle\Extension\UqlExtensionContainer;
11			use Netdudes\DataSourceryBundle\Extension\UqlFunctionInterface;
12			use Netdudes\DataSourceryBundle\Query\Filter;
13			use Netdudes\DataSourceryBundle\Query\FilterCondition;
14			use Netdudes\DataSourceryBundle\Query\FilterConditionFactory;
15			use Netdudes\DataSourceryBundle\UQL\AST\ASTArray;
16			use Netdudes\DataSourceryBundle\UQL\AST\ASTAssertion;
17			use Netdudes\DataSourceryBundle\UQL\AST\ASTFunctionCall;
18			use Netdudes\DataSourceryBundle\UQL\AST\ASTGroup;
19			use Netdudes\DataSourceryBundle\UQL\Exception\UQLInterpreterException;
20
21			/**
22			* Class Interpreter
23			*
24			* The Interpreter transforms the generic Abstract Syntax Tree into Filters
25			*/
26			class Interpreter
27			{
28			/**
29			* @var UqlExtensionContainer
30			*/
31			private $extensionContainer;
32
33			/**
34			* @var DataSourceInterface
35			*/
36			private $dataSource;
37
38			/**
39			* @var array
40			*/
41			private $dataSourceElements;
42
43			/**
44			* @var bool
45			*/
46			private $caseSensitive;
47
48			/**
49			* @var FilterConditionFactory
50			*/
51			private $filterConditionFactory;
52
53			/**
54			* @var ContextFactory
55			*/
56			private $contextFactory;
57
58			/**
59			* Constructor needs the columns descriptor to figure out appropriate filtering methods
60			* and translate identifiers.
61			*
62			* @param UqlExtensionContainer $extensionContainer
63			* @param DataSourceInterface $dataSource
64			* @param FilterConditionFactory $filterConditionFactory
65			* @param ContextFactory $contextFactory
66			* @param bool $caseSensitive
67			*/
68			public function __construct(
69			UqlExtensionContainer $extensionContainer,
70			DataSourceInterface $dataSource,
71			FilterConditionFactory $filterConditionFactory,
72			ContextFactory $contextFactory,
73			$caseSensitive = true
74			) {
75			$this->extensionContainer = $extensionContainer;
76			$this->dataSource = $dataSource;
77			$this->filterConditionFactory = $filterConditionFactory;
78			$this->contextFactory = $contextFactory;
79			$this->caseSensitive = $caseSensitive;
80
81			// Cache an array of data sources (name => object pairs) for reference during the interpretation
82			$this->dataSourceElements = array_combine(
83			array_map(
84			function (FieldInterface $element) use ($caseSensitive) {
85			return $caseSensitive ? $element->getUniqueName() : strtolower($element->getUniqueName());
86			},
87			$this->dataSource->getFields()
88			),
89			$this->dataSource->getFields()
90			);
91			}
92
93			/**
94			* Generate the filter objects corresponding to a UQL string.
95			*
96			* @param string $uql
97			*
98			* @return Filter
99			*/
100			public function interpret($uql)
101			{
102			if (empty(trim($uql))) {
103			return new Filter();
104			}
105
106			$parser = new Parser();
107			$AST = $parser->parse($uql);
108
109			return $this->buildFilter($AST);
110			}
111
112			/**
113			* Helper method: matches filtering operators to valid UQL operators
114			* in order to do Filter to UQL transformations
115			*
116			* @param string $method
117			*
118			* @throws UQLInterpreterException
119			* @return string
120			*/
121			public static function methodToUQLOperator($method)
122			{
123			$translationMap = [
124			FilterCondition::METHOD_STRING_EQ => "=",
125			FilterCondition::METHOD_STRING_LIKE => "~",
126			FilterCondition::METHOD_STRING_NEQ => "!=",
127			FilterCondition::METHOD_NUMERIC_GT => ">",
128			FilterCondition::METHOD_NUMERIC_GTE => ">=",
129			FilterCondition::METHOD_NUMERIC_EQ => "=",
130			FilterCondition::METHOD_NUMERIC_LTE => "<=",
131			FilterCondition::METHOD_NUMERIC_LT => "<",
132			FilterCondition::METHOD_NUMERIC_NEQ => "!=",
133			FilterCondition::METHOD_IN => "IN",
134			FilterCondition::METHOD_BOOLEAN => "is",
135			FilterCondition::METHOD_IS_NULL => "is null",
136			FilterCondition::METHOD_DATETIME_GT => "after",
137			FilterCondition::METHOD_DATETIME_GTE => "after or at",
138			FilterCondition::METHOD_DATETIME_EQ => "at",
139			FilterCondition::METHOD_DATETIME_LTE => "before or at",
140			FilterCondition::METHOD_DATETIME_LT => "before",
141			FilterCondition::METHOD_DATETIME_NEQ => "not at",
142			];
143
144			if (isset($translationMap[$method])) {
145			return $translationMap[$method];
146			}
147
148			throw new UQLInterpreterException("Can't translate filtering method '$method'' into a valid UQL operator");
149			}
150
151			/**
152			* Transforms a subtree of the AST into a concrete filter definition.
153			* This function recursively builds all sub-trees.
154			*
155			* @param ASTGroup\|ASTAssertion\|mixed $astSubtree
156			*
157			* TODO: This looks like it should not be public (it is only used in tests).
158			* We could move it and it's dependencies to its own class so that it can be tested
159			*
160			* @return Filter
161			* @throws \Exception
162			*/
163			public function buildFilter($astSubtree)
164			{
165			if ($astSubtree instanceof ASTGroup) {
166			return $this->buildFilterFromASTGroup($astSubtree);
167			}
168
169			if ($astSubtree instanceof ASTAssertion) {
170			$filterCondition = $this->buildFilterConditionFromASTAssertion($astSubtree);
171			// Single filter. Wrap into dummy filter collection for consistency.
172			$filter = new Filter();
173			$filter[] = $filterCondition;
174
175			return $filter;
176			}
177
178			throw new UQLInterpreterException('Unexpected Abstract Syntax Tree element');
179			}
180
181			/**
182			* Translate <operator> tokens into Filter Methods.
183			*
184			* @param string $token
185			* @param FieldInterface $dataSourceElement
186			*
187			* @throws UQLInterpreterException
188			* @return mixed
189			*/
190			public function translateOperator($token, FieldInterface $dataSourceElement)
191			{
192			$translationTable = [
193			"T_OP_LT" => [
194			FilterCondition::METHOD_NUMERIC_LT,
195			FilterCondition::METHOD_DATETIME_LT,
196			],
197			"T_OP_LTE" => [
198			FilterCondition::METHOD_NUMERIC_LTE,
199			FilterCondition::METHOD_DATETIME_LTE,
200			],
201			"T_OP_EQ" => [
202			FilterCondition::METHOD_NUMERIC_EQ,
203			FilterCondition::METHOD_STRING_EQ,
204			FilterCondition::METHOD_DATETIME_EQ,
205			FilterCondition::METHOD_BOOLEAN,
206			],
207			"T_OP_GTE" => [
208			FilterCondition::METHOD_NUMERIC_GTE,
209			FilterCondition::METHOD_DATETIME_GTE,
210			],
211			"T_OP_GT" => [
212			FilterCondition::METHOD_NUMERIC_GT,
213			FilterCondition::METHOD_DATETIME_GT,
214			],
215			"T_OP_NEQ" => [
216			FilterCondition::METHOD_NUMERIC_NEQ,
217			FilterCondition::METHOD_STRING_NEQ,
218			FilterCondition::METHOD_DATETIME_NEQ,
219			],
220			"T_OP_LIKE" => [
221			FilterCondition::METHOD_STRING_LIKE,
222			],
223			"T_OP_IN" => [
224			FilterCondition::METHOD_IN,
225			],
226			];
227
228			if (!isset($translationTable[$token])) {
229			throw new UQLInterpreterException('Unable to translate token ' . $token . ' to a valid filtering method. Unknown token.');
230			}
231			$possibleMethods = $translationTable[$token];
232
233			// See if any of the methods is the default of the data type
234			$dataType = $dataSourceElement->getDataType();
235			foreach ($possibleMethods as $possibleMethod) {
236			if ($possibleMethod === $dataType->getDefaultFilterMethod()) {
237			return $possibleMethod;
238			}
239			}
240
241			// Else, just accept the first one in the available methods
242			foreach ($possibleMethods as $possibleMethod) {
243			if (in_array($possibleMethod, $dataType->getAvailableFilterMethods())) {
244			return $possibleMethod;
245			}
246			}
247
248			throw new UQLInterpreterException('Unable to translate token ' . $token . ' to a valid filtering method. No methods are valid for the data type "' . $dataType->getName() . '" for data element "' . $dataSourceElement->getUniqueName() . '"');
249			}
250
251			/**
252			* Translate Lexer <logic> tokens into Filter Condition Types.
253			*
254			* @param $token
255			*
256			* @return string
257			* @throws \Exception
258			*/
259			private function translateLogic($token)
260			{
261			$translationTable = [
262			"T_LOGIC_AND" => Filter::CONDITION_TYPE_AND,
263			"T_LOGIC_OR" => Filter::CONDITION_TYPE_OR,
264			"T_LOGIC_XOR" => Filter::CONDITION_TYPE_XOR,
265			];
266
267			if (isset($translationTable[$token])) {
268			return $translationTable[$token];
269			}
270
271			throw new \Exception('Unable to translate token ' . $token . ' to a valid filter condition type.');
272			}
273
274			/**
275			* Trim and clean up the value to be set in the filter.
276			*
277			* @param mixed $value
278			*
279			* @return mixed
280			*/
281			private function parseValue($value)
282			{
283			if (is_bool($value)) {
284			return $value ? "1" : "0";
285			}
286
287			return trim($value, "\"'");
288			}
289
290			/**
291			* @param ASTFunctionCall $functionCall
292			*
293			* @return mixed
294			* @throws FunctionNotFoundException
295			* @throws UQLInterpreterException
296			*/
297			private function callFunction(ASTFunctionCall $functionCall)
298			{
299			$functionName = $functionCall->getFunctionName();
300			$function = $this->extensionContainer->getFunction($functionName);
301			$arguments = $this->getFunctionArguments($functionCall, $function);
302
303			try {
304			return $function->call($arguments);
305			} catch (\Exception $e) {
306			throw new UQLInterpreterException("The execution of function '$functionName' failed. Please check the arguments are valid. (" . $e->getMessage() . ")");
307			}
308			}
309
310			/**
311			* @param array $elements
312			*
313			* @return array
314			*/
315			private function parseArray($elements)
316			{
317			$array = [];
318			foreach ($elements as $element) {
319			$array[] = $this->parseValue($element);
320			}
321
322			return $array;
323			}
324
325			/**
326			* @param string $identifier
327			*
328			* @return Field
329			* @throws UQLInterpreterException
330			*/
331			private function matchDataSourceElement($identifier)
332			{
333			if (!$this->caseSensitive) {
334			$identifier = strtolower($identifier);
335			}
336
337			if (!isset($this->dataSourceElements[$identifier])) {
338			throw new UQLInterpreterException('Unknown filtering element "' . $identifier . '"');
339			}
340
341			return $this->dataSourceElements[$identifier];
342			}
343
344			/**
345			* @param ASTAssertion $astSubtree
346			*
347			* @throws UQLInterpreterException
348			*
349			* @return array\|mixed
350			*/
351			private function getValue(ASTAssertion $astSubtree)
352			{
353			if ($astSubtree->getValue() instanceof ASTFunctionCall) {
354			return $this->callFunction($astSubtree->getValue());
355			}
356
357			if ($astSubtree->getOperator() == 'T_OP_IN') {
358			if (!($astSubtree->getValue() instanceof ASTArray)) {
359			throw new UQLInterpreterException('Only arrays are valid arguments for IN statements');
360			}
361
362			return $this->parseArray($astSubtree->getValue()->getElements());
363			}
364
365			return $this->parseValue($astSubtree->getValue());
366			}
367
368			/**
369			* @param ASTAssertion $astSubtree
370			*
371			* @throws UQLInterpreterException
372			*
373			* @return FilterCondition
374			*/
375			private function buildFilterConditionFromASTAssertion(ASTAssertion $astSubtree)
376			{
377			$field = $this->matchDataSourceElement($astSubtree->getIdentifier());
378			$method = $this->translateOperator($astSubtree->getOperator(), $field);
379			$value = $this->getValue($astSubtree);
380
381			return $this->filterConditionFactory->create($field, $method, $value);
382			}
383
384			/**
385			* @param ASTGroup $astSubtree
386			*
387			* @throws UQLInterpreterException
388			* @throws \Exception
389			*
390			* @return Filter
391			*/
392			private function buildFilterFromASTGroup(ASTGroup $astSubtree)
393			{
394			$filter = new Filter();
395			$condition = $this->translateLogic($astSubtree->getLogic());
396			$filter->setConditionType($condition);
397			foreach ($astSubtree->getElements() as $element) {
398			if ($element instanceof ASTGroup) {
399			$filter[] = $this->buildFilterFromASTGroup($element);
400			}
401			if ($element instanceof ASTAssertion) {
402			$filter[] = $this->buildFilterConditionFromASTAssertion($element);
403			}
404			}
405
406			return $filter;
407			}
408
409			/**
410			* @param ASTFunctionCall $functionCall
411			* @param UqlFunctionInterface $function
412			*
413			* @return array
414			*/
415			private function getFunctionArguments(ASTFunctionCall $functionCall, $function)
416			{
417			$arguments = $functionCall->getArguments();
418
419			if ($function instanceof ContextAwareUqlFunction) {
420			$context = $this->contextFactory->create($this->dataSource->getEntityClass());
421			array_unshift($arguments, $context);
422			}
423
424			return $arguments;
425			}
426			}
427

netdudes / DataSourceryBundle

Push — master ( f7f008...2d0f6c )

Interpreter::callFunction() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like