FreeDATA/modem/event_manager.py
2023-12-30 23:00:27 +01:00

71 lines
2.3 KiB
Python

import base64
import json
import structlog
class EventManager:
def __init__(self, queues):
self.queues = queues
self.logger = structlog.get_logger('Event Manager')
self.lastpttstate = False
def broadcast(self, data):
for q in self.queues:
self.logger.debug(f"Event: ", ev=data)
q.put(data)
def send_ptt_change(self, on:bool = False):
if (on == self.lastpttstate):
return
self.lastpttstate= on
self.broadcast({"ptt": bool(on)})
def send_scatter_change(self, data):
self.broadcast({"scatter": json.dumps(data)})
def send_buffer_overflow(self, data):
self.broadcast({"buffer-overflow": str(data)})
def send_custom_event(self, **event_data):
self.broadcast(event_data)
def send_arq_session_new(self, outbound: bool, session_id, dxcall, total_bytes, state):
direction = 'outbound' if outbound else 'inbound'
event = {
f"arq-transfer-{direction}": {
'session_id': session_id,
'dxcall': dxcall,
'total_bytes': total_bytes,
'state': state,
}
}
self.broadcast(event)
def send_arq_session_progress(self, outbound: bool, session_id, dxcall, received_bytes, total_bytes, state):
direction = 'outbound' if outbound else 'inbound'
event = {
f"arq-transfer-{direction}": {
'session_id': session_id,
'dxcall': dxcall,
'received_bytes': received_bytes,
'total_bytes': total_bytes,
'state': state,
}
}
self.broadcast(event)
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}": {
'session_id': session_id,
'dxcall': dxcall,
'total_bytes': total_bytes,
'success': success,
'state': state,
'data': data
}
}
self.broadcast(event)