diff --git a/main.py b/main.py index e53bd1e..72dd078 100644 --- a/main.py +++ b/main.py @@ -55,8 +55,9 @@ if __name__ == '__main__': DXCluster("hrd.wa9pie.net", 8000), # DXCluster("dxc.w3lpl.net", 22) ] - # Set up spot list + # Set up spot list & status data areas spot_list = [] + status_data = {} # Set up data providers for p in providers: p.setup(spot_list=spot_list) # Start data providers @@ -67,13 +68,18 @@ if __name__ == '__main__': cleanup_timer.start() # Set up web server - web_server = WebServer(spot_list=spot_list, port=config["web-server-port"]) + web_server = WebServer(spot_list=spot_list, status_data=status_data, port=config["web-server-port"]) web_server.start() logging.info("Startup complete.") + # While running, update the status information at a regular interval while run: - sleep(1) + sleep(5) + for p in providers: status_data[p.name()] = {"status": p.status, "last_updated": p.last_update_time, "last_spot": p.last_spot_time} + status_data["Cleanup Timer"] = {"status": cleanup_timer.status, "last_ran": cleanup_timer.last_cleanup_time} + status_data["Web Server"] = {"status": web_server.status, "last_api_access": web_server.last_api_access_time, "last_page_access": web_server.last_page_access_time} + # TODO NOTES FOR NGINX REVERSE PROXY diff --git a/providers/dxcluster.py b/providers/dxcluster.py index d5dbd29..ae42d60 100644 --- a/providers/dxcluster.py +++ b/providers/dxcluster.py @@ -67,7 +67,7 @@ class DXCluster(Provider): if match: spot_time = datetime.strptime(match.group(5), "%H%MZ") spot_datetime = datetime.combine(datetime.today(), spot_time.time()).replace(tzinfo=pytz.UTC) - spot = Spot(source="DX Cluster", + spot = Spot(source="Cluster", dx_call=match.group(3), de_call=match.group(1), freq=float(match.group(2)), diff --git a/providers/gma.py b/providers/gma.py index 70edc72..b6e4425 100644 --- a/providers/gma.py +++ b/providers/gma.py @@ -30,7 +30,7 @@ class GMA(HTTPProvider): spot = Spot(source=self.name(), dx_call=source_spot["ACTIVATOR"].upper(), de_call=source_spot["SPOTTER"].upper(), - freq=float(source_spot["QRG"]), + freq=float(source_spot["QRG"]) if (source_spot["QRG"] != "") else None, # Seen GMA spots with no frequency mode=source_spot["MODE"].upper(), comment=source_spot["TEXT"], sig_refs=[source_spot["REF"]], diff --git a/server/webserver.py b/server/webserver.py index 247321d..4254e95 100644 --- a/server/webserver.py +++ b/server/webserver.py @@ -1,8 +1,10 @@ import json import logging +from datetime import datetime from threading import Thread import bottle +import pytz from bottle import run, response from core.utils import serialize_everything @@ -12,14 +14,19 @@ from core.utils import serialize_everything class WebServer: # Constructor - def __init__(self, spot_list, port): + def __init__(self, spot_list, status_data, port): + self.last_page_access_time = None + self.last_api_access_time = None self.spot_list = spot_list + self.status_data = status_data self.port = port self.thread = Thread(target=self.run) self.thread.daemon = True + self.status = "Starting" # Set up routing bottle.get("/api/spots")(self.serve_api_spots) + bottle.get("/api/status")(self.serve_api_status) bottle.get("/")(self.serve_index) bottle.get("/")(self.serve_static_file) @@ -30,16 +37,29 @@ class WebServer: # Run the web server itself. This blocks until the server is shut down, so it runs in a separate thread. def run(self): logging.info("Starting web server on port " + str(self.port) + "...") + self.status = "Waiting" run(host='localhost', port=self.port) # Main spots API def serve_api_spots(self): + self.last_api_access_time = datetime.now(pytz.UTC) + self.status = "OK" spots_json = json.dumps(self.spot_list, default=serialize_everything) response.content_type = 'application/json' return spots_json + # Server status API + def serve_api_status(self): + self.last_api_access_time = datetime.now(pytz.UTC) + self.status = "OK" + status_json = json.dumps(self.status_data, default=serialize_everything) + response.content_type = 'application/json' + return status_json + # Serve the home page. This would be accessible as /index.html but we need this workaround to make it available as / def serve_index(self): + self.last_page_access_time = datetime.now(pytz.UTC) + self.status = "OK" return bottle.static_file("index.html", root="webassets") # Serve general static files from "webassets" directory @@ -49,10 +69,4 @@ class WebServer: # Todo spot API arguments e.g. "since" based on received_time of spots, sources, sigs, dx cont, dxcc, de cont, band, mode, filter out qrt, filter pre-qsy, sort order, list of fields # Todo serve status API -# Todo serve apidocs -# Todo serve website - -# Examples -# @route('/download/') -# def download(filename): -# return static_file(filename, root='/path/to/static/files', download=f"download-{filename}") \ No newline at end of file +# Todo serve apidocs \ No newline at end of file