update

Author: tomkralidis

pygeoapi/api/__init__.py

@@ -68,7 +68,7 @@
     filter_dict_by_key_value, filter_providers_by_type, get_api_rules,
     get_base_url, get_provider_by_type, get_provider_default, get_typed_value,
     get_crs_from_uri, get_supported_crs_list, render_j2_template, to_json,
-    get_choice_from_headers, get_from_headers
+    get_choice_from_headers, get_from_headers, get_dataset_formatters
 )
 
 LOGGER = logging.getLogger(__name__)
@@ -1142,6 +1142,13 @@ def describe_collections(api: API, request: APIRequest,
                 'title': l10n.translate('Items as HTML', request.locale),  # noqa
                 'href': f'{api.get_collections_url()}/{k}/items?f={F_HTML}'  # noqa
             })
+            for key, value in get_dataset_formatters(v).items():
+                collection['links'].append({
+                    'type': value.mimetype,
+                    'rel': 'items',
+                    'title': l10n.translate(f'Items as {value.name}', request.locale),  # noqa
+                    'href': f'{api.get_collections_url()}/{k}/items?f={key}'  # noqa
+                })
 
         # OAPIF Part 2 - list supported CRSs and StorageCRS
         if collection_data_type in ['edr', 'feature']:

pygeoapi/api/itemtypes.py

@@ -51,6 +51,7 @@
 from pygeoapi.api import evaluate_limit
 from pygeoapi.formatter.base import FormatterSerializationError
 from pygeoapi.linked_data import geojson2jsonld
+from pygeoapi.openapi import get_oas_30_parameters
 from pygeoapi.plugin import load_plugin, PLUGINS
 from pygeoapi.provider.base import (
     ProviderGenericError, ProviderTypeError, SchemaType)
@@ -59,7 +60,7 @@
                            filter_dict_by_key_value, get_crs_from_uri,
                            get_provider_by_type, get_supported_crs_list,
                            modify_pygeofilter, render_j2_template, str2bool,
-                           to_json, transform_bbox)
+                           to_json, transform_bbox, get_dataset_formatters)
 
 from . import (
     APIRequest, API, SYSTEM_LOCALE, F_JSON, FORMAT_TYPES, F_HTML, F_JSONLD,
@@ -355,13 +356,7 @@ def get_collection_items(
             err.ogc_exception_code, err.message)
 
     LOGGER.debug('Validating requested format')
-    dataset_formatters = {}
-    for key, value in PLUGINS['formatter'].items():
-        df2 = load_plugin('formatter', {'name': key})
-        dataset_formatters[df2.name] = df2
-    for df in collections[dataset].get('formatters', []):
-        df2 = load_plugin('formatter', df)
-        dataset_formatters[df2.name] = df2
+    dataset_formatters = get_dataset_formatters(collections[dataset])
 
     if not request.is_valid(dataset_formatters.keys()):
         return api.get_format_exception(request)
@@ -1189,14 +1184,19 @@ def get_oas_30(cfg: dict, locale: str) -> tuple[list[dict[str, str]], dict[str,
                 v.get('limits', {})
             )
 
+            dataset_formatters = get_dataset_formatters(v)
+            coll_f_parameter = deepcopy(get_oas_30_parameters(cfg, locale))['f']  # noqa
+            for key, value in dataset_formatters.items():
+                coll_f_parameter['schema']['enum'].append(key)
+
             paths[items_path] = {
                 'get': {
                     'summary': f'Get {title} items',
                     'description': description,
                     'tags': [k],
                     'operationId': f'get{k.capitalize()}Features',
                     'parameters': [
-                        {'$ref': '#/components/parameters/f'},
+                        coll_f_parameter,
                         {'$ref': '#/components/parameters/lang'},
                         {'$ref': '#/components/parameters/bbox'},
                         coll_limit,

pygeoapi/formatter/base.py

@@ -39,7 +39,7 @@ def __init__(self, formatter_def: dict):
         """
         Initialize object
 
-        :param formatter_def: formatter definition
+        param formatter_def: formatter definition
 
         :returns: pygeoapi.formatter.base.BaseFormatter
         """

pygeoapi/util.py

@@ -80,6 +80,7 @@
 from pygeoapi import __version__
 from pygeoapi import l10n
 from pygeoapi.models import config as config_models
+from pygeoapi.plugin import load_plugin, PLUGINS
 from pygeoapi.provider.base import ProviderTypeError
 
 
@@ -1113,3 +1114,27 @@ def get_choice_from_headers(headers: dict,
 
     # Return one or all choices
     return sorted_choices if all else sorted_choices[0]
+
+
+def get_dataset_formatters(dataset: dict) -> dict:
+    """
+    Helper function to derive all formatters for an itemtype
+
+    :param dataset: `dict` of dataset resource definition
+
+    :returns: `dict` of formatters
+    """
+
+    dataset_formatters = {}
+
+    print(dataset)
+    for key, value in PLUGINS['formatter'].items():
+        print("PLUGINS")
+        df2 = load_plugin('formatter', {'name': key})
+        dataset_formatters[df2.name] = df2
+    for df in dataset.get('formatters', []):
+        print("CUSTOM")
+        df2 = load_plugin('formatter', df)
+        dataset_formatters[df2.name] = df2
+
+    return dataset_formatters