fix backoff

Author: MarcoGlauser

backoff.py

@@ -2,7 +2,7 @@
 
 
 class Backoff:
-    def __init__(self, initial_backoff=30, max_backoff=300, backoff_increment=30, counter_size=8):
+    def __init__(self, initial_backoff=10, max_backoff=60, backoff_increment=10, counter_size=8):
         self.current_backoff = initial_backoff
         self.max_backoff = max_backoff
         self.backoff_increment = backoff_increment
@@ -19,4 +19,4 @@ def backoff(self):
             self.current_backoff = min(self.current_backoff + self.backoff_increment, self.max_backoff)
 
     def _sleep(self):
-        time.sleep(5)
+        time.sleep(self.current_backoff)

recalibrate_s8.py

@@ -0,0 +1,5 @@
+from sensors.s8 import S8
+
+if __name__ == "__main__":
+    s8 = S8()
+    s8.force_calibration()

sensors/s8.py

@@ -1,4 +1,5 @@
 from dataclasses import dataclass
+from time import sleep
 
 import serial
 
@@ -8,6 +9,10 @@
 s8_abc_status = b"\xfe\x03\x00\x1f\x00\x01\xa1\xc3"
 s8_abc_enable = b"\xfe\x06\x00\x1f\x00\xb4\xac\x74"
 
+s8_clear_hr1 = b"\xfe\x06\x00\x00\x00\x00\x9D\xC5"
+s8_read_hr1  = b"\xfe\x03\x00\x00\x00\x01\x90\x05"
+s8_start_calibration = b"\xFE\x06\x00\x01\x7c\x06\x6C\xC7"
+
 
 @dataclass
 class ModbusResponse:
@@ -25,14 +30,8 @@ def __init__(self, response: bytes):
         self.data = response[3:-2]
         self.crc = response[-2:]
         self.message_without_crc = response[:-2]
-
-        print(f"Address: {self.address}")
-        print(f"Function: {self.function}")
-        print(f"Byte Count: {self.byte_count}")
-        print(f"Data: {self.data}")
-        print(f"CRC: {self.crc}")
-        print(f"Generated CRC: {self.generate_crc()}")
-        print(f"Data as int: {self.data_as_int()}")
+        if self.crc != self.generate_crc():
+            raise ValueError("CRC Mismatch")
 
 
     def data_as_int(self):
@@ -56,23 +55,30 @@ def __init__(self):
         super().__init__()
         self.serial = serial.Serial("/dev/ttyUSB0", 9600, 8, "N", 1, timeout=1)
 
-        abc_status = self.send_command(s8_abc_enable, 8)
-        print(f"ABC Status: {abc_status.data_as_int()}")
+        self.send_command(s8_abc_enable)
 
     def read_response(self, size) -> ModbusResponse:
         output = None
         while not output:
             output = self.serial.read(size)
         return ModbusResponse(output)
 
-    def send_command(self, command: bytes, expected_response_size:int) -> ModbusResponse:
+    def force_calibration(self):
+        self.send_command(s8_clear_hr1)
+        calibration_ack = self.send_command(s8_start_calibration)
+        print({"starting calibration": calibration_ack})
+        sleep(4)
+        calibration_result = self.send_command(s8_read_hr1)
+        print({"calibration finished": calibration_result})
+
+
+    def send_command(self, command: bytes, expected_response_size:int = 100) -> ModbusResponse:
         self.serial.flush()
         self.serial.write(command)
         return self.read_response(expected_response_size)
 
     def read_data(self):
-        response = self.send_command(s8_co2, 7)
-        print({"carbon_dioxide": response.data_as_int()})
+        response = self.send_command(s8_co2,7)
         return {"carbon_dioxide": response.data_as_int()}
 
     def home_assistant_auto_discovery(self) -> [str, dict]: