Skip to content

Commit d9a8502

Browse files
committed
fix filter extension
1 parent a1f0770 commit d9a8502

File tree

2 files changed

+10
-10
lines changed

2 files changed

+10
-10
lines changed

stac_fastapi/core/stac_fastapi/core/core.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ async def get_search(
455455
sortby: Optional[str] = None,
456456
q: Optional[List[str]] = None,
457457
intersects: Optional[str] = None,
458-
filter: Optional[str] = None,
458+
filter_expr: Optional[str] = None,
459459
filter_lang: Optional[str] = None,
460460
**kwargs,
461461
) -> stac_types.ItemCollection:
@@ -503,12 +503,12 @@ async def get_search(
503503
for sort in sortby
504504
]
505505

506-
if filter:
507-
base_args["filter-lang"] = "cql2-json"
506+
if filter_expr:
507+
base_args["filter_lang"] = "cql2-json"
508508
base_args["filter"] = orjson.loads(
509-
unquote_plus(filter)
509+
unquote_plus(filter_expr)
510510
if filter_lang == "cql2-json"
511-
else to_cql2(parse_cql2_text(filter))
511+
else to_cql2(parse_cql2_text(filter_expr))
512512
)
513513

514514
if fields:
@@ -590,8 +590,8 @@ async def post_search(
590590
)
591591

592592
# only cql2_json is supported here
593-
if hasattr(search_request, "filter"):
594-
cql2_filter = getattr(search_request, "filter", None)
593+
if hasattr(search_request, "filter_expr"):
594+
cql2_filter = getattr(search_request, "filter_expr", None)
595595
try:
596596
search = self.database.apply_cql2_filter(search, cql2_filter)
597597
except Exception as e:

stac_fastapi/core/stac_fastapi/core/extensions/aggregation.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -338,7 +338,7 @@ async def aggregate(
338338
datetime: Optional[DateTimeType] = None,
339339
intersects: Optional[str] = None,
340340
filter_lang: Optional[str] = None,
341-
filter: Optional[str] = None,
341+
filter_expr: Optional[str] = None,
342342
aggregations: Optional[str] = None,
343343
ids: Optional[List[str]] = None,
344344
bbox: Optional[BBox] = None,
@@ -380,8 +380,8 @@ async def aggregate(
380380
if datetime:
381381
base_args["datetime"] = self._format_datetime_range(datetime)
382382

383-
if filter:
384-
base_args["filter"] = self.get_filter(filter, filter_lang)
383+
if filter_expr:
384+
base_args["filter"] = self.get_filter(filter_expr, filter_lang)
385385
aggregate_request = EsAggregationExtensionPostRequest(**base_args)
386386
else:
387387
# Workaround for optional path param in POST requests

0 commit comments

Comments
 (0)