58 lines
1.9 KiB
Python
58 lines
1.9 KiB
Python
|
import threading
|
||
|
|
from owrx.config import Config
|
||
|
|
from owrx.reporting.reporter import Reporter
|
||
|
|
from owrx.reporting.pskreporter import PskReporter
|
||
|
|
from owrx.reporting.wsprnet import WsprnetReporter
|
||
|
|
import logging
|
||
|
|
|
||
|
|
logger = logging.getLogger(__name__)
|
||
|
|
|
||
|
|
|
||
|
|
class ReportingEngine(object):
|
||
|
|
creationLock = threading.Lock()
|
||
|
|
sharedInstance = None
|
||
|
|
|
||
|
|
reporterClasses = {
|
||
|
|
"pskreporter_enabled": PskReporter,
|
||
|
|
"wsprnet_enabled": WsprnetReporter,
|
||
|
|
}
|
||
|
|
|
||
|
|
@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 = []
|
||
|
|
self.configSub = Config.get().filter(*ReportingEngine.reporterClasses.keys()).wire(self.setupReporters)
|
||
|
|
self.setupReporters()
|
||
|
|
|
||
|
|
def setupReporters(self, *args):
|
||
|
|
config = Config.get()
|
||
|
|
for configKey, reporterClass in ReportingEngine.reporterClasses.items():
|
||
|
|
if configKey in config and config[configKey]:
|
||
|
|
if not any(isinstance(r, reporterClass) for r in self.reporters):
|
||
|
|
self.reporters += [reporterClass()]
|
||
|
|
else:
|
||
|
|
for reporter in [r for r in self.reporters if isinstance(r, reporterClass)]:
|
||
|
|
reporter.stop()
|
||
|
|
self.reporters.remove(reporter)
|
||
|
|
|
||
|
|
def stop(self):
|
||
|
|
for r in self.reporters:
|
||
|
|
r.stop()
|
||
|
|
self.configSub.cancel()
|
||
|
|
|
||
|
|
def spot(self, spot):
|
||
|
|
for r in self.reporters:
|
||
|
|
if spot["mode"] in r.getSupportedModes():
|
||
|
|
r.spot(spot)
|