44 lines
1.4 KiB
Python
44 lines
1.4 KiB
Python
import threading
|
|
import time
|
|
from owrx.config import PropertyManager
|
|
from urllib import request, parse
|
|
|
|
import logging
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class SdrHuUpdater(threading.Thread):
|
|
def __init__(self):
|
|
self.doRun = True
|
|
super().__init__(daemon=True)
|
|
|
|
def update(self):
|
|
pm = PropertyManager.getSharedInstance().collect("server_hostname", "web_port", "sdrhu_key")
|
|
data = parse.urlencode({
|
|
"url": "http://{server_hostname}:{web_port}".format(**pm.__dict__()),
|
|
"apikey": pm["sdrhu_key"]
|
|
}).encode()
|
|
|
|
res = request.urlopen("https://sdr.hu/update", data=data)
|
|
if res.getcode() < 200 or res.getcode() >= 300:
|
|
logger.warning('sdr.hu update failed with error code %i', res.getcode())
|
|
return 2
|
|
|
|
returned = res.read().decode("utf-8")
|
|
if "UPDATE:" not in returned:
|
|
logger.warning("Update failed, your receiver cannot be listed on sdr.hu!")
|
|
return 2
|
|
|
|
value = returned.split("UPDATE:")[1].split("\n", 1)[0]
|
|
if value.startswith("SUCCESS"):
|
|
logger.info("Update succeeded!")
|
|
else:
|
|
logger.warning("Update failed, your receiver cannot be listed on sdr.hu! Reason: %s", value)
|
|
return 20
|
|
|
|
def run(self):
|
|
while self.doRun:
|
|
retrytime_mins = self.update()
|
|
time.sleep(60 * retrytime_mins)
|