kopia lustrzana https://github.com/bugout-dev/moonstream
Fixed time filters in Bugout Event Provider
Bugout journal `created_at:` filters require ISO formatted time.pull/137/head
rodzic
2ac0277d81
commit
0f3be7c700
|
@ -4,7 +4,6 @@ Event providers powered by Bugout journals.
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
import json
|
import json
|
||||||
import logging
|
import logging
|
||||||
import time
|
|
||||||
from typing import Dict, List, Optional, Tuple
|
from typing import Dict, List, Optional, Tuple
|
||||||
|
|
||||||
from bugout.app import Bugout
|
from bugout.app import Bugout
|
||||||
|
@ -202,12 +201,11 @@ class BugoutEventProvider:
|
||||||
raise BugoutEventProviderError(
|
raise BugoutEventProviderError(
|
||||||
"Cannot return next event for a stream boundary which is current."
|
"Cannot return next event for a stream boundary which is current."
|
||||||
)
|
)
|
||||||
|
end_time = datetime.fromtimestamp(stream_boundary.end_time).isoformat()
|
||||||
operator = ">="
|
operator = ">="
|
||||||
if stream_boundary.include_end:
|
if stream_boundary.include_end:
|
||||||
operator = ">"
|
operator = ">"
|
||||||
additional_constraints.append(
|
additional_constraints.append(f"created_at:{operator}{end_time}")
|
||||||
f"created_at:{operator}{stream_boundary.end_time}"
|
|
||||||
)
|
|
||||||
|
|
||||||
final_query = " ".join(self.query + additional_constraints)
|
final_query = " ".join(self.query + additional_constraints)
|
||||||
search_results = bugout_client.search(
|
search_results = bugout_client.search(
|
||||||
|
@ -244,12 +242,11 @@ class BugoutEventProvider:
|
||||||
raise BugoutEventProviderError(
|
raise BugoutEventProviderError(
|
||||||
"Cannot return previous event for a stream boundary starting at the beginning of time."
|
"Cannot return previous event for a stream boundary starting at the beginning of time."
|
||||||
)
|
)
|
||||||
|
start_time = datetime.fromtimestamp(stream_boundary.start_time).isoformat()
|
||||||
operator = "<="
|
operator = "<="
|
||||||
if stream_boundary.include_start:
|
if stream_boundary.include_start:
|
||||||
operator = "<"
|
operator = "<"
|
||||||
additional_constraints.append(
|
additional_constraints.append(f"created_at:{operator}{start_time}")
|
||||||
f"created_at:{operator}{stream_boundary.start_time}"
|
|
||||||
)
|
|
||||||
|
|
||||||
final_query = " ".join(self.query + additional_constraints)
|
final_query = " ".join(self.query + additional_constraints)
|
||||||
search_results = bugout_client.search(
|
search_results = bugout_client.search(
|
||||||
|
|
Ładowanie…
Reference in New Issue