test

Author: tomkralidis

pycsw/core/pygeofilter_ext.py

@@ -68,6 +68,7 @@ def bbox(self, node, lhs):
     def ilike(self, node, lhs):
         LOGGER.debug('Overriding ILIKE filter handling')
         LOGGER.debug(f'Term: {node.pattern}')
+        print("DBTYPE", self._pycsw_dbtype)
         if (str(lhs.prop) == 'dataset.anytext' and
                 self._pycsw_dbtype.startswith('postgres')):
             if '%' not in node.pattern:
@@ -91,11 +92,11 @@ class PycswCSWFES11Parser(FES11Parser):
     def parse(self, input_):
         return FES11Parser().parse(input_)
 
-    @fhandle('BBOX')
-    def geometry_bbox(self, node: Element, lhs, rhs, crs=None):
-        minx = rhs.geometry['coordinates'][0][0][1]
-        miny = rhs.geometry['coordinates'][0][0][0]
-        maxx = rhs.geometry['coordinates'][0][2][1]
-        maxy = rhs.geometry['coordinates'][0][2][0]
+#    @fhandle('BBOX')
+#    def geometry_bbox(self, node: Element, lhs, rhs, crs=None):
+#        minx = rhs.geometry['coordinates'][0][0][1]
+#        miny = rhs.geometry['coordinates'][0][0][0]
+#        maxx = rhs.geometry['coordinates'][0][2][1]
+#        maxy = rhs.geometry['coordinates'][0][2][0]
 
-        return ast.BBox(lhs, minx, miny, maxx, maxy, crs)
+#        return ast.BBox(lhs, minx, miny, maxx, maxy, crs)

pycsw/ogc/csw/csw2.py

@@ -825,6 +825,8 @@ def getrecords(self):
             self.parent.kvp['startposition'] = 1
 
         # query repository
+        print("AST", self.parent.kvp['constraint']['ast'])
+        print("AST", dir(self.parent.kvp['constraint']['ast']))
         LOGGER.debug('Querying repository with constraint: %s,\
         sortby: %s, typenames: %s, maxrecords: %s, startposition: %s',
         self.parent.kvp['constraint'], self.parent.kvp['sortby'], self.parent.kvp['typenames'],
@@ -1005,6 +1007,8 @@ def getrecords(self):
                         self.parent.response = self.exceptionreport(
                         'NoApplicableCode', 'service',
                         'Record serialization failed: %s' % str(err))
+                        import traceback
+                        print(traceback.format_exc())
                         return self.parent.response
 
         if len(dsresults) > 0:  # return DistributedSearch results
@@ -1545,13 +1549,16 @@ def _write_record(self, recobj, queryables):
                 self.parent.context.md_core_model['mappings']['pycsw:Links'])
 
                 if rlinks:
-                    for link in util.jsonify_links(rlinks):
+                    if isinstance(rlinks, str):
+                        rlinks = util.jsonify_links(rlinks)
+                    for link in rlinks:
+                        print("LINK", link)
                         ref = etree.SubElement(record, util.nspath_eval('dct:references',
                             self.parent.context.namespaces))
                         if link.get('protocol'):
                             ref.attrib['scheme'] = link['protocol']
 
-                        ref.text = link['url']
+                        ref.text = link.get('url', link.get('href'))
 
                 for i in ['dc:relation', 'dct:modified', 'dct:abstract']:
                     val = util.getqattr(recobj, queryables[i]['dbcol'])