socket fixed and kr_packet updated with compass_offset

utils/ether_service/entities/data/kr_packet.py

@@ -48,6 +48,7 @@ class KrPacketV2(BasicDataclass):
     ant_type: str
     latency: int
     processing_time: int
+    compass_offset: float = 0
 
     def __repr__(self):
         dt = (
@@ -59,6 +60,10 @@ class KrPacketV2(BasicDataclass):
             absolute_bearing += 360
         elif absolute_bearing > 359:
             absolute_bearing -= 360
+
+        if self.compass_offset != 0:
+            absolute_bearing += self.compass_offset
+
         return f"{dt}::{self.station_id}::" \
                f"frequency: {self.freq / 1000000}, " \
                f"DoA: {absolute_bearing}, " \

utils/ws_client.py

@@ -148,4 +148,7 @@ class WSClient:
                 exc_info = (ex.__class__, ex, ex.__traceback__)
                 logging.warning("WS error.", exc_info=exc_info)
                 self.ws = None
+            finally:
+                if session is not None:
+                    await session.close()
             await asyncio.sleep(0)