From fc8e4bb93e36b05cd5add1856936dde269dd96b9 Mon Sep 17 00:00:00 2001 From: harvey_xiang Date: Thu, 6 Nov 2025 10:15:36 +0800 Subject: [PATCH 1/3] fix: response error --- src/memos/api/middleware/request_context.py | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/src/memos/api/middleware/request_context.py b/src/memos/api/middleware/request_context.py index 443aa1f3d..5e7f3224d 100644 --- a/src/memos/api/middleware/request_context.py +++ b/src/memos/api/middleware/request_context.py @@ -72,10 +72,19 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response: f"headers: {request.headers}" ) + response = await call_next(request) + end_time = time.time() + # Process the request try: - response = await call_next(request) - end_time = time.time() + + if not response: + logger.error( + f"Request Failed No Response, path: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms" + ) + + return response + if response.status_code == 200: logger.info( f"Request completed: source: {self.source}, path: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms" @@ -89,6 +98,6 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response: logger.error( f"Request Exception Error: source: {self.source}, path: {request.url.path}, error: {e}, cost: {(end_time - start_time) * 1000:.2f}ms" ) - raise e + raise response return response From 93343c0a142bf120da474b2d0b0eb7a613a5dde0 Mon Sep 17 00:00:00 2001 From: harvey_xiang Date: Thu, 6 Nov 2025 10:16:41 +0800 Subject: [PATCH 2/3] fix: response error --- src/memos/api/middleware/request_context.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/memos/api/middleware/request_context.py b/src/memos/api/middleware/request_context.py index 5e7f3224d..355866ca6 100644 --- a/src/memos/api/middleware/request_context.py +++ b/src/memos/api/middleware/request_context.py @@ -98,6 +98,5 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response: logger.error( f"Request Exception Error: source: {self.source}, path: {request.url.path}, error: {e}, cost: {(end_time - start_time) * 1000:.2f}ms" ) - raise response return response From cf574f1c1bd74b447bfd860e0b77eaafbcbdaa4a Mon Sep 17 00:00:00 2001 From: harvey_xiang Date: Thu, 6 Nov 2025 10:39:50 +0800 Subject: [PATCH 3/3] fix: response error --- src/memos/api/middleware/request_context.py | 1 - src/memos/api/routers/server_router.py | 5 ++++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/memos/api/middleware/request_context.py b/src/memos/api/middleware/request_context.py index 355866ca6..025a0f9eb 100644 --- a/src/memos/api/middleware/request_context.py +++ b/src/memos/api/middleware/request_context.py @@ -77,7 +77,6 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response: # Process the request try: - if not response: logger.error( f"Request Failed No Response, path: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms" diff --git a/src/memos/api/routers/server_router.py b/src/memos/api/routers/server_router.py index 684e02a0c..8df383bfb 100644 --- a/src/memos/api/routers/server_router.py +++ b/src/memos/api/routers/server_router.py @@ -349,7 +349,7 @@ def search_memories(search_req: APISearchRequest): mem_cube_id=search_req.mem_cube_id, session_id=search_req.session_id or "default_session", ) - logger.info(f"Search user_id is: {user_context.mem_cube_id}") + logger.info(f"Search Req is: {search_req}") memories_result: MOSSearchResult = { "text_mem": [], "act_mem": [], @@ -502,6 +502,9 @@ def add_memories(add_req: APIADDRequest): mem_cube_id=add_req.mem_cube_id, session_id=add_req.session_id or "default_session", ) + + logger.info(f"Add Req is: {add_req}") + target_session_id = add_req.session_id if not target_session_id: target_session_id = "default_session"