FreeDATA/modem/service_manager.py

import threading
import frame_dispatcher
import modem
import structlog
import audio
import ujson as json
import explorer
import beacon


class SM:
    def __init__(self, app):
        self.log = structlog.get_logger("service")

        self.modem = False
        self.beacon = False
        self.explorer = False
        self.app = app
        self.config = self.app.config_manager.read()
        self.modem_fft = app.modem_fft
        self.modem_service = app.modem_service
        self.states = app.state_manager
        self.event_manager = app.event_manager


        runner_thread = threading.Thread(
            target=self.runner, name="runner thread", daemon=True
        )
        runner_thread.start()

    def runner(self):
        while True:
            cmd = self.modem_service.get()
            if cmd in ['start'] and not self.modem:
                self.log.info("------------------ FreeDATA ------------------")
                self.log.info("------------------  MODEM   ------------------")
                self.start_modem()
                self.start_explorer_publishing()

            elif cmd in ['stop'] and self.modem:
                self.stop_modem()
                self.stop_explorer_publishing()
                # we need to wait a bit for avoiding a portaudio crash
                threading.Event().wait(0.5)

            elif cmd in ['restart']:
                self.stop_modem()
                self.stop_explorer_publishing()
                # we need to wait a bit for avoiding a portaudio crash
                threading.Event().wait(0.5)
                if self.start_modem():
                    self.event_manager.modem_restarted()
            elif cmd in ['start_beacon']:
                self.start_beacon()

            elif cmd in ['stop_beacon']:
                self.stop_beacon()



            else:
                self.log.warning("[SVC] modem command processing failed", cmd=cmd, state=self.states.is_modem_running)


    def start_modem(self):
        # read config
        self.config = self.app.config_manager.read()

        if self.states.is_modem_running:
            self.log.warning("modem already running")
            return False

        # test audio devices
        audio_test = self.test_audio()

        if False in audio_test or None in audio_test or self.states.is_modem_running:
            self.log.warning("starting modem failed", input_test=audio_test[0], output_test=audio_test[1])
            self.states.set("is_modem_running", False)
            self.event_manager.modem_failed()
            return False

        self.log.info("starting modem....")
        self.modem = modem.RF(self.config, self.event_manager, self.modem_fft, self.modem_service, self.states)

        self.frame_dispatcher = frame_dispatcher.DISPATCHER(self.config, 
                                                            self.event_manager,
                                                            self.states,
                                                            self.modem)
        self.frame_dispatcher.start()

        self.event_manager.modem_started()
        self.states.set("is_modem_running", True)
        self.modem.start_modem()

        return True
        
    def stop_modem(self):
        self.log.info("stopping modem....")
        del self.modem
        self.modem = False
        self.states.set("is_modem_running", False)
        self.event_manager.modem_stopped()

    def test_audio(self):
        try:
            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
        except Exception as e:
            self.log.error("Error testing audio devices", e=e)
            return [False, False]

    def start_beacon(self):
        self.beacon = beacon.Beacon(self.config, self.states, self.event_manager, self.log, self.modem)
        self.beacon.start()

    def stop_beacon(self):
        del self.beacon

    def start_explorer_publishing(self):
        try:
            # optionally start explorer module
            if self.config['STATION']['enable_explorer']:
                self.explorer = explorer.explorer(self.app, self.config, self.states)
        except Exception as e:
            self.log.warning("[EXPLORER] Publishing not started because of error", e=e)

    def stop_explorer_publishing(self):
        del self.explorer