From a74b3c23a162dafb4122c6ab1a02af3ab8d37fa0 Mon Sep 17 00:00:00 2001
From: Ivan <ivan@quad4.io>
Date: Mon, 13 Apr 2026 18:27:57 -0500
Subject: [PATCH] feat(rncp): update file transfer handling with transfer start
 callbacks and new API endpoints for status and stop; improve websocket
 message broadcasting

---
 meshchatx/meshchat.py | 42 +++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 41 insertions(+), 1 deletion(-)

diff --git a/meshchatx/meshchat.py b/meshchatx/meshchat.py
index d676d74..3f47c34 100644
--- a/meshchatx/meshchat.py
+++ b/meshchatx/meshchat.py
@@ -7131,6 +7131,10 @@ class ReticulumMeshChat:
 
             transfer_id = None
 
+            def on_transfer_started(tid):
+                nonlocal transfer_id
+                transfer_id = tid
+
             def on_progress(progress):
                 if transfer_id:
                     AsyncUtils.run_async(
@@ -7150,8 +7154,18 @@ class ReticulumMeshChat:
                     timeout=timeout,
                     on_progress=on_progress,
                     no_compress=no_compress,
+                    on_transfer_started=on_transfer_started,
+                )
+                AsyncUtils.run_async(
+                    self._broadcast_websocket_message(
+                        {
+                            "type": "rncp.send.completed",
+                            "transfer_id": result["transfer_id"],
+                            "file_path": result.get("file_path"),
+                            "status": "completed",
+                        },
+                    ),
                 )
-                transfer_id = result["transfer_id"]
                 return web.json_response(result)
             except Exception as e:
                 return web.json_response(
@@ -7178,6 +7192,10 @@ class ReticulumMeshChat:
 
             transfer_id = None
 
+            def on_transfer_started(tid):
+                nonlocal transfer_id
+                transfer_id = tid
+
             def on_progress(progress):
                 if transfer_id:
                     AsyncUtils.run_async(
@@ -7198,6 +7216,16 @@ class ReticulumMeshChat:
                     on_progress=on_progress,
                     save_path=save_path,
                     allow_overwrite=allow_overwrite,
+                    on_transfer_started=on_transfer_started,
+                )
+                AsyncUtils.run_async(
+                    self._broadcast_websocket_message(
+                        {
+                            "type": "rncp.fetch.completed",
+                            "file_path": result.get("file_path"),
+                            "status": "completed",
+                        },
+                    ),
                 )
                 return web.json_response(result)
             except Exception as e:
@@ -7244,6 +7272,18 @@ class ReticulumMeshChat:
                     status=500,
                 )
 
+        @routes.get("/api/v1/rncp/status")
+        async def rncp_status(_request):
+            return web.json_response(self.rncp_handler.get_listener_status())
+
+        @routes.post("/api/v1/rncp/stop")
+        async def rncp_stop(_request):
+            try:
+                self.rncp_handler.teardown_receive_destination()
+                return web.json_response({"message": "RNCP listener stopped"})
+            except Exception as e:
+                return web.json_response({"message": str(e)}, status=500)
+
         # --- Page Node API ---
 
         @routes.get("/api/v1/page-nodes")