From 1b0d8bdd2e6e030dfa731975fca4351c515a631e Mon Sep 17 00:00:00 2001 From: heng <137639544+heng-ah@users.noreply.github.com> Date: Fri, 16 May 2025 18:27:46 +0800 Subject: [PATCH] improvement(OMM)- fix the sse failed to connect issue (#2696) --- openmemory/api/app/mcp_server.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/openmemory/api/app/mcp_server.py b/openmemory/api/app/mcp_server.py index e5774590..fa6863a4 100644 --- a/openmemory/api/app/mcp_server.py +++ b/openmemory/api/app/mcp_server.py @@ -350,7 +350,7 @@ async def handle_sse(request: Request): client_name_var.reset(client_token) -@mcp_router.post("/messages/") +@mcp_router.post("/{client_name}/sse/{user_id}/messages/") async def handle_post_message(request: Request): """Handle POST messages for SSE""" try: @@ -362,7 +362,7 @@ async def handle_post_message(request: Request): # Create a simple send function that does nothing async def send(message): - pass + return {} # Call handle_post_message with the correct arguments await sse.handle_post_message(request.scope, receive, send)