SOBD is not Exported (#451)

* Bug fixed. (#450)

* Added connection notification. (#450)

* Using SOBD. (#450)

Author: ATATC

leads_comm_serial/sobd/__init__.py

@@ -1 +1 @@
-from leads_comm_serial.sobd import *
+from leads_comm_serial.sobd.sobd import *

leads_comm_serial/sobd/sobd.py

@@ -3,7 +3,7 @@
 from serial import Serial as _Serial
 
 from leads import require_config as _require_config, Device as _Device, L as _L
-from leads.comm import Entity as _Entity, Callback as _Callback, Service as _Service
+from leads.comm import Entity as _Entity, Callback as _Callback, Service as _Service, ConnectionBase as _ConnectionBase
 from leads_comm_serial.connection import SerialConnection
 from leads_comm_serial.identity import AutoIdentity
 
@@ -72,6 +72,11 @@ def __init__(self, sobd: SOBD) -> None:
         super().__init__()
         self._sobd: SOBD = sobd
 
+    @_override
+    def on_connect(self, service: _Service, connection: _ConnectionBase) -> None:
+        _L.debug(f"SOBD connected on {self._sobd.port()}")
+
+
     @_override
     def on_receive(self, service: _Service, msg: bytes) -> None:
         self.super(service=service, msg=msg)

leads_vec/devices.py

@@ -6,13 +6,16 @@
     FRONT_VIEW_CAMERA, LEFT_VIEW_CAMERA, RIGHT_VIEW_CAMERA, REAR_VIEW_CAMERA, VisualDataContainer, BRAKE_INDICATOR, \
     SFT, read_device_marker, has_controller, POWER_CONTROLLER, WHEEL_SPEED_CONTROLLER, ACCELEROMETER
 from leads_arduino import ArduinoMicro, WheelSpeedSensor, VoltageSensor, Accelerometer, Acceleration
+from leads_comm_serial import SOBD
 from leads_gpio import NMEAGPSReceiver, LEDGroup, LED, LEDGroupCommand, LEDCommand, Entire, Transition
 from leads_vec.config import Config
 from leads_video import Base64Camera, get_camera
 
 config: Config = require_config()
 GPS_ONLY: int = config.get("gps_only", False)
 BAUD_RATE: int = config.get("baud_rate", 9600)
+SOBD_PORT: int = config.get("sobd_port", "auto")
+SOBD_PASSWORD: int = config.get("sobd_password", "")
 POWER_CONTROLLER_PORT: str = config.get("power_controller_port", "auto")
 WHEEL_SPEED_CONTROLLER_PORT: str = config.get("wheel_speed_controller_port", "auto")
 GPS_RECEIVER_PORT: str = config.get("gps_receiver_port", "auto")
@@ -80,6 +83,14 @@ def read(self) -> DataContainer:
         return DataContainer(**wsc, **general) if len(visual) < 1 else VisualDataContainer(**visual, **wsc, **general)
 
 
+@device("obd", MAIN_CONTROLLER, (SOBD_PORT, BAUD_RATE, SOBD_PASSWORD))
+class OBD(SOBD):
+    @override
+    def initialize(self, *parent_tags: str) -> None:
+        mark_device(self, "OBD")
+        super().initialize(*parent_tags)
+
+
 @controller(POWER_CONTROLLER, MAIN_CONTROLLER, (POWER_CONTROLLER_PORT, BAUD_RATE))
 class PowerController(ArduinoMicro):
     @override