Temperature and humidity attributes now added for actuator battery status

.pre-commit-config.yaml

@@ -23,19 +23,12 @@ repos:
   rev: v1.0.0
   hooks:
   - id: check-json5
--   repo: https://github.com/PyCQA/flake8
-    rev: 7.1.1
-    hooks:
-    -   id: flake8
-        additional_dependencies: [
-            'flake8-blind-except',
-            'flake8-bugbear',
-            'flake8-comprehensions',
-            'flake8-implicit-str-concat',
-            'flake8-logging-format',
-            'pydocstyle>=5.0.0',
-        ]
-        exclude: ^wadas/ui/.*|demo/.*
+- repo: https://github.com/astral-sh/ruff-pre-commit
+  rev: v0.3.5
+  hooks:
+    - id: ruff
+      args: [--no-fix]
+      exclude: ^wadas/ui/.*|demo/.*
 -   repo: https://github.com/pycqa/isort
     rev: 5.13.2
     hooks:

wadas/_version.py

@@ -17,5 +17,5 @@
 # Date: 2024-08-14
 # Description: module to keep track of WADAS version
 
-__version__ = "v1.0.0.a5"
+__version__ = "v1.0.0.a6"
 __dbversion__ = __version__

wadas/domain/actuator.py

@@ -76,6 +76,8 @@ def from_json(cls, s: str) -> "Command":
 class ActuatorBatteryStatus:
     actuator_id: str
     voltage: float
+    temperature: float
+    humidity: float
     time_stamp: datetime.datetime = field(default_factory=datetime.datetime.now)
 
     def to_json(self) -> str:
@@ -84,6 +86,8 @@ def to_json(self) -> str:
                 "actuator_id": self.actuator_id,
                 "voltage": self.voltage,
                 "time_stamp": self.time_stamp.isoformat(),
+                "temperature": self.temperature,
+                "humidity": self.humidity,
             }
         )
 

wadas/domain/actuator_server_app.py

@@ -193,6 +193,10 @@ async def receive_battery_status(actuator_id: str, payload: dict = Body(...)):
     if voltage is None:
         raise HTTPException(status_code=400, detail="Missing 'volt' in payload")
 
+    # We accept the possibility that temperature or humidity are null if sensor is not plugged
+    temperature = payload.get("payload", {}).get("temperature")
+    humidity = payload.get("payload", {}).get("humidity")
+
     # Timestamp set by server
     ts = datetime.datetime.now()
 
@@ -201,9 +205,21 @@ async def receive_battery_status(actuator_id: str, payload: dict = Body(...)):
         actuator_id=actuator_id,
         voltage=voltage,
         time_stamp=ts,
+        temperature=temperature,
+        humidity=humidity,
     )
     actuator.battery_status = battery_status
-    logger.info("Received actuator %s battery status: %s", actuator_id, voltage)
+
+    if temperature and humidity:
+        logger.info(
+            "Received actuator %s battery status: %s V, temperature: %s °, humidity: %s %%",
+            actuator_id,
+            voltage,
+            temperature,
+            humidity,
+        )
+    else:
+        logger.info("Received actuator %s battery status: %s V.", actuator_id, voltage)
 
     # Persist in DB
     if db := DataBase.get_enabled_db():

wadas/domain/database.py

@@ -499,6 +499,14 @@ def update_db_version(self):
                         """
                     )
                 )
+            elif cur_db_version <= "v1.0.0.a5":
+                DataBase.run_query(
+                    text("ALTER TABLE actuator_battery_status ADD COLUMN temperature FLOAT NULL;")
+                )
+                DataBase.run_query(
+                    text("ALTER TABLE actuator_battery_status ADD COLUMN humidity FLOAT NULL;")
+                )
+
             DataBase.run_query(text(f"UPDATE db_metadata SET version='{__dbversion__}';"))
             logger.info("Database updated from %s to %s", cur_db_version, __dbversion__)
         except Exception:
@@ -950,6 +958,8 @@ def domain_to_orm(domain_object, foreign_key=None):
                 actuator_id=foreign_key[0],
                 time_stamp=domain_object.time_stamp,
                 voltage=domain_object.voltage,
+                temperature=domain_object.temperature,
+                humidity=domain_object.humidity,
             )
         elif isinstance(domain_object, ActuatorTemperatureStatus):
             return ORMActuatorTemperature(

wadas/domain/db_model.py

@@ -208,6 +208,8 @@ class ActuatorBatteryStatus(Base):
     actuator_id = Column(Integer, ForeignKey("actuators.id"), primary_key=True, nullable=False)
     time_stamp = Column(MySQLDATETIME6(timezone=True), primary_key=True, nullable=False)
     voltage = Column(Float)
+    temperature = Column(Float, nullable=True)
+    humidity = Column(Float, nullable=True)
 
 
 class ActuatorTemperatureStatus(Base):