import logging # the linter will complain about this, but the logging must be configured before importing all the other modules # loglevel will be adjusted later, INFO is just for the startup logging.basicConfig(level=logging.INFO, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s") logger = logging.getLogger(__name__) from http.server import HTTPServer from owrx.http import RequestHandler from owrx.config.core import CoreConfig from owrx.config import Config from owrx.config.commands import MigrateCommand from owrx.feature import FeatureDetector from owrx.sdr import SdrService from socketserver import ThreadingMixIn from owrx.service import Services from owrx.websocket import WebSocketConnection from owrx.reporting import ReportingEngine from owrx.version import openwebrx_version from owrx.audio.queue import DecoderQueue from owrx.admin import add_admin_parser, run_admin_action import signal import argparse class ThreadedHttpServer(ThreadingMixIn, HTTPServer): pass class SignalException(Exception): pass def handleSignal(sig, frame): raise SignalException("Received Signal {sig}".format(sig=sig)) def main(): parser = argparse.ArgumentParser(description="OpenWebRX - Open Source SDR Web App for Everyone!") parser.add_argument("-v", "--version", action="store_true", help="Show the software version") parser.add_argument("--debug", action="store_true", help="Set loglevel to DEBUG") moduleparser = parser.add_subparsers(title="Modules", dest="module") adminparser = moduleparser.add_parser("admin", help="Administration actions") add_admin_parser(adminparser) configparser = moduleparser.add_parser("config", help="Configuration actions") configcommandparser = configparser.add_subparsers(title="Commands", dest="command") migrateparser = configcommandparser.add_parser("migrate", help="Migrate configuration files") migrateparser.set_defaults(cls=MigrateCommand) args = parser.parse_args() if args.version: print("OpenWebRX version {version}".format(version=openwebrx_version)) return 0 if args.module == "admin": return run_admin_action(adminparser, args) if args.module == "config": return run_admin_action(configparser, args) return start_receiver(loglevel=logging.DEBUG if args.debug else None) def start_receiver(loglevel=None): print( """ OpenWebRX - Open Source SDR Web App for Everyone! | for license see LICENSE file in the package _________________________________________________________________________________________________ Author contact info: Jakob Ketterl, DD5JFK Documentation: https://github.com/jketterl/openwebrx/wiki Support and info: https://groups.io/g/openwebrx """ ) logger.info("OpenWebRX version {0} starting up...".format(openwebrx_version)) for sig in [signal.SIGINT, signal.SIGTERM]: signal.signal(sig, handleSignal) # config warmup Config.validateConfig() coreConfig = CoreConfig() # passed loglevel takes priority (used for the --debug argument) logging.getLogger().setLevel(coreConfig.get_log_level() if loglevel is None else loglevel) featureDetector = FeatureDetector() failed = featureDetector.get_failed_requirements("core") if failed: logger.error( "you are missing required dependencies to run openwebrx. " "please check that the following core requirements are installed and up to date: %s", ", ".join(failed) ) for f in failed: description = featureDetector.get_requirement_description(f) if description: logger.error("description for %s:\n%s", f, description) return 1 # Get error messages about unknown / unavailable features as soon as possible # start up "always-on" sources right away SdrService.getAllSources() Services.start() try: server = ThreadedHttpServer(("0.0.0.0", coreConfig.get_web_port()), RequestHandler) server.serve_forever() except SignalException: pass WebSocketConnection.closeAll() Services.stop() SdrService.stopAllSources() ReportingEngine.stopAll() DecoderQueue.stopAll() return 0