_generate_triggers()

Complexity

Conditions

7

Size

Total Lines

38

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	1
CRAP Score	47.3747

Importance

Changes	5
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	_query_compiling()	0	29	6

# ~*~ coding: utf-8 ~*~
#-
# OSMAlchemy - OpenStreetMap to SQLAlchemy bridge
# Copyright (c) 2016 Dominik George <nik@naturalnet.de>
#
# Permission is hereby granted, free of charge, to any person obtaining a copy
# of this software and associated documentation files (the "Software"), to deal
# in the Software without restriction, including without limitation the rights
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
# copies of the Software, and to permit persons to whom the Software is
# furnished to do so, subject to the following conditions:
#
# The above copyright notice and this permission notice shall be included in all
# copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.
#
# Alternatively, you are free to use OSMAlchemy under Simplified BSD, The
# MirOS Licence, GPL-2+, LGPL-2.1+, AGPL-3+ or the same terms as Python
# itself.

""" Trigger code for live OSMAlchemy/Overpass integration. """

import datetime

The import datetime seems to be unused.

from sqlalchemy import inspect

Unused inspect imported from sqlalchemy

from sqlalchemy.event import listens_for
from sqlalchemy.orm import Query
from weakref import WeakSet

standard import "from weakref import WeakSet" comes before "from sqlalchemy import inspect"

from .online import _get_single_element_by_id

Unused _get_single_element_by_id imported from online

from .util import _analyse_clause, _import_osm_xml

Unused _import_osm_xml imported from util

def _generate_triggers(osmalchemy, maxage=60*60*24):

The argument maxage seems to be unused.

    """ Generates the triggers for online functionality.

      osmalchemy - reference to the OSMAlchemy instance to be configured
      maxage - maximum age of objects before they are updated online, in seconds
    """

    _visited_queries = WeakSet()

    @listens_for(Query, "before_compile")
    def _query_compiling(query):

The variable _query_compiling seems to be unused.

        # Get the session associated with the query:
        session = query.session

The variable session seems to be unused.

        # Prevent recursion by skipping already-seen queries
        if query in _visited_queries:
            return
        else:
            _visited_queries.add(query)

        # Check whether this query affects our model
        affected_models = set([c["type"] for c in query.column_descriptions])
        our_models = set([osmalchemy.node, osmalchemy.way,  osmalchemy.relation,

Exactly one space required after comma

                          osmalchemy.element])
        if affected_models.isdisjoint(our_models):
            # None of our models is affected
            return

        # Check whether this query filters elements
        # Online update will only run on a specified set, not all data
        if query.whereclause is None:
            # No filters
            return

        # Analyse where clause looking for all looked-up fields
        tree = {}
        for target in our_models.intersection(affected_models):
            tree[target.__name__] = _analyse_clause(query.whereclause, target)