openwebrx-clone/owrx/reporting.py

import threading
from abc import ABC, abstractmethod
from owrx.config import Config


class Reporter(ABC):
    @abstractmethod
    def stop(self):
        pass

    @abstractmethod
    def spot(self, spot):
        pass

    @abstractmethod
    def getSupportedModes(self):
        return []


class ReportingEngine(object):
    creationLock = threading.Lock()
    sharedInstance = None

    @staticmethod
    def getSharedInstance():
        with ReportingEngine.creationLock:
            if ReportingEngine.sharedInstance is None:
                ReportingEngine.sharedInstance = ReportingEngine()
            return ReportingEngine.sharedInstance

    @staticmethod
    def stopAll():
        with ReportingEngine.creationLock:
            if ReportingEngine.sharedInstance is not None:
                ReportingEngine.sharedInstance.stop()

    def __init__(self):
        self.reporters = []
        config = Config.get()
        if "pskreporter_enabled" in config and config["pskreporter_enabled"]:
            # inline import due to circular dependencies
            from owrx.pskreporter import PskReporter
            self.reporters += [PskReporter()]
        if "wsprnet_enabled" in config and config["wsprnet_enabled"]:
            # inline import due to circular dependencies
            from owrx.wsprnet import WsprnetReporter
            self.reporters += [WsprnetReporter()]

    def stop(self):
        for r in self.reporters:
            r.stop()

    def spot(self, spot):
        for r in self.reporters:
            if spot["mode"] in r.getSupportedModes():
                r.spot(spot)