feat: update log

Author: harvey_xiang

src/memos/api/middleware/request_context.py

@@ -80,26 +80,23 @@ async def dispatch(self, request: Request, call_next: Callable) -> Response:
         logger.info(f"Request started, params: {params_log}, headers: {request.headers}")
 
         # Process the request
-        response = await call_next(request)
-        end_time = time.time()
-        if isinstance(response, StreamingResponse):
-            response.body_iterator = _tee_stream(response)
-            content = "Streaming response"
-        else:
-            try:
-                content = (
-                    response.body.decode("utf-8") if hasattr(response, "body") else str(response)
-                )
-            except Exception as e:
-                content = f"Unable to decode response content: {e!s}"
+        try:
+            response = await call_next(request)
+            end_time = time.time()
 
-        if response.status_code == 200:
-            logger.info(
-                f"Request completed: {request.url.path}, content: {content}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms"
-            )
-        else:
+            if response.status_code == 200:
+                logger.info(
+                    f"Request completed: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms"
+                )
+            else:
+                logger.error(
+                    f"Request Failed: {request.url.path}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms"
+                )
+        except Exception as e:
+            end_time = time.time()
             logger.error(
-                f"Request Failed: {request.url.path}, content: {content}, status: {response.status_code}, cost: {(end_time - start_time) * 1000:.2f}ms"
+                f"Request Exception Error: {e}, cost: {(end_time - start_time) * 1000:.2f}ms"
             )
+            raise e
 
         return response

src/memos/context/context.py

@@ -133,7 +133,7 @@ def get_current_user_type() -> str | None:
     context = _request_context.get()
     if context:
         return context.get("user_type")
-    return "normal"
+    return "opensource"
 
 
 def get_current_user_name() -> str | None:
@@ -143,7 +143,7 @@ def get_current_user_name() -> str | None:
     context = _request_context.get()
     if context:
         return context.get("user_name")
-    return "unknown"
+    return "memos"
 
 
 def get_current_context() -> RequestContext | None:

src/memos/log.py

@@ -171,7 +171,7 @@ def close(self):
     "disable_existing_loggers": False,
     "formatters": {
         "standard": {
-            "format": "%(asctime)s | %(trace_id)s | env=%(env)s | user_type=%(user_type)s | user_name=%(user_name)s |%(name)s - %(levelname)s - %(filename)s:%(lineno)d - %(funcName)s - %(message)s"
+            "format": "%(asctime)s | %(trace_id)s | env=%(env)s | user_type=%(user_type)s | user_name=%(user_name)s | %(name)s - %(levelname)s - %(filename)s:%(lineno)d - %(funcName)s - %(message)s"
         },
         "no_datetime": {
             "format": "%(trace_id)s | env=%(env)s | user_type=%(user_type)s | user_name=%(user_name)s | %(name)s - %(levelname)s - %(filename)s:%(lineno)d - %(funcName)s - %(message)s"