File tree Expand file tree Collapse file tree 2 files changed +7
-3
lines changed
elasticsearch/stac_fastapi/elasticsearch
opensearch/stac_fastapi/opensearch Expand file tree Collapse file tree 2 files changed +7
-3
lines changed Original file line number Diff line number Diff line change 1212from starlette .requests import Request
1313
1414from elasticsearch import exceptions , helpers # type: ignore
15+ from stac_fastapi .core .base_database_logic import BaseDatabaseLogic
1516from stac_fastapi .core .database_logic import (
1617 COLLECTIONS_INDEX ,
1718 DEFAULT_SORT ,
@@ -124,7 +125,7 @@ async def delete_item_index(collection_id: str):
124125
125126
126127@attr .s
127- class DatabaseLogic :
128+ class DatabaseLogic ( BaseDatabaseLogic ) :
128129 """Database logic."""
129130
130131 client = AsyncElasticsearchSettings ().create_client
Original file line number Diff line number Diff line change 1515from starlette .requests import Request
1616
1717from stac_fastapi .core import serializers
18+ from stac_fastapi .core .base_database_logic import BaseDatabaseLogic
1819from stac_fastapi .core .database_logic import (
1920 COLLECTIONS_INDEX ,
2021 DEFAULT_SORT ,
@@ -145,7 +146,7 @@ async def delete_item_index(collection_id: str):
145146
146147
147148@attr .s
148- class DatabaseLogic :
149+ class DatabaseLogic ( BaseDatabaseLogic ) :
149150 """Database logic."""
150151
151152 client = AsyncSearchSettings ().create_client
@@ -274,7 +275,9 @@ async def get_all_collections(
274275 # Ensure we have a valid sort value for next_token
275276 next_token_values = hits [- 1 ].get ("sort" )
276277 if next_token_values :
277- next_token = next_token_values [0 ]
278+ next_token = urlsafe_b64encode (
279+ json .dumps (next_token_values ).encode ()
280+ ).decode ()
278281
279282 return collections , next_token
280283
You can’t perform that action at this time.
0 commit comments