dandri/MeshChatX
1
0
Fork 0
mirror of https://git.quad4.io/RNS-Things/MeshChatX.git synced 2026-08-28 12:54:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(rncp): update file transfer handling with transfer start callbacks and new API endpoints for status and stop; improve websocket message broadcasting

Browse Source
This commit is contained in:
Ivan
2026-04-13 18:27:57 -05:00
parent bd56b884ba
commit a74b3c23a1
1 changed files with 41 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
meshchatx/meshchat.py
+41 -1
View File
@@ -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")