add sort to item collection route

Author: jonhealy1

CHANGELOG.md

@@ -10,12 +10,16 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ### Added
 
+- Sortby functionality to the item collection route.
+
 ### Changed
 
 - Changed assets serialization to prevent mapping explosion while allowing asset inforamtion to be indexed. [#341](https://github.com/stac-utils/stac-fastapi-elasticsearch-opensearch/pull/341)
 
 ### Fixed
 
+- Fixed issue where sortby was not accepting the default sort where a + or - was not specified before the field value ie. localhost:8081/collections/{collection_id}/items?sortby=id.
+
 ## [v6.2.1] - 2025-09-02
 
 ### Added

stac_fastapi/core/stac_fastapi/core/core.py

@@ -5,6 +5,7 @@
 from datetime import datetime as datetime_type
 from datetime import timezone
 from enum import Enum
+from types import SimpleNamespace
 from typing import List, Optional, Set, Type, Union
 from urllib.parse import unquote_plus, urljoin
 
@@ -287,6 +288,7 @@ async def item_collection(
         bbox: Optional[BBox] = None,
         datetime: Optional[str] = None,
         limit: Optional[int] = None,
+        sortby: Optional[str] = None,
         token: Optional[str] = None,
         **kwargs,
     ) -> stac_types.ItemCollection:
@@ -296,7 +298,7 @@ async def item_collection(
             collection_id (str): The identifier of the collection to read items from.
             bbox (Optional[BBox]): The bounding box to filter items by.
             datetime (Optional[str]): The datetime range to filter items by.
-            limit (int): The maximum number of items to return.
+            sortby (Optional[str]]): Sort spec like "-datetime". Bare fields imply ascending.
             token (str): A token used for pagination.
             request (Request): The incoming request.
 
@@ -313,6 +315,16 @@ async def item_collection(
 
         base_url = str(request.base_url)
 
+        es_sort = None
+        if sortby:
+            specs = []
+            for s in sortby:
+                field = s[1:]
+                direction = "desc" if s[0] == "-" else "asc"
+                specs.append(SimpleNamespace(field=field, direction=direction))
+            if specs:
+                es_sort = self.database.populate_sort(specs)
+
         collection = await self.get_collection(
             collection_id=collection_id, request=request
         )
@@ -346,7 +358,7 @@ async def item_collection(
         items, maybe_count, next_token = await self.database.execute_search(
             search=search,
             limit=limit,
-            sort=None,
+            sort=es_sort,
             token=token,
             collection_ids=[collection_id],
             datetime_search=datetime_search,

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/app.py

@@ -7,7 +7,12 @@
 from fastapi import FastAPI
 
 from stac_fastapi.api.app import StacApi
-from stac_fastapi.api.models import create_get_request_model, create_post_request_model
+from stac_fastapi.api.models import (
+    ItemCollectionUri,
+    create_get_request_model,
+    create_post_request_model,
+    create_request_model,
+)
 from stac_fastapi.core.core import (
     BulkTransactionsClient,
     CoreClient,
@@ -39,6 +44,7 @@
     TransactionExtension,
 )
 from stac_fastapi.extensions.core.filter import FilterConformanceClasses
+from stac_fastapi.extensions.core.sort import SortConformanceClasses
 from stac_fastapi.extensions.third_party import BulkTransactionExtension
 from stac_fastapi.sfeos_helpers.aggregation import EsAsyncBaseAggregationClient
 from stac_fastapi.sfeos_helpers.filter import EsAsyncBaseFiltersClient
@@ -54,6 +60,7 @@
 
 database_logic = DatabaseLogic()
 
+
 filter_extension = FilterExtension(
     client=EsAsyncBaseFiltersClient(database=database_logic)
 )
@@ -114,6 +121,17 @@
 
 post_request_model = create_post_request_model(search_extensions)
 
+items_get_request_model = create_request_model(
+    model_name="ItemCollectionUri",
+    base_model=ItemCollectionUri,
+    extensions=[
+        SortExtension(
+            conformance_classes=[SortConformanceClasses.ITEMS],
+        )
+    ],
+    request_type="GET",
+)
+
 app_config = {
     "title": os.getenv("STAC_FASTAPI_TITLE", "stac-fastapi-elasticsearch"),
     "description": os.getenv("STAC_FASTAPI_DESCRIPTION", "stac-fastapi-elasticsearch"),
@@ -128,6 +146,7 @@
     ),
     "search_get_request_model": create_get_request_model(search_extensions),
     "search_post_request_model": post_request_model,
+    "items_get_request_model": items_get_request_model,
     "route_dependencies": get_route_dependencies(),
 }
 

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/database/query.py

@@ -82,6 +82,7 @@ def populate_sort_shared(sortby: List) -> Optional[Dict[str, Dict[str, str]]]:
         directly used in search requests.
         Always includes 'id' as secondary sort to ensure unique pagination tokens.
     """
+    print("sortbx: ", sortby)
     if sortby:
         sort_config = {s.field: {"order": s.direction} for s in sortby}
         sort_config.setdefault("id", {"order": "asc"})