Crash_Override/FreeDATA
1
0
Fork 0
mirror of https://github.com/DJ2LS/FreeDATA synced 2024-05-14 08:04:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARQ WIP - data event on IRS

Browse source
This commit is contained in:
DJ2LS 2023-12-30 23:00:27 +01:00
parent 424f4738c5
commit e40ff05190
2 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
modem/arq_session_irs.py
View file

@ -179,7 +179,7 @@ class ARQSessionIRS(arq_session.ARQSession):
self.log("ACK sent")
self.set_state(IRS_State.ENDED)
self.event_manager.send_arq_session_finished(
False, self.id, self.dxcall, self.total_length, True, self.state.name)
False, self.id, self.dxcall, self.total_length, True, self.state.name, data=self.received_data)
else:

8
modem/event_manager.py
View file

@ -1,3 +1,4 @@
import base64
import json
import structlog
@ -53,7 +54,9 @@ class EventManager:
}
self.broadcast(event)
def send_arq_session_finished(self, outbound: bool, session_id, dxcall, total_bytes, success: bool, state):
def send_arq_session_finished(self, outbound: bool, session_id, dxcall, total_bytes, success: bool, state, data=False):
if data:
data = base64.b64encode(data).decode("UTF-8")
direction = 'outbound' if outbound else 'inbound'
event = {
f"arq-transfer-{direction}": {
@ -62,6 +65,7 @@ class EventManager:
'total_bytes': total_bytes,
'success': success,
'state': state,
'data': data
}
}
self.broadcast(event)
self.broadcast(event)