90 lines
3.5 KiB
Python
Executable File
90 lines
3.5 KiB
Python
Executable File
#! /usr/bin/env python3
|
|
import argparse
|
|
import sys
|
|
import logging
|
|
import socket
|
|
import re
|
|
import json
|
|
import paho.mqtt.client as mqtt # pip install paho-mqtt
|
|
from datetime import datetime, UTC
|
|
|
|
logger = logging.getLogger(__name__)
|
|
RBN_SPOT_RE = re.compile(r"DX de (?P<spotter>[A-Z\d]+(?:-\d+)?)[^\d]+(?P<frequency>[\d\.]+)\s+(?P<spotted>[A-Z\d\/]+)\s+(?P<mode>[A-Z\d]+)\s+(?P<db>[a-zA-Z\d\-]+) dB\s+(?P<notes>(?:[A-Z]+\d+)|(?:\d+ WPM))?[^\d]+(?P<time>\d+Z)")
|
|
|
|
def main() -> int:
|
|
# Handle program arguments
|
|
ap = argparse.ArgumentParser(prog='rbn-to-mqtt', description='Reflects RBN spots to an MQTT broker')
|
|
ap.add_argument("rbn_mode", help="RBN mode to use", choices=['cw', 'ft8'])
|
|
ap.add_argument("mqtt_broker", help="MQTT broker to connect to")
|
|
ap.add_argument('-v', '--verbose', help='Enable verbose logging', action='store_true')
|
|
args = ap.parse_args()
|
|
|
|
# Configure logging
|
|
logging.basicConfig(
|
|
level=logging.DEBUG if args.verbose else logging.INFO,
|
|
format='%(levelname)s: %(message)s',
|
|
)
|
|
|
|
# Connect to the MQTT broker
|
|
mqtt_client = mqtt.Client()
|
|
mqtt_client.connect(args.mqtt_broker)
|
|
|
|
# Connect to the reverse beacon network
|
|
rbn_socket = socket.create_connection(('telnet.reversebeacon.net', 7000 if args.rbn_mode == 'cw' else 7001))
|
|
|
|
# Authenticate with the RBN
|
|
rbn_socket.sendall(b'va3ujf\r\n')
|
|
|
|
# Handle incoming RBN spots
|
|
buffer = b''
|
|
while True:
|
|
|
|
# Read incoming packet (may contain multiple spots)
|
|
data = rbn_socket.recv(1024)
|
|
if not data:
|
|
break
|
|
|
|
# Append to buffer
|
|
buffer += data
|
|
|
|
# Split the packet into spots
|
|
if b'\r\n' in buffer:
|
|
chunks = buffer.splitlines()
|
|
buffer = chunks.pop() # Store the un-finished chunk for later
|
|
for spot in chunks:
|
|
# Some lines aren't spots
|
|
if not spot.startswith(b'DX'):
|
|
continue
|
|
|
|
# Parse the spot
|
|
match = RBN_SPOT_RE.match(spot.decode('utf-8'))
|
|
if not match:
|
|
logger.warning("Failed to parse spot: %s", spot)
|
|
continue
|
|
|
|
values = match.groupdict()
|
|
|
|
# Parse the timestamp into something more useful
|
|
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)
|
|
|
|
# Sanitize into a new dict
|
|
sanitized = {
|
|
"spotter": values["spotter"].upper(),
|
|
"frequency_khz": float(values["frequency"]),
|
|
"spotted": values["spotted"].upper(),
|
|
"mode": values["mode"].upper(),
|
|
"db": int(values["db"]),
|
|
"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,
|
|
"timestamp": timestamp.timestamp(),
|
|
}
|
|
|
|
# Publish the spot to the MQTT broker
|
|
logger.debug("Writing spot: %s", sanitized)
|
|
mqtt_client.publish(f"radio/spots/rbn/{args.rbn_mode}/{sanitized['spotted']}", payload=json.dumps(sanitized))
|
|
|
|
return 0
|
|
|
|
if __name__ == "__main__":
|
|
sys.exit(main()) |