Index: docs/SDD/Comms_Overview.puml =================================================================== diff -u -rcaca75be9a284ac5f98c078ec47c2e826ac5e980 -r6d2ef8c97f4bb34204e95811839b3995000c47c1 --- docs/SDD/Comms_Overview.puml (.../Comms_Overview.puml) (revision caca75be9a284ac5f98c078ec47c2e826ac5e980) +++ docs/SDD/Comms_Overview.puml (.../Comms_Overview.puml) (revision 6d2ef8c97f4bb34204e95811839b3995000c47c1) @@ -5,9 +5,9 @@ participant "Can::CanInterface" as CANI participant "CloudConnectController" as LRC participant "Can::MessageDispatcher" as MDISP -participant "CloudConnectClient" as AI -participant "Unix Domain\nSocket" as UDS -participant "AgentSimController" as ASC +participant "CloudConnectServer" as RS +participant "Unix Domain\nSocket (app)" as UDS +participant "Luis application" as APP == CAN frame → assembled message == @@ -17,19 +17,25 @@ == Message handling & forwarding == -LRC -> LRC : look up policy in _msgHandling\n(drop / send_always / send_delta) -LRC -> AI : send(topic, sequence, protobuf payload) -AI -> UDS : write(CloudConnectFrame frame) +LRC -> LRC : look up policy in _msgHandling\n(Drop / SendAlways / SendDelta) +LRC -> RS : send(topic, sequence, protobuf payload) +RS -> UDS : write(CloudConnectFrame frame) +UDS -> APP : readyRead -== AgentSim receives == +== Cloud delivery (planned — Phase 2/3) == -UDS -> ASC : readyRead → onReadyRead() -ASC -> ASC : feed() → didMessageReceive() +note over LRC + The Connectivity Agent socket has been removed. + The spool/publish pipeline that replaces it + (MessageSpool → Router → MqttPublisher, with + SpoolDrain replaying on reconnect) is not yet + implemented — see docs/SDD/AgentMigrationPlan.md. +end note == Connection events == -AI -> LRC : didConnect()\n→ (future) -AI -> LRC : didDisconnect()\n→ onAgentDisconnect()\n resets _msgCache received flags -AI -> LRC : didMessageReceive()\n→ (future inbound) +RS -> LRC : didConnect()\n→ (future) serial-number handshake +RS -> LRC : didDisconnect()\n→ (future) +RS -> LRC : didMessageReceive()\n→ (future inbound) @enduml