STAC API: map collection to links

Author: tomkralidis

pycsw/ogc/api/records.py

@@ -1214,23 +1214,24 @@ def record2json(record, url, collection, mode='ogcapi-records'):
     if record.metadata_type in ['application/json', 'application/geo+json']:
         rec = json.loads(record.metadata)
         if rec.get('stac_version') is not None and rec['type'] == 'Feature' and mode == 'stac-api':
+            collection_ = rec.get('collection', collection)
             LOGGER.debug('Returning native STAC representation')
             rec['links'].extend([{
                 'rel': 'self',
                 'type': 'application/geo+json',
-                'href': f"{url}/collections/{collection}/items/{rec['id']}"
+                'href': f"{url}/collections/{collection_}/items/{rec['id']}"
                 }, {
                 'rel': 'root',
                 'type': 'application/json',
                 'href': url
                 }, {
                 'rel': 'parent',
                 'type': 'application/json',
-                'href': f"{url}/collections/{collection}"
+                'href': f"{url}/collections/{collection_}"
                 }, {
                 'rel': 'collection',
                 'type': 'application/json',
-                'href': f"{url}/collections/{collection}"
+                'href': f"{url}/collections/{collection_}"
                 }
             ])
 

tests/functionaltests/suites/stac_api/test_stac_api_functional.py

@@ -389,6 +389,11 @@ def test_items(config):
 
     content = json.loads(api.items({}, cql_json, {})[2])
     assert content['numberMatched'] == 1
+    for feature in content['features']:
+        for link in feature['links']:
+            if link['rel'] in ['self', 'parent', 'collection']:
+                collection_match = f"collections/{cql_json['collections'][0]}"
+                assert collection_match in link['href']
 
     cql_json = {
         'filter-lang': 'cql2-json',