From d299e15c2fee294ee6dcd7e5c8f788879c359aa4 Mon Sep 17 00:00:00 2001 From: Tiago Vasconcelos Date: Fri, 8 May 2026 05:32:48 +0100 Subject: [PATCH] wait for zap receipt (#133) --- tasks.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/tasks.py b/tasks.py index c03e6ce..5c1decd 100644 --- a/tasks.py +++ b/tasks.py @@ -144,6 +144,16 @@ async def send_zap(payment: Payment): async with websockets.connect(relay_url, open_timeout=5) as websocket: logger.debug(f"Sending zap to {relay_url}") await websocket.send(event_message) + response = await asyncio.wait_for(websocket.recv(), timeout=5) + relay_response = json.loads(response) + if relay_response[0] != "OK" or not relay_response[2]: + logger.debug( + f"Relay did not acknowledge zap receipt: {relay_response}" + ) + return + logger.debug(f"Zap sent to {relay_url} successfully") + except asyncio.TimeoutError: + logger.debug(f"Relay did not acknowledge zap receipt: {relay_url}") except Exception as e: logger.warning(f"Failed to send zap to {relay_url}: {e}")