65 lines
2.1 KiB
Python
Executable File
65 lines
2.1 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__)
|
|
def main() -> int:
|
|
# Handle program arguments
|
|
ap = argparse.ArgumentParser(prog='aprs-to-mqtt', description='Reflects APRS spots to an MQTT broker')
|
|
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 APRS-IS
|
|
aprs_socket = socket.create_connection(('rotate.aprs.net', 10152))
|
|
|
|
# Authenticate with the core server
|
|
aprs_socket.sendall(b'user n0call pass -1\r\n')
|
|
|
|
# Handle incoming packets
|
|
buffer = b''
|
|
while True:
|
|
|
|
# Read incoming packet (may contain multiple actual APRS packets)
|
|
data = aprs_socket.recv(1024)
|
|
if not data:
|
|
break
|
|
|
|
# Append to buffer
|
|
buffer += data
|
|
|
|
# Split the packet into aprs packets
|
|
if b'\r\n' in buffer:
|
|
chunks = buffer.splitlines()
|
|
buffer = chunks.pop() # Store the un-finished chunk for later
|
|
for aprs_packet in chunks:
|
|
if aprs_packet.startswith(b'#'):
|
|
continue
|
|
|
|
# Try to chop off the sender callsign
|
|
sender = aprs_packet.split(b'>', 1)[0]
|
|
|
|
# Send over MQTT
|
|
logger.debug(f"Received APRS packet from {sender.decode('utf-8').upper()}: {aprs_packet}")
|
|
mqtt_client.publish(f"radio/aprs/raw/{sender.decode('utf-8').upper()}", aprs_packet)
|
|
|
|
return 0
|
|
|
|
if __name__ == "__main__":
|
|
sys.exit(main()) |