Use verbatim context and inject it even in plain JSON

Author: avillar

pygeoapi/api/itemtypes.py

@@ -956,6 +956,9 @@ def get_collection_item(api: API, request: APIRequest,
     # locale (or fallback default locale)
     l10n.set_response_language(headers, prv_locale, request.locale)
 
+    config_dataset = api.config['resources'][dataset]
+    linked_data = config_dataset.get('linked-data')
+
     if request.format == F_HTML:  # render
         tpl_config = api.get_dataset_templates(dataset)
         content['title'] = l10n.translate(collections[dataset]['title'],
@@ -973,7 +976,12 @@ def get_collection_item(api: API, request: APIRequest,
                                      content, request.locale)
         return headers, HTTPStatus.OK, content
 
-    elif request.format == F_JSONLD:
+    elif request.format == F_JSONLD or (
+            request.format == F_JSON
+            and linked_data
+            and all(linked_data.get(k)
+                    for k in ('context', 'inject_verbatim_context'))
+      ):
         content = geojson2jsonld(
             api, content, dataset, uri, (p.uri_field or 'id')
         )

pygeoapi/linked_data.py

@@ -195,59 +195,71 @@ def geojson2jsonld(cls, data: dict, dataset: str,
     context = linked_data.get('context', []).copy()
     templates = cls.get_dataset_templates(dataset)
 
-    defaultVocabulary = {
-        'schema': 'https://schema.org/',
-        'gsp': 'http://www.opengis.net/ont/geosparql#',
-        'type': '@type'
-    }
-
-    if identifier:
-        # Expand properties block
-        data.update(data.pop('properties'))
-
-        # Include multiple geometry encodings
-        if (data.get('geometry') is not None):
-            jsonldify_geometry(data)
-
-        data['@id'] = identifier
-
+    if (identifier and context
+            and linked_data.get('inject_verbatim_context', False)):
+        ldjsonData = {
+            '@context': context,
+            **data
+        }
+        if replace_id_field := linked_data.get('replace_id_field'):
+            ldjsonData[replace_id_field] = identifier
     else:
-        # Collection of jsonld
-        defaultVocabulary.update({
-            'features': 'schema:itemListElement',
-            'FeatureCollection': 'schema:itemList'
-        })
-
-        ds_url = url_join(cls.get_collections_url(), dataset)
-        data['@id'] = ds_url
-
-        for i, feature in enumerate(data['features']):
-            # Get URI for each feature
-            identifier_ = feature.get(id_field,
-                                      feature['properties'].get(id_field, ''))
-            if not is_url(str(identifier_)):
-                identifier_ = f"{ds_url}/items/{feature['id']}"  # noqa
 
-            # Include multiple geometry encodings
-            if feature.get('geometry') is not None:
-                jsonldify_geometry(feature)
-
-            data['features'][i] = {
-                '@id': identifier_,
-                'type': 'schema:Place',
-                **feature.pop('properties'),
-                **feature
-            }
-
-    if data.get('timeStamp', False):
-        data['https://schema.org/sdDatePublished'] = data.pop('timeStamp')
+        defaultVocabulary = {
+            'schema': 'https://schema.org/',
+            'gsp': 'http://www.opengis.net/ont/geosparql#',
+            'type': '@type'
+        }
 
-    data['links'] = data.pop('links')
+        if identifier:
+            # Expand properties block
+            data.update(data.pop('properties'))
 
-    ldjsonData = {
-        '@context': [defaultVocabulary, *(context or [])],
-        **data
-    }
+            # Include multiple geometry encodings
+            if (data.get('geometry') is not None):
+                jsonldify_geometry(data)
+
+            data['@id'] = identifier
+
+        else:
+            # Collection of jsonld
+            defaultVocabulary.update({
+                'features': 'schema:itemListElement',
+                'FeatureCollection': 'schema:itemList'
+            })
+
+            ds_url = url_join(cls.get_collections_url(), dataset)
+            data['@id'] = ds_url
+
+            for i, feature in enumerate(data['features']):
+                # Get URI for each feature
+                identifier_ = feature.get(
+                    id_field,
+                    feature['properties'].get(id_field, '')
+                )
+                if not is_url(str(identifier_)):
+                    identifier_ = f"{ds_url}/items/{feature['id']}"  # noqa
+
+                # Include multiple geometry encodings
+                if feature.get('geometry') is not None:
+                    jsonldify_geometry(feature)
+
+                data['features'][i] = {
+                    '@id': identifier_,
+                    'type': 'schema:Place',
+                    **feature.pop('properties'),
+                    **feature
+                }
+
+        if data.get('timeStamp', False):
+            data['https://schema.org/sdDatePublished'] = data.pop('timeStamp')
+
+        data['links'] = data.pop('links')
+
+        ldjsonData = {
+            '@context': [defaultVocabulary, *(context or [])],
+            **data
+        }
 
     if identifier:
         # Render jsonld template for single item