fix: aggregated_data model

agent/src/config.py

@@ -8,6 +8,7 @@ def try_parse(type, value: str):
         return None
 
 
+USER_ID = 1
 # MQTT config
 MQTT_BROKER_HOST = os.environ.get("MQTT_BROKER_HOST") or "mqtt"
 MQTT_BROKER_PORT = try_parse(int, os.environ.get("MQTT_BROKER_PORT")) or 1883

agent/src/domain/aggregated_data.py

@@ -9,4 +9,5 @@ from domain.gps import Gps
 class AggregatedData:
     accelerometer: Accelerometer
     gps: Gps
-    time: datetime
+    timestamp: datetime
+    user_id: int

agent/src/file_datasource.py

@@ -1,6 +1,9 @@
 from csv import reader
 from datetime import datetime
+from domain.accelerometer import Accelerometer
+from domain.gps import Gps
 from domain.aggregated_data import AggregatedData
+import config
 
 
 class FileDatasource:
@@ -13,6 +16,12 @@ class FileDatasource:
 
     def read(self) -> AggregatedData:
         """Метод повертає дані отримані з датчиків"""
+        return AggregatedData(
+            Accelerometer(1, 2, 3),
+            Gps(4, 5),
+            datetime.now(),
+            config.USER_ID,
+        )
 
     def startReading(self, *args, **kwargs):
         """Метод повинен викликатись перед початком читання даних"""

agent/src/schema/aggregated_data_schema.py

@@ -6,4 +6,5 @@ from schema.gps_schema import GpsSchema
 class AggregatedDataSchema(Schema):
     accelerometer = fields.Nested(AccelerometerSchema)
     gps = fields.Nested(GpsSchema)
-    time = fields.DateTime("iso")
+    timestamp = fields.DateTime("iso")
+    user_id = fields.Int()