jmbwell/craprniac
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

let's stick with debug for now

Browse Source
This commit is contained in:
John Burwell 2025-04-27 13:21:07 -05:00
parent 83259e6c33
commit d67f528dc7
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
client_node/client.py
View File

@ -6,6 +6,7 @@ import os
import logging import logging
import logging.handlers import logging.handlers
import socket import socket
import sys
import ax25 import ax25
import ax25.ports import ax25.ports
import ax25.socket import ax25.socket
@ -21,7 +22,7 @@ ETH_P_ALL = 3
# Setup logging # Setup logging
os.makedirs("logs", exist_ok=True) os.makedirs("logs", exist_ok=True)
logger = logging.getLogger("craprniac_client") logger = logging.getLogger("craprniac_client")
logger.setLevel(logging.INFO) logger.setLevel(logging.DEBUG)
log_handler = logging.handlers.TimedRotatingFileHandler( log_handler = logging.handlers.TimedRotatingFileHandler(
"logs/craprniac_client.log", "logs/craprniac_client.log",
@ -82,7 +83,15 @@ def main():
reset_network_config() reset_network_config()
data, src_callsign = beacon_sock.recvfrom(1024) # recvfrom, not recv data, src_callsign = beacon_sock.recvfrom(1024) # recvfrom, not recv
parts = data.decode('utf-8').split('|') logger.debug(f"Received: {data}")
frame = ax25.Frame.unpack(data[1:])
logger.debug(f"Unpacked: {frame}")
decoded = frame.data.decode('utf-8')
logger.debug(f"Data: {decoded}")
parts = decoded.split('|')
if len(parts) < 2: if len(parts) < 2:
continue continue
@ -93,6 +102,7 @@ def main():
logger.info(f"Received beacon from {base_callsign} (network {network_name})") logger.info(f"Received beacon from {base_callsign} (network {network_name})")
# Now create a connection socket for CRAP_REQUEST # Now create a connection socket for CRAP_REQUEST
logger.debug(f"Connecting to {base_callsign}")
session_sock = ax25.socket.Socket() # SOCK_STREAM by default session_sock = ax25.socket.Socket() # SOCK_STREAM by default
session_sock.bind(CLIENT_CALLSIGN) session_sock.bind(CLIENT_CALLSIGN)
session_sock.connect(base_callsign) session_sock.connect(base_callsign)