fix(logging): inject user_email into structured log output

app/api/dependencies.py

@@ -9,6 +9,7 @@
 from app.core.db import get_db_session
 from app.core.enums import UserStatus
 from app.core.config import get_settings
+from app.core.logging import set_request_user_email
 from app.core.security import decode_access_token
 from app.repositories.user import UserRepository
 from app.schemas.auth import TokenPayload, UserRead
@@ -51,6 +52,7 @@ def get_current_user(
     span = trace.get_current_span()
     span.set_attribute("user.id", str(resolved.id))
     span.set_attribute("user.email", resolved.email)
+    set_request_user_email(resolved.email)
     return resolved
 
 

app/core/logging.py

@@ -4,9 +4,17 @@
 
 import json
 import logging
+from contextvars import ContextVar
 
 from opentelemetry import trace
 
+_user_email_var: ContextVar[str] = ContextVar('user_email', default='')
+
+
+def set_request_user_email(email: str) -> None:
+    _user_email_var.set(email)
+
+
 _SKIP_ATTRS = frozenset((
     "name", "msg", "args", "levelname", "levelno",
     "pathname", "filename", "module", "exc_info",
@@ -33,6 +41,10 @@ def format(self, record: logging.LogRecord) -> str:
             "span_id": format(ctx.span_id, "016x") if ctx.is_valid else "",
         }
 
+        user_email = _user_email_var.get()
+        if user_email:
+            entry["user_email"] = user_email
+
         for key, val in record.__dict__.items():
             if key not in _SKIP_ATTRS and not key.startswith("_"):
                 entry[key] = val