make a media api, encapsulate the original S3 bucket address

there are 3 parts, from back to head, url inside the bucket -> url of backend media api -> backend domain, only the last part is spliced by frontend, the other two parts are spliced with sqlalchemy

app/db.py

@@ -21,6 +21,19 @@ if not DATABASE_URL:
 engine = create_engine(
     DATABASE_URL,
     pool_recycle=3600,
-    pool_pre_ping=True
+    pool_pre_ping=True,
+    connect_args={
+        "keepalives": 1,
+        "keepalives_idle": 30,
+        "keepalives_interval": 10,
+        "keepalives_count": 5
+    }
 )
-SessionLocal = sessionmaker(bind=engine)
+SessionLocal = sessionmaker(bind=engine)
+
+def get_db():
+    db = SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()

app/graphql/context.py

@@ -28,7 +28,7 @@ async def load_members_by_workspace_ids(workspace_ids: List[str]) -> List[List[W
 
 class CustomContext(BaseContext):
     def __init__(self, request: Request):
-        super().__init__(request)
+        super().__init__()
         self.db = SessionLocal()
         self.request = request
         self._current_user: Optional[User] = None
@@ -41,17 +41,32 @@ class CustomContext(BaseContext):
             return self._current_user
             
         try:
+            # 打印 Request Headers，确认 Token 是否真的传过来了
+            # print(f"DEBUG: Auth Headers: {self.request.headers.get('authorization')}")
+            # print(f"DEBUG: Cookies: {self.request.cookies}")
             # 借用 auth 包的纯工具解出 ID
             user_id = get_current_user_id(self.request)
+            # print(f"DEBUG: Extracted User ID: {user_id}") # 确认 ID 是否解出
+            
+            if not user_id:
+                return None
+            
             # 在 Context 的数据库连接中查询完整用户
             user = self.db.query(User).filter(User.id == user_id).first()
+            # print(f"DEBUG: DB User Found: {user}") # 确认数据库是否查到
+            
             self._current_user = user
             return user
-        except Exception:
+        except Exception as e:
+            # 打印真实的异常信息
+            # print(f"DEBUG: Error in get_current_user: {str(e)}")
+            import traceback
+            traceback.print_exc() # 打印堆栈
             return None
 
 
 async def get_context(request: Request) -> AsyncGenerator[CustomContext, None]:
+    # print("--- NEW GRAPHQL REQUEST RECEIVED ---")
     context = CustomContext(request)
     try:
         yield context

app/graphql/types.py

@@ -4,17 +4,39 @@ from datetime import datetime
 from strawberry.types import Info
 
 from app.utils.format import get_image_url
-from app.graphql.context import CustomContext
+from app.models.user import User
 
 @strawberry.type
 class UserType:
-    id: strawberry.ID
+    id: str
     email: str
-    name: Optional[str]
+    name: str
     handle: Optional[str]
-    avatar: Optional[str]
+    
+    @strawberry.field
+    def avatar(self, root: User) -> Optional[str]:
+        return root.avatar_url
+    
+    # 互动统计字段
     following_count: int
     follower_count: int
+    
+    # 统计汇总字段
+    owner_project_count: int
+    owner_likes_count: int
+    owner_favorites_count: int
+    owner_shares_count: int
+    
+    admin_project_count: int
+    admin_likes_count: int
+    admin_favorites_count: int
+    admin_shares_count: int
+    
+    user_project_count: int
+    user_likes_count: int
+    user_favorites_count: int
+    user_shares_count: int
+    
     created_at: datetime
 
     # 动态解析字段：例如自动处理头像的绝对路径

app/main.py

@@ -6,6 +6,7 @@ from strawberry.fastapi import GraphQLRouter
 from dotenv import load_dotenv
 
 from auth import router as auth_router
+from app.media.router import router as media_router
 
 from app.db import engine, SessionLocal
 from app.models import Base, User
@@ -44,6 +45,7 @@ graphql_router = GraphQLRouter(schema, context_getter=get_context)
 
 # 挂载路由
 app.include_router(auth_router)                         # 保留现有的 auth 路由供 Google OAuth 回调使用
+app.include_router(media_router)                        # 挂载媒体路由，提供头像代理访问等等
 app.include_router(graphql_router, prefix="/graphql")   # 挂载 GraphQL 终点，前端以后只需要请求 /graphql
 
 # 打印路由测试

app/media/router.py

@@ -0,0 +1,45 @@
+from fastapi import APIRouter, HTTPException
+from fastapi.responses import StreamingResponse
+import oss2
+from app.utils.s3 import bucket  
+
+router = APIRouter(prefix="/v1/media", tags=["Media"])
+
+@router.get("/{file_path:path}")
+async def get_avatar(file_path: str):
+    """
+    通过流式传输代理阿里云 OSS 中的图片
+    file_path 接收 avatars/xxx/avatar.jpg 等任何相对路径
+    """
+    s3_key = file_path.lstrip("/")
+    
+    if not s3_key:
+        raise HTTPException(status_code=400, detail="Invalid file path")
+        
+    try:
+        # 从阿里云 OSS 获取对象
+        # oss2 的 get_object 是同步阻塞的
+        # 初期可以直接用，后续高并发可以放入 run_in_executor
+        oss_object = bucket.get_object(s3_key)
+        
+        # 获取文件的 Content-Type
+        content_type = oss_object.headers.get("Content-Type", "image/jpeg")
+        
+        # 创建一个生成器来分块读取 OSS 数据，防止大文件时撑爆内存
+        def image_stream():
+            while True:
+                chunk = oss_object.read(1024 * 64)  # 每次读 64KB
+                if not chunk:
+                    break
+                yield chunk
+                
+        # 流式返回给前端
+        return StreamingResponse(image_stream(), media_type=content_type)
+        
+    except oss2.exceptions.NoSuchKey:
+        # 阿里云 OSS 专属的 404 异常
+        raise HTTPException(status_code=404, detail="Image not found in storage")
+    except Exception as e:
+        import traceback
+        traceback.print_exc()
+        raise HTTPException(status_code=500, detail="Internal storage service error")

app/models/user.py

@@ -17,6 +17,19 @@ class User(Base, AutoID):
     handle = Column(String, unique=True, index=True, nullable=True)
     avatar = Column(String)
     
+    @property
+    def avatar_url(self) -> str | None:
+        if not self.avatar:
+            return None
+            
+        # 如果是第三方（如未迁移成功时降级的 Google 原始链接），直接返回
+        if self.avatar.startswith(("http://", "https://")):
+            return self.avatar
+        
+        path = self.avatar.lstrip("/")
+        
+        return f"/v1/media/{path}"
+    
     # ---- 互动统计字段 ----
     following_count = Column(Integer, default=0, nullable=False, server_default="0")            # 关注了多少人
     follower_count = Column(Integer, default=0, nullable=False, server_default="0")             # 粉丝数

auth/deps.py

@@ -17,7 +17,7 @@ def get_current_user_id(request: Request):
         raise HTTPException(status_code=401, detail="Not authenticated")
 
     try:
-        payload = decode_token(token, JWT_SECRET, algorithms=[JWT_ALGORITHM])
+        payload = decode_token(token)
         return payload["sub"]
     except:
         raise HTTPException(status_code=401, detail="Invalid token")

auth/oauth/google.py

@@ -8,8 +8,9 @@ import secrets
 import json
 from urllib.parse import quote
 from dotenv import load_dotenv
+from sqlalchemy.orm import Session
 
-from app.db import SessionLocal
+from app.db import SessionLocal, get_db
 from app.models import User
 from auth.tokens import create_jwt_token, create_refresh_token, decode_token
 from app.utils.format import get_image_url
@@ -94,7 +95,13 @@ def login_google():
     return response
 
 @router.get("/auth/callback")
-async def auth_callback(request: Request, code: str, state: str, background_tasks: BackgroundTasks):
+async def auth_callback(
+    request: Request,
+    code: str,
+    state: str,
+    background_tasks: BackgroundTasks,
+    db: Session = Depends(get_db)
+):
     cookie_state = request.cookies.get("oauth_state")
 
     if not cookie_state or cookie_state != state:
@@ -121,10 +128,7 @@ async def auth_callback(request: Request, code: str, state: str, background_task
         )
 
         user_info = user_res.json()
-
-    db = SessionLocal()
     
-    try:
         user = db.query(User).filter(User.email == user_info["email"]).first()
 
         if not user:
@@ -166,8 +170,6 @@ async def auth_callback(request: Request, code: str, state: str, background_task
             
             # 这里不需要再次 refresh，除非后面还要用到更新后的 user 对象
             # db.refresh(user)
-    finally:
-        db.close()
 
     jwt_token = create_jwt_token({
         "sub": user.id,