Skip to content

Commit ccbffae

Browse files
CarltonXiangharvey_xiang
andauthored
Fix/no response (#463)
* fix: response error * fix: response error * fix: response error --------- Co-authored-by: harvey_xiang <[email protected]>
1 parent b37939c commit ccbffae

File tree

2 files changed

+14
-4
lines changed

2 files changed

+14
-4
lines changed

src/memos/api/middleware/request_context.py

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -72,10 +72,18 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response:
7272
f"headers: {request.headers}"
7373
)
7474

75+
response = await call_next(request)
76+
end_time = time.time()
77+
7578
# Process the request
7679
try:
77-
response = await call_next(request)
78-
end_time = time.time()
80+
if not response:
81+
logger.error(
82+
f"Request Failed No Response, path: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms"
83+
)
84+
85+
return response
86+
7987
if response.status_code == 200:
8088
logger.info(
8189
f"Request completed: source: {self.source}, path: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms"
@@ -89,6 +97,5 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response:
8997
logger.error(
9098
f"Request Exception Error: source: {self.source}, path: {request.url.path}, error: {e}, cost: {(end_time - start_time) * 1000:.2f}ms"
9199
)
92-
raise e
93100

94101
return response

src/memos/api/routers/server_router.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,7 @@ def search_memories(search_req: APISearchRequest):
349349
mem_cube_id=search_req.mem_cube_id,
350350
session_id=search_req.session_id or "default_session",
351351
)
352-
logger.info(f"Search user_id is: {user_context.mem_cube_id}")
352+
logger.info(f"Search Req is: {search_req}")
353353
memories_result: MOSSearchResult = {
354354
"text_mem": [],
355355
"act_mem": [],
@@ -502,6 +502,9 @@ def add_memories(add_req: APIADDRequest):
502502
mem_cube_id=add_req.mem_cube_id,
503503
session_id=add_req.session_id or "default_session",
504504
)
505+
506+
logger.info(f"Add Req is: {add_req}")
507+
505508
target_session_id = add_req.session_id
506509
if not target_session_id:
507510
target_session_id = "default_session"

0 commit comments

Comments
 (0)