Normalize primary communication around UART
This commit is contained in:
@@ -7,14 +7,14 @@ from protocol import (
|
||||
toggle_ignition_request,
|
||||
toggle_sensor_fault_request,
|
||||
)
|
||||
from transport import RS485Transport
|
||||
from transport import UARTTransport
|
||||
|
||||
|
||||
class PicoSimulator:
|
||||
def __init__(self, controller):
|
||||
self.transport = RS485Transport(controller)
|
||||
self.transport = UARTTransport(controller)
|
||||
self.last_status = None
|
||||
self.primary_link = "rs485"
|
||||
self.primary_link = "uart"
|
||||
self.backup_link_available = True
|
||||
self.messages_sent = 0
|
||||
self.messages_received = 0
|
||||
@@ -40,7 +40,7 @@ class PicoSimulator:
|
||||
|
||||
if response.get("type") == "error":
|
||||
if self.last_status:
|
||||
self.last_status["network"]["rs485_connected"] = False
|
||||
self.last_status["network"]["uart_connected"] = False
|
||||
self.last_status["network"]["communication_lost"] = True
|
||||
self.add_comms_to_status(self.last_status)
|
||||
return self.last_status
|
||||
@@ -53,7 +53,7 @@ class PicoSimulator:
|
||||
"sensor_health": {},
|
||||
"relays": {},
|
||||
"network": {
|
||||
"rs485_connected": False,
|
||||
"uart_connected": False,
|
||||
"communication_lost": True,
|
||||
"wifi_enabled": False,
|
||||
"wifi_override_active": False,
|
||||
@@ -63,7 +63,7 @@ class PicoSimulator:
|
||||
}
|
||||
|
||||
self.last_status = response["data"]
|
||||
self.last_status["network"]["rs485_connected"] = self.transport.connected
|
||||
self.last_status["network"]["uart_connected"] = self.transport.connected
|
||||
self.last_status["network"]["communication_lost"] = False
|
||||
self.add_comms_to_status(self.last_status)
|
||||
return self.last_status
|
||||
@@ -87,10 +87,10 @@ class PicoSimulator:
|
||||
def toggle_sensor_fault(self, sensor):
|
||||
return self.send_message(toggle_sensor_fault_request(sensor))
|
||||
|
||||
def disconnect_rs485(self):
|
||||
def disconnect_uart(self):
|
||||
self.transport.disconnect()
|
||||
|
||||
def restore_rs485(self):
|
||||
def restore_uart(self):
|
||||
self.transport.restore()
|
||||
|
||||
def set_latency(self, latency_ms):
|
||||
@@ -103,7 +103,7 @@ class PicoSimulator:
|
||||
return {
|
||||
"primary": self.primary_link,
|
||||
"backup_available": self.backup_link_available,
|
||||
"rs485_connected": self.transport.connected,
|
||||
"uart_connected": self.transport.connected,
|
||||
"messages_sent": self.messages_sent,
|
||||
"messages_received": self.messages_received,
|
||||
"last_message_time": self.last_message_time,
|
||||
|
||||
Reference in New Issue
Block a user