iarv/Remote-Terminal-for-MeshCore
1
0
Fork 1
mirror of https://github.com/jkingsman/Remote-Terminal-for-MeshCore.git synced 2026-03-28 17:43:05 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add some sleeps between router operations to smooth out inconsistent behavior

Browse Source
This commit is contained in:
Jack Kingsman
2026-01-13 21:11:16 -08:00
parent 6c94cca399
commit e0d60f7d7f
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
app/routers/contacts.py
View File

@@ -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] = []