From e0d60f7d7f7390df030b01e304268fd26be6d1f2 Mon Sep 17 00:00:00 2001
From: Jack Kingsman <jack.kingsman@gmail.com>
Date: Tue, 13 Jan 2026 21:11:16 -0800
Subject: [PATCH] Add some sleeps between router operations to smooth out
 inconsistent behavior

---
 app/routers/contacts.py | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/app/routers/contacts.py b/app/routers/contacts.py
index c34546a..3594d24 100644
--- a/app/routers/contacts.py
+++ b/app/routers/contacts.py
@@ -1,3 +1,4 @@
+import asyncio
 import logging
 
 from fastapi import APIRouter, HTTPException, Query
@@ -29,6 +30,9 @@ from app.repository import ContactRepository
 logger = logging.getLogger(__name__)
 router = APIRouter(prefix="/contacts", tags=["contacts"])
 
+# Delay between repeater radio operations to allow key exchange and path establishment
+REPEATER_OP_DELAY_SECONDS = 2.0
+
 
 async def ensure_repeater_on_radio(mc, contact: Contact) -> None:
     """Ensure a repeater contact is on the radio with flood mode.
@@ -109,6 +113,10 @@ async def prepare_repeater_connection(mc, contact: Contact, password: str) -> No
             detail=f"Login failed: {login_result.payload}"
         )
 
+    # Wait for key exchange to complete before sending requests
+    logger.debug("Waiting %.1fs for key exchange to complete", REPEATER_OP_DELAY_SECONDS)
+    await asyncio.sleep(REPEATER_OP_DELAY_SECONDS)
+
 
 @router.get("", response_model=list[Contact])
 async def list_contacts(
@@ -287,6 +295,7 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem
         if status:
             break
         logger.debug("Status request timeout, retrying...")
+        await asyncio.sleep(REPEATER_OP_DELAY_SECONDS)
 
     if not status:
         raise HTTPException(
@@ -296,6 +305,9 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem
 
     logger.info("Received telemetry from %s: %s", contact.public_key[:12], status)
 
+    # Wait before next request
+    await asyncio.sleep(REPEATER_OP_DELAY_SECONDS)
+
     # Fetch neighbors (fetch_all_neighbours handles pagination)
     logger.info("Fetching neighbors from repeater %s", contact.public_key[:12])
     neighbors_data = None
@@ -309,6 +321,7 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem
         if neighbors_data:
             break
         logger.debug("Neighbors request timeout, retrying...")
+        await asyncio.sleep(REPEATER_OP_DELAY_SECONDS)
 
     # Process neighbors - resolve pubkey prefixes to contact names
     neighbors: list[NeighborInfo] = []
@@ -325,6 +338,9 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem
                 last_heard_seconds=n.get("secs_ago", 0),
             ))
 
+    # Wait before next request
+    await asyncio.sleep(REPEATER_OP_DELAY_SECONDS)
+
     # Fetch ACL
     logger.info("Fetching ACL from repeater %s", contact.public_key[:12])
     acl_data = None
@@ -338,6 +354,7 @@ async def request_telemetry(public_key: str, request: TelemetryRequest) -> Telem
         if acl_data:
             break
         logger.debug("ACL request timeout, retrying...")
+        await asyncio.sleep(REPEATER_OP_DELAY_SECONDS)
 
     # Process ACL - resolve pubkey prefixes to contact names
     acl_entries: list[AclEntry] = []