|
24 | 24 | from stac_fastapi.core.base_settings import ApiBaseSettings |
25 | 25 | from stac_fastapi.core.datetime_utils import format_datetime_range |
26 | 26 | from stac_fastapi.core.models.links import PagingLinks |
27 | | -from stac_fastapi.core.redis_utils import redis_pagination_links |
28 | 27 | from stac_fastapi.core.serializers import CollectionSerializer, ItemSerializer |
29 | 28 | from stac_fastapi.core.session import Session |
30 | 29 | from stac_fastapi.core.utilities import filter_fields, get_bool_env |
@@ -426,6 +425,8 @@ async def all_collections( |
426 | 425 | ] |
427 | 426 |
|
428 | 427 | if redis_enable: |
| 428 | + from stac_fastapi.core.redis_utils import redis_pagination_links |
| 429 | + |
429 | 430 | await redis_pagination_links( |
430 | 431 | current_url=str(request.url), |
431 | 432 | token=token, |
@@ -758,7 +759,7 @@ async def post_search( |
758 | 759 |
|
759 | 760 | body_limit = None |
760 | 761 | try: |
761 | | - if request.method == "POST" and request.body(): |
| 762 | + if request.method == "POST" and await request.body(): |
762 | 763 | body_data = await request.json() |
763 | 764 | body_limit = body_data.get("limit") |
764 | 765 | except Exception: |
@@ -904,6 +905,8 @@ async def post_search( |
904 | 905 | links.extend(collection_links) |
905 | 906 |
|
906 | 907 | if redis_enable: |
| 908 | + from stac_fastapi.core.redis_utils import redis_pagination_links |
| 909 | + |
907 | 910 | await redis_pagination_links( |
908 | 911 | current_url=str(request.url), |
909 | 912 | token=token_param, |
|
0 commit comments