2023-11-15 22:34:26 +00:00
|
|
|
import time
|
2023-11-12 18:56:15 +00:00
|
|
|
import ujson as json
|
2023-11-11 19:01:15 +00:00
|
|
|
class STATES:
|
|
|
|
def __init__(self, statequeue):
|
2023-11-17 09:22:45 +00:00
|
|
|
|
|
|
|
# state related settings
|
2023-11-11 19:01:15 +00:00
|
|
|
self.statequeue = statequeue
|
2023-11-14 18:26:11 +00:00
|
|
|
self.newstate = None
|
2023-11-17 09:22:45 +00:00
|
|
|
self.last = time.time()
|
|
|
|
|
|
|
|
# modem related states
|
|
|
|
# not every state is needed to publish, yet
|
|
|
|
# TODO can we reduce them?
|
2023-11-11 19:01:15 +00:00
|
|
|
self.channel_busy = False
|
|
|
|
self.channel_busy_slot = [False, False, False, False, False]
|
|
|
|
self.is_codec2_traffic = False
|
2023-11-12 18:56:15 +00:00
|
|
|
self.is_modem_running = False
|
2023-11-17 10:07:29 +00:00
|
|
|
self.is_modem_busy = False
|
2023-11-12 22:22:53 +00:00
|
|
|
self.is_beacon_running = False
|
2023-11-13 19:26:27 +00:00
|
|
|
self.is_arq_state = False
|
|
|
|
self.is_arq_session = False
|
2023-11-17 09:22:45 +00:00
|
|
|
self.is_transmitting = False
|
2023-11-13 19:26:27 +00:00
|
|
|
self.arq_session_state = 'disconnected'
|
2023-11-13 17:11:55 +00:00
|
|
|
self.audio_dbfs = 0
|
2023-11-17 09:58:07 +00:00
|
|
|
self.dxcallsign: bytes = b"ZZ9YY-0"
|
|
|
|
self.dxgrid: bytes = b"------"
|
2023-11-12 22:22:53 +00:00
|
|
|
|
2023-11-17 09:37:50 +00:00
|
|
|
self.radio_frequency = 0
|
|
|
|
self.radio_mode = None
|
|
|
|
self.radio_bandwidth = 0
|
|
|
|
self.radio_rf_power = 0
|
|
|
|
|
2023-11-17 01:39:04 +00:00
|
|
|
def sendStateUpdate (self):
|
2023-11-17 11:54:26 +00:00
|
|
|
self.statequeue.put(self.newstate)
|
2023-11-17 01:39:04 +00:00
|
|
|
|
2023-11-12 22:22:53 +00:00
|
|
|
|
2023-11-11 19:01:15 +00:00
|
|
|
def set(self, key, value):
|
|
|
|
setattr(self, key, value)
|
2023-11-14 18:26:11 +00:00
|
|
|
# only process data if changed
|
2023-11-15 22:34:26 +00:00
|
|
|
# but also send an update if more than a 'updateCadence' second(s) has lapsed
|
|
|
|
# Otherwise GUI can't tell if modem is active due to lack of state messages on startup
|
2023-11-14 18:26:11 +00:00
|
|
|
new_state = self.getAsJSON()
|
2023-11-17 01:39:04 +00:00
|
|
|
if new_state != self.newstate:
|
2023-11-14 18:26:11 +00:00
|
|
|
self.newstate = new_state
|
2023-11-17 01:39:04 +00:00
|
|
|
self.sendStateUpdate()
|
|
|
|
|
2023-11-11 19:01:15 +00:00
|
|
|
|
|
|
|
def getAsJSON(self):
|
2023-11-12 18:56:15 +00:00
|
|
|
return json.dumps({
|
2023-11-11 19:01:15 +00:00
|
|
|
"freedata-message": "state-change",
|
|
|
|
"channel_busy": self.channel_busy,
|
2023-11-12 18:56:15 +00:00
|
|
|
"is_codec2_traffic": self.is_codec2_traffic,
|
|
|
|
"is_modem_running": self.is_modem_running,
|
2023-11-12 22:22:53 +00:00
|
|
|
"is_beacon_running": self.is_beacon_running,
|
|
|
|
|
2023-11-12 18:56:15 +00:00
|
|
|
})
|