evan/ewconfig
1
Fork 0
Code

New chunking logic

Browse Source
This commit is contained in:
Evan Pratten 2024-11-21 15:24:31 -05:00
parent 57b4f2e52c
commit a4b2ea29ee
1 changed files with 39 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
scripts/rbn-to-mqtt
View File

@ -36,6 +36,7 @@ def main() -> int:
rbn_socket.sendall(b'va3ujf\r\n') rbn_socket.sendall(b'va3ujf\r\n')
# Handle incoming RBN spots # Handle incoming RBN spots
buffer = b''
while True: while True:
# Read incoming packet (may contain multiple spots) # Read incoming packet (may contain multiple spots)
@ -43,39 +44,45 @@ def main() -> int:
if not data: if not data:
break break
# Append to buffer
buffer += data
# Split the packet into spots # Split the packet into spots
for spot in data.splitlines(): if b'\r\n' in buffer:
# Some lines aren't spots chunks = buffer.splitlines()
if not spot.startswith(b'DX'): buffer = chunks.pop() # Store the un-finished chunk for later
continue for spot in chunks:
# Some lines aren't spots
if not spot.startswith(b'DX'):
continue
# Parse the spot # Parse the spot
match = RBN_SPOT_RE.match(spot.decode('utf-8')) match = RBN_SPOT_RE.match(spot.decode('utf-8'))
if not match: if not match:
logger.warning("Failed to parse spot: %s", spot) logger.warning("Failed to parse spot: %s", spot)
continue continue
values = match.groupdict() values = match.groupdict()
# Parse the timestamp into something more useful # Parse the timestamp into something more useful
utc_now = datetime.now(UTC) utc_now = datetime.now(UTC)
timestamp = datetime(utc_now.year, utc_now.month, utc_now.day, int(values["time"][:2]), int(values["time"][2:4]), 0) timestamp = datetime(utc_now.year, utc_now.month, utc_now.day, int(values["time"][:2]), int(values["time"][2:4]), 0)
# Sanitize into a new dict # Sanitize into a new dict
sanitized = { sanitized = {
"spotter": values["spotter"].upper(), "spotter": values["spotter"].upper(),
"frequency_khz": float(values["frequency"]), "frequency_khz": float(values["frequency"]),
"spotted": values["spotted"].upper(), "spotted": values["spotted"].upper(),
"mode": values["mode"].upper(), "mode": values["mode"].upper(),
"db": int(values["db"]), "db": int(values["db"]),
"speed": values["notes"] if values["notes"] and values["notes"].endswith("WPM") else None, "speed": values["notes"] if values["notes"] and values["notes"].endswith("WPM") else None,
"grid": values["notes"] if values["notes"] and (not values.get("notes", "WPM").endswith("WPM")) else None, "grid": values["notes"] if values["notes"] and (not values.get("notes", "WPM").endswith("WPM")) else None,
"timestamp": timestamp.timestamp(), "timestamp": timestamp.timestamp(),
} }
# Publish the spot to the MQTT broker # Publish the spot to the MQTT broker
logger.debug("Writing spot: %s", sanitized) logger.debug("Writing spot: %s", sanitized)
mqtt_client.publish(f"radio/spots/rbn/{args.rbn_mode}/{sanitized['spotted']}", payload=json.dumps(sanitized)) mqtt_client.publish(f"radio/spots/rbn/{args.rbn_mode}/{sanitized['spotted']}", payload=json.dumps(sanitized))
return 0 return 0