From 2504016bdcd4433d93d86d66c6bde193b51b1453 Mon Sep 17 00:00:00 2001 From: Laurent Date: Sun, 4 Jan 2026 14:44:17 +0100 Subject: [PATCH] fix date filters --- api-customer/src/controllers/telemetryController.py | 4 ++-- api-customer/src/services/mongo_service.py | 9 +++++++-- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/api-customer/src/controllers/telemetryController.py b/api-customer/src/controllers/telemetryController.py index 416d6625..3566992d 100644 --- a/api-customer/src/controllers/telemetryController.py +++ b/api-customer/src/controllers/telemetryController.py @@ -22,8 +22,8 @@ class TelemetryController: def sound(self): try: odata_filter = request.args.get("$filter") - start_date, end_date = self._extract_dates_from_odata(odata_filter) - return self._database_service.find_by_date("telemetry", start_date, end_date) + start_timestamp, end_timestamp = self._extract_dates_from_odata(odata_filter) + return self._database_service.find_by_date("telemetry", start_timestamp, end_timestamp) except Exception as e: logger.log_info(e) diff --git a/api-customer/src/services/mongo_service.py b/api-customer/src/services/mongo_service.py index 3e133311..40057e25 100644 --- a/api-customer/src/services/mongo_service.py +++ b/api-customer/src/services/mongo_service.py @@ -36,7 +36,7 @@ class MongoService: logger.log_info(e) def find_by_date(self, collection: str, filters: dict = None, timestamp_field: str = "created_at", - start_time: datetime = None, end_time: datetime = None): + start_time: int = None, end_time: int = None): try: collection = self._db[collection] query = filters.copy() if filters else {} @@ -48,7 +48,12 @@ class MongoService: if end_time: query[timestamp_field]["$lte"] = end_time - return list(collection.find(query)) + results = list(collection.find(query)) + for doc in results: + if "_id" in doc: + doc["_id"] = str(doc["_id"]) + + return results except Exception as e: logger.log_info(e) return []