FreeDATA/modem/service_manager.py

86 lines
3.2 KiB
Python
Raw Normal View History

2023-11-09 21:11:53 +00:00
import threading
import data_handler
import modem
import structlog
import audio
2023-11-12 21:35:10 +00:00
import ujson as json
2023-11-12 22:22:53 +00:00
import explorer
2023-11-12 21:35:10 +00:00
2023-11-09 21:11:53 +00:00
class SM:
def __init__(self, app):
self.log = structlog.get_logger("service")
self.modem = False
self.data_handler = False
2023-11-14 18:26:11 +00:00
self.config = app.config_manager.read()
2023-11-09 21:11:53 +00:00
self.modem_events = app.modem_events
self.modem_fft = app.modem_fft
self.modem_service = app.modem_service
self.states = app.states
2023-11-09 21:11:53 +00:00
runner_thread = threading.Thread(
target=self.runner, name="runner thread", daemon=True
)
runner_thread.start()
2023-11-12 22:22:53 +00:00
# optionally start explorer module
if self.config['STATION']['enable_explorer']:
2023-11-13 08:19:42 +00:00
explorer.explorer(self.config, self.states)
2023-11-12 22:22:53 +00:00
2023-11-09 21:11:53 +00:00
def runner(self):
while True:
cmd = self.modem_service.get()
if cmd in ['start'] and not self.modem:
2023-11-12 21:35:10 +00:00
self.log.info("------------------ FreeDATA ------------------")
self.log.info("------------------ MODEM ------------------")
self.start_modem()
elif cmd in ['stop'] and self.modem:
self.stop_modem()
# we need to wait a bit for avoiding a portaudio crash
threading.Event().wait(0.5)
2023-11-12 18:56:15 +00:00
2023-11-12 21:35:10 +00:00
elif cmd in ['restart']:
self.stop_modem()
# we need to wait a bit for avoiding a portaudio crash
threading.Event().wait(0.5)
if self.start_modem():
self.modem_events.put(json.dumps({"freedata": "modem-event", "event": "restart"}))
2023-11-09 21:11:53 +00:00
else:
2023-11-12 21:35:10 +00:00
self.log.warning("[SVC] modem command processing failed", cmd=cmd, state=self.states.is_modem_running)
def start_modem(self):
audio_test = self.test_audio()
if False not in audio_test and None not in audio_test and not self.states.is_modem_running:
self.log.info("starting modem....")
self.modem = modem.RF(self.config, self.modem_events, self.modem_fft, self.modem_service, self.states)
2023-11-12 22:22:53 +00:00
self.data_handler = data_handler.DATA(self.config, self.modem_events, self.states)
2023-11-12 21:35:10 +00:00
self.states.set("is_modem_running", True)
return True
elif self.states.is_modem_running:
self.log.warning("modem already running")
return False
else:
self.log.warning("starting modem failed", input_test=audio_test[0], output_test=audio_test[1])
self.states.set("is_modem_running", False)
self.modem_events.put(json.dumps({"freedata": "modem-event", "event": "failed"}))
return False
def stop_modem(self):
self.log.info("stopping modem....")
del self.modem
del self.data_handler
self.modem = False
self.data_handler = False
self.states.set("is_modem_running", False)
def test_audio(self):
audio_test = audio.test_audio_devices(self.config['AUDIO']['input_device'],
self.config['AUDIO']['output_device'])
self.log.info("tested audio devices", result=audio_test)
return audio_test