def _constructSolrQuery()

in plugins/product_type/atom/Writer.py [0:0]
42 lines of code
20 McCabe index (conditional complexity)

    def _constructSolrQuery(self, startIndex, entriesPerPage, parameters, facets):
        queries = []
        filterQueries = []

        for key, value in parameters.items():
            if key == 'keyword':
                queries.append(urllib.parse.quote(value))
            elif key == 'layers' and value == 'true':
                filterQueries.append('-product_type_identifier:*_SRC')
            elif key == 'layers' and value == 'false':
                filterQueries.append('product_type_identifier:*_SRC')
            elif key == 'product_type_identifier':
                filterQueries.append('product_type_identifier:'+value)
            elif key == 'startTime':
                queries.append('product_type_last_updated:['+value+'%20TO%20*]')
            elif key == 'endTime':
                queries.append('product_type_last_updated:[*%20TO%20'+value+']')
            elif key == 'bbox':
                coordinates = value.split(",")
                filterQueries.append('Spatial-Geometry:[' + coordinates[1] + ',' + coordinates[0] + '%20TO%20' + coordinates[3] + ',' + coordinates[2] + ']')
            elif key == 'id':
                queries.append('id:' + self._urlEncodeSolrQueryValue(value))

        for key, value in facets.items():
            if type(value) is list:
                if (len(value) == 1):
                    filterQueries.append(key + ':' + self._urlEncodeSolrQueryValue(value[0]))
                else:
                    filterQueries.append(key + ':(' + '+OR+'.join([ self._urlEncodeSolrQueryValue(x) for x in value ]) + ")")
            else:    
                filterQueries.append(key + ':' + self._urlEncodeSolrQueryValue(value))

        if len(queries) == 0:
            queries.append('*:*')

        query = 'q='+'+AND+'.join(queries)+'&version=2.2&indent=on&wt=json'

        if len(filterQueries) > 0:
            query += '&fq='+'+AND+'.join(filterQueries)
        
        if self.facet:
            query += '&rows=0&facet=true&facet.limit=-1&facet.mincount=1&'
            query += '&'.join(['facet.field=' + facet for facet in self._configuration.get('solr', 'facets').split(',')])
        else:
            query += '&start='+str(startIndex)+'&rows='+str(entriesPerPage)
            query += '&sort=' + self._configuration.get('solr', 'sort')

        logging.debug('solr query: '+query)

        return query