Lechimp\Dicto\Graph\QueryImpl

Complexity

Total Complexity

28

Size/Duplication

Total Lines	188
Duplicated Lines	8.51 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

96.94%

Importance

Changes

0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	predicate_factory()	0	3	1
A	expand()	0	6	1
A	extract()	0	6	1
A	filter()	0	6	1
B	run()	0	23	5
A	switch_run_command()	0	15	4
A	run_expand()	8	10	3
A	run_extract()	0	11	3
A	run_filter()	8	11	3
A	add_result()	0	7	2
A	filter_by_types()	0	5	1
A	expand_relations()	0	9	1
A	expand_target()	0	5	1

<?php
/******************************************************************************
 * An implementation of dicto (scg.unibe.ch/dicto) in and for PHP.
 * 
 * Copyright (c) 2016 Richard Klees <richard.klees@rwth-aachen.de>
 *
 * This software is licensed under The MIT License. You should have received 
 * a copy of the license along with the code.
 */

namespace Lechimp\Dicto\Graph;

class QueryImpl implements Query {
    /**
     * @var Graph
     */
    protected $graph;

    /**
     * @var array[]
     */
    protected $steps;

    public function __construct(Graph $graph) {
        $this->graph = $graph;
        $this->steps = [];
        $this->predicate_factory = new PredicateFactory();

The property predicate_factory does not exist. Did you maybe forget to declare it?

    }

    /**
     * @inheritdocs
     */
    public function predicate_factory() {
        return $this->predicate_factory;
    }

    /**
     * @inheritdocs
     */
    public function expand(\Closure $expander) {
        $clone = clone $this;
        $clone->steps[] = ["expand", $expander];
        assert('$this->steps != $clone->steps');
        return $clone;
    }

    /**
     * @inheritdocs
     */
    public function extract(\Closure $extractor) {
        $clone = clone $this;
        $clone->steps[] = ["extract", $extractor];
        assert('$this->steps != $clone->steps');
        return $clone;
    }

    /**
     * @inheritdocs
     */
    public function filter(Predicate $predicate) {
        $clone = clone $this;
        $clone->steps[] = ["filter", $predicate];
        assert('$this->steps != $clone->steps');
        return $clone;
    }

    /**
     * @inheritdocs
     */
    public function run($result) {
        $steps = $this->steps;
        if (count($steps) > 0 && $steps[0][0] == "filter") {
            $nodes = $this->graph->nodes($steps[0][1]);
            array_shift($steps);
        }
        else {
            $nodes = $this->graph->nodes();
        }
        $nodes = $this->add_result($nodes, $result);

        foreach ($this->steps as $step) {
            $nodes = $this->switch_run_command($nodes, $step);
        }

        $res = array();
        while ($nodes->valid()) {
            $val = $nodes->current();
            $res[] = $val[1];
            $nodes->next();
        }
        return $res;
    }

    /**
     * @return  Iterator<[Node,mixed]>

The doc-type Iterator<[Node,mixed]> could not be parsed: Expected "|" or "end of type", but got "<" at position 8. (view supported doc-types)

     */
    protected function switch_run_command(\Iterator $nodes, $step) {
        list($cmd,$par) = $step;
        if ($cmd == "expand") {
            return $this->run_expand($nodes, $par);
        }
        elseif ($cmd == "extract") {
            return $this->run_extract($nodes, $par);
        }
        elseif ($cmd == "filter") {
            return $this->run_filter($nodes, $par);
        }
        else {
            throw new \LogicException("Unknown command: $cmd");
        }
    }

    /**
     * @return  Iterator<[Node,mixed]>

The doc-type Iterator<[Node,mixed]> could not be parsed: Expected "|" or "end of type", but got "<" at position 8. (view supported doc-types)

     */
    protected function run_expand(\Iterator $nodes, \Closure $clsr) {
        while ($nodes->valid()) {

This code seems to be duplicated across your project.

            list($node, $result) = $nodes->current();
            // TODO: let closure return an Iterator too.
            foreach($clsr($node) as $new_node) {
                yield [$new_node, $result];
            }
            $nodes->next();
        }
    }

    /**
     * @return  Iterator<[Node,mixed]>

The doc-type Iterator<[Node,mixed]> could not be parsed: Expected "|" or "end of type", but got "<" at position 8. (view supported doc-types)

     */
    protected function run_extract(\Iterator $nodes, \Closure $clsr) {
        while ($nodes->valid()) {
            list($node, $result) = $nodes->current();
            if (is_object($result)) {
                $result = clone($result);
            }
            $clsr($node, $result);
            yield [$node, $result];
            $nodes->next();
        }
    }

    /**
     * @return  Iterator<[Node,mixed]>

The doc-type Iterator<[Node,mixed]> could not be parsed: Expected "|" or "end of type", but got "<" at position 8. (view supported doc-types)

     */
    protected function run_filter(\Iterator $nodes, Predicate $predicate) {
        $clsr = $predicate->compile();
        while ($nodes->valid()) {

This code seems to be duplicated across your project.

            $val = $nodes->current();
            list($node, $result) = $val;
            if ($clsr($node, $result)) {
                yield $val;
            }
            $nodes->next();
        }
    }

    /**
     * @return  Iterator<[Node,mixed]>

The doc-type Iterator<[Node,mixed]> could not be parsed: Expected "|" or "end of type", but got "<" at position 8. (view supported doc-types)

     */
    protected function add_result(\Iterator $nodes, &$result) {
        while ($nodes->valid()) {
            $node = $nodes->current();
            yield [$node, $result];
            $nodes->next();
        }
    }

    // Convenience Functions

    /**
     * @inheritdocs
     */
    public function filter_by_types(array $types) {
        return $this->filter($this->predicate_factory()->_custom(function(Node $n) use ($types) {
            return in_array($n->type(), $types);
        }));
    }

    /**
     * @inheritdocs
     */
    public function expand_relations(array $types) {
        return $this->expand(function(Node $n) use (&$types) {
            return array_filter
                ( $n->relations()
                , function(Relation $r) use (&$types) {
                    return in_array($r->type(), $types);
                });
        });
    }

    /**
     * @inheritdocs
     */
    public function expand_target() {
        return $this->expand(function(Relation $r) {
            return [$r->target()];
        });
    }
}