Skip to content

Commit a69fe3c

Browse files
Yuri ZmytrakovYuri Zmytrakov
Yuri Zmytrakov
authored and
Yuri Zmytrakov
committed
dummy
1 parent 56af26d commit a69fe3c

File tree

3 files changed

+211
-88
lines changed

3 files changed

+211
-88
lines changed

‎README.md‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -634,3 +634,4 @@ The system uses a precise naming convention:
634634
- Ensures fair resource allocation among all clients
635635
636636
- **Examples**: Implementation examples are available in the [examples/rate_limit](examples/rate_limit) directory.
637+

‎stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py‎

Lines changed: 93 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
from stac_fastapi.core.base_database_logic import BaseDatabaseLogic
1919
from stac_fastapi.core.serializers import CollectionSerializer, ItemSerializer
20-
from stac_fastapi.core.utilities import bbox2polygon, get_max_limit
20+
from stac_fastapi.core.utilities import bbox2polygon, get_bool_env, get_max_limit
2121
from stac_fastapi.elasticsearch.config import AsyncElasticsearchSettings
2222
from stac_fastapi.elasticsearch.config import (
2323
ElasticsearchSettings as SyncElasticsearchSettings,
@@ -294,21 +294,94 @@ def apply_datetime_filter(
294294
if not datetime_search:
295295
return search, datetime_search
296296

297-
if "eq" in datetime_search:
298-
# For exact matches, include:
299-
# 1. Items with matching exact datetime
300-
# 2. Items with datetime:null where the time falls within their range
301-
should = [
302-
Q(
303-
"bool",
304-
filter=[
305-
Q("exists", field="properties.datetime"),
306-
Q("term", **{"properties__datetime": datetime_search["eq"]}),
307-
],
308-
),
309-
Q(
297+
# USE_DATETIME env var
298+
# True: Search by datetime, if null search by start/end datetime
299+
# False: Always search only by start/end datetime
300+
USE_DATETIME = get_bool_env("USE_DATETIME", default=True)
301+
302+
if USE_DATETIME:
303+
if "eq" in datetime_search:
304+
# For exact matches, include:
305+
# 1. Items with matching exact datetime
306+
# 2. Items with datetime:null where the time falls within their range
307+
should = [
308+
Q(
309+
"bool",
310+
filter=[
311+
Q("exists", field="properties.datetime"),
312+
Q(
313+
"term",
314+
**{"properties__datetime": datetime_search["eq"]},
315+
),
316+
],
317+
),
318+
Q(
319+
"bool",
320+
must_not=[Q("exists", field="properties.datetime")],
321+
filter=[
322+
Q("exists", field="properties.start_datetime"),
323+
Q("exists", field="properties.end_datetime"),
324+
Q(
325+
"range",
326+
properties__start_datetime={
327+
"lte": datetime_search["eq"]
328+
},
329+
),
330+
Q(
331+
"range",
332+
properties__end_datetime={"gte": datetime_search["eq"]},
333+
),
334+
],
335+
),
336+
]
337+
else:
338+
# For date ranges, include:
339+
# 1. Items with datetime in the range
340+
# 2. Items with datetime:null that overlap the search range
341+
should = [
342+
Q(
343+
"bool",
344+
filter=[
345+
Q("exists", field="properties.datetime"),
346+
Q(
347+
"range",
348+
properties__datetime={
349+
"gte": datetime_search["gte"],
350+
"lte": datetime_search["lte"],
351+
},
352+
),
353+
],
354+
),
355+
Q(
356+
"bool",
357+
must_not=[Q("exists", field="properties.datetime")],
358+
filter=[
359+
Q("exists", field="properties.start_datetime"),
360+
Q("exists", field="properties.end_datetime"),
361+
Q(
362+
"range",
363+
properties__start_datetime={
364+
"lte": datetime_search["lte"]
365+
},
366+
),
367+
Q(
368+
"range",
369+
properties__end_datetime={
370+
"gte": datetime_search["gte"]
371+
},
372+
),
373+
],
374+
),
375+
]
376+
377+
return (
378+
search.query(Q("bool", should=should, minimum_should_match=1)),
379+
datetime_search,
380+
)
381+
else:
382+
if "eq" in datetime_search:
383+
filter_query = Q(
310384
"bool",
311-
must_not=[Q("exists", field="properties.datetime")],
312385
filter=[
313386
Q("exists", field="properties.start_datetime"),
314387
Q("exists", field="properties.end_datetime"),
@@ -321,29 +394,10 @@ def apply_datetime_filter(
321394
properties__end_datetime={"gte": datetime_search["eq"]},
322395
),
323396
],
324-
),
325-
]
326-
else:
327-
# For date ranges, include:
328-
# 1. Items with datetime in the range
329-
# 2. Items with datetime:null that overlap the search range
330-
should = [
331-
Q(
332-
"bool",
333-
filter=[
334-
Q("exists", field="properties.datetime"),
335-
Q(
336-
"range",
337-
properties__datetime={
338-
"gte": datetime_search["gte"],
339-
"lte": datetime_search["lte"],
340-
},
341-
),
342-
],
343-
),
344-
Q(
397+
)
398+
else:
399+
filter_query = Q(
345400
"bool",
346-
must_not=[Q("exists", field="properties.datetime")],
347401
filter=[
348402
Q("exists", field="properties.start_datetime"),
349403
Q("exists", field="properties.end_datetime"),
@@ -356,13 +410,8 @@ def apply_datetime_filter(
356410
properties__end_datetime={"gte": datetime_search["gte"]},
357411
),
358412
],
359-
),
360-
]
361-
362-
return (
363-
search.query(Q("bool", should=should, minimum_should_match=1)),
364-
datetime_search,
365-
)
413+
)
414+
return search.query(filter_query), datetime_search
366415

367416
@staticmethod
368417
def apply_bbox_filter(search: Search, bbox: List):

‎stac_fastapi/opensearch/stac_fastapi/opensearch/database_logic.py‎

Lines changed: 117 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616

1717
from stac_fastapi.core.base_database_logic import BaseDatabaseLogic
1818
from stac_fastapi.core.serializers import CollectionSerializer, ItemSerializer
19-
from stac_fastapi.core.utilities import bbox2polygon, get_max_limit
19+
from stac_fastapi.core.utilities import bbox2polygon, get_bool_env, get_max_limit
2020
from stac_fastapi.extensions.core.transaction.request import (
2121
PartialCollection,
2222
PartialItem,
@@ -301,21 +301,118 @@ def apply_datetime_filter(
301301
if not datetime_search:
302302
return search, datetime_search
303303

304-
if "eq" in datetime_search:
305-
# For exact matches, include:
306-
# 1. Items with matching exact datetime
307-
# 2. Items with datetime:null where the time falls within their range
308-
should = [
309-
Q(
310-
"bool",
311-
filter=[
312-
Q("exists", field="properties.datetime"),
313-
Q("term", **{"properties__datetime": datetime_search["eq"]}),
314-
],
315-
),
316-
Q(
304+
# USE_DATETIME env var
305+
# True: Search by datetime, if null search by start/end datetime
306+
# False: Always search only by start/end datetime
307+
USE_DATETIME = get_bool_env("USE_DATETIME", default=True)
308+
309+
if USE_DATETIME:
310+
if "eq" in datetime_search:
311+
# For exact matches, include:
312+
# 1. Items with matching exact datetime
313+
# 2. Items with datetime:null where the time falls within their range
314+
should = [
315+
Q(
316+
"bool",
317+
filter=[
318+
Q("exists", field="properties.datetime"),
319+
Q(
320+
"term",
321+
**{"properties__datetime": datetime_search["eq"]},
322+
),
323+
],
324+
),
325+
Q(
326+
"bool",
327+
filter=[
328+
Q(
329+
"bool",
330+
should=[
331+
Q(
332+
"bool",
333+
must_not=[
334+
Q("exists", field="properties.datetime")
335+
],
336+
),
337+
Q("term", **{"properties__datetime": None}),
338+
],
339+
minimum_should_match=1,
340+
),
341+
Q("exists", field="properties.start_datetime"),
342+
Q("exists", field="properties.end_datetime"),
343+
Q(
344+
"range",
345+
properties__start_datetime={
346+
"lte": datetime_search["eq"]
347+
},
348+
),
349+
Q(
350+
"range",
351+
properties__end_datetime={"gte": datetime_search["eq"]},
352+
),
353+
],
354+
),
355+
]
356+
else:
357+
# For date ranges, include:
358+
# 1. Items with datetime in the range
359+
# 2. Items with datetime:null that overlap the search range
360+
should = [
361+
Q(
362+
"bool",
363+
filter=[
364+
Q("exists", field="properties.datetime"),
365+
Q(
366+
"range",
367+
properties__datetime={
368+
"gte": datetime_search["gte"],
369+
"lte": datetime_search["lte"],
370+
},
371+
),
372+
],
373+
),
374+
Q(
375+
"bool",
376+
filter=[
377+
Q(
378+
"bool",
379+
should=[
380+
Q(
381+
"bool",
382+
must_not=[
383+
Q("exists", field="properties.datetime")
384+
],
385+
),
386+
Q("term", **{"properties__datetime": None}),
387+
],
388+
minimum_should_match=1,
389+
),
390+
Q("exists", field="properties.start_datetime"),
391+
Q("exists", field="properties.end_datetime"),
392+
Q(
393+
"range",
394+
properties__start_datetime={
395+
"lte": datetime_search["lte"]
396+
},
397+
),
398+
Q(
399+
"range",
400+
properties__end_datetime={
401+
"gte": datetime_search["gte"]
402+
},
403+
),
404+
],
405+
),
406+
]
407+
408+
return (
409+
search.query(Q("bool", should=should, minimum_should_match=1)),
410+
datetime_search,
411+
)
412+
else:
413+
if "eq" in datetime_search:
414+
filter_query = Q(
317415
"bool",
318-
must_not=[Q("exists", field="properties.datetime")],
319416
filter=[
320417
Q("exists", field="properties.start_datetime"),
321418
Q("exists", field="properties.end_datetime"),
@@ -328,29 +425,10 @@ def apply_datetime_filter(
328425
properties__end_datetime={"gte": datetime_search["eq"]},
329426
),
330427
],
331-
),
332-
]
333-
else:
334-
# For date ranges, include:
335-
# 1. Items with datetime in the range
336-
# 2. Items with datetime:null that overlap the search range
337-
should = [
338-
Q(
339-
"bool",
340-
filter=[
341-
Q("exists", field="properties.datetime"),
342-
Q(
343-
"range",
344-
properties__datetime={
345-
"gte": datetime_search["gte"],
346-
"lte": datetime_search["lte"],
347-
},
348-
),
349-
],
350-
),
351-
Q(
428+
)
429+
else:
430+
filter_query = Q(
352431
"bool",
353-
must_not=[Q("exists", field="properties.datetime")],
354432
filter=[
355433
Q("exists", field="properties.start_datetime"),
356434
Q("exists", field="properties.end_datetime"),
@@ -363,13 +441,8 @@ def apply_datetime_filter(
363441
properties__end_datetime={"gte": datetime_search["gte"]},
364442
),
365443
],
366-
),
367-
]
368-
369-
return (
370-
search.query(Q("bool", should=should, minimum_should_match=1)),
371-
datetime_search,
372-
)
444+
)
445+
return search.query(filter_query), datetime_search
373446

374447
@staticmethod
375448
def apply_bbox_filter(search: Search, bbox: List):

0 commit comments

Comments
 (0)