style: auto-format with black + isort + ruff + prettier [skip ci-format-check]

apps/api/app/api/routes/ai_avatar_render.py

@@ -14,7 +14,6 @@ import logging
 from datetime import UTC, datetime
 
 from app.auth import AuthenticatedUser, get_current_user
-from packages.middleware.points_gate import points_gate
 from app.dependencies import get_db_session
 from app.schemas.ai_avatar_render import (
     AiAvatarRenderJobResponse,
@@ -30,6 +29,8 @@ from app.services.ai_avatar_render_service import (
 from fastapi import APIRouter, Depends, HTTPException, Query
 from sqlalchemy.orm import Session
 
+from packages.middleware.points_gate import points_gate
+
 logger = logging.getLogger(__name__)
 
 router = APIRouter()

apps/api/app/api/routes/generation_cover.py

@@ -15,7 +15,6 @@ from typing import Any, Optional
 from urllib.parse import urlparse
 
 from app.auth import AuthenticatedUser, get_current_user
-from packages.middleware.points_gate import points_gate
 from app.dependencies import get_db_session, get_generated_video_repository
 from app.services.edit_plan_service import EditPlanService
 from app.services.edit_template_service import EditTemplateService
@@ -28,6 +27,7 @@ from packages.adapters.sqlalchemy_impl.generation_task_repository import (
 )
 from packages.application import ListGeneratedVideosByTaskUseCase
 from packages.domain.config_schemas import normalize_plan_config
+from packages.middleware.points_gate import points_gate
 from packages.shared.storage import get_shared_storage_service
 
 from .templates_editor.dependencies import get_draft_plan_id, get_editor_services

apps/api/app/api/routes/generation_preview.py

@@ -8,7 +8,6 @@ from __future__ import annotations
 import logging
 
 from app.auth import AuthenticatedUser, get_current_user
-from packages.middleware.points_gate import points_gate
 from app.core.storage import get_storage_service
 from app.core.task_enqueue import (
     GLOBAL_PENDING_LIMIT,
@@ -44,6 +43,7 @@ from packages.application import (
     GetGenerationTaskUseCase,
     ListGeneratedVideosByTaskUseCase,
 )
+from packages.middleware.points_gate import points_gate
 
 logger = logging.getLogger(__name__)
 

apps/api/app/api/routes/generation_tasks.py

@@ -4,7 +4,6 @@ from typing import Any
 
 from app.api.routes._helpers import check_project_access
 from app.auth import AuthenticatedUser, get_current_user
-from packages.middleware.points_gate import points_gate
 from app.core.storage import OSSStorageService, get_storage_service
 from app.core.task_enqueue import (
     GLOBAL_PENDING_LIMIT,
@@ -43,6 +42,7 @@ from packages.application import (
     ListGeneratedVideosByTaskUseCase,
 )
 from packages.domain.smart_match import smart_select_assets
+from packages.middleware.points_gate import points_gate
 
 logger = logging.getLogger(__name__)
 

packages/middleware/points_gate.py

@@ -91,13 +91,16 @@ def points_gate(
         is_async = asyncio.iscoroutinefunction(func)
 
         if is_async:
+
             async def wrapper(*args: Any, **kwargs: Any) -> Any:
                 if not _pg_enabled():  # noqa: F821
                     return await func(*args, **kwargs)
                 return await _pg_execute(  # noqa: F821
                     func, args, kwargs, scene_key, per_unit, unit_field, quantity_field, True
                 )
+
         else:
+
             def wrapper(*args: Any, **kwargs: Any) -> Any:
                 if not _pg_enabled():  # noqa: F821
                     return func(*args, **_pg_filter(func, kwargs))  # noqa: F821
@@ -126,8 +129,7 @@ def points_gate(
                 # 为稳妥起见，直接把 wrapper code 的 co_names 映射到新名——复杂度过高，
                 # 这里采用「确保短名没冲突」策略：如果冲突就抛异常让开发者改名。
                 raise RuntimeError(
-                    f"points_gate: name collision in {func.__module__}.{func.__name__}: "
-                    f"'{k}' already defined"
+                    f"points_gate: name collision in {func.__module__}.{func.__name__}: " f"'{k}' already defined"
                 )
             merged_globals[k] = v
 

tests/unit/test_ai_avatar_render_points.py

@@ -1,4 +1,5 @@
 """AI数字人渲染 积分扣点单元测试 (#1895 P2 step 2.6)"""
+
 from __future__ import annotations
 
 from unittest.mock import MagicMock, patch
@@ -17,17 +18,19 @@ def _enable(monkeypatch):
 class TestAiAvatarRenderPoints:
     def test_ai_digital_human_per_unit(self):
         from packages.domain.points_rules import calculate_points_cost
+
         cost = calculate_points_cost("ai_digital_human", is_member=False, duration_minutes=1)
         assert cost >= 15
 
     def test_decorator_attached(self):
         from app.api.routes.ai_avatar_render import create_render_job
+
         assert hasattr(create_render_job, "__wrapped__"), "missing @points_gate"
 
     def test_insufficient_raises_402(self):
-        from fastapi import HTTPException
         from app.api.routes.ai_avatar_render import create_render_job
         from app.schemas.ai_avatar_render import CreateAiAvatarRenderRequest
+        from fastapi import HTTPException
 
         db = MagicMock()
         cu = MagicMock()

tests/unit/test_generation_cover.py

@@ -15,7 +15,6 @@ def _disable_points_gate(monkeypatch):
     yield
 
 
-
 def test_generation_cover_router_importable():
     """新路由模块可以正确导入"""
     from app.api.routes.generation_cover import router

tests/unit/test_generation_cover_points.py

@@ -1,4 +1,5 @@
 """AI封面生成 积分扣点单元测试 (#1895 P2 step 2.7)"""
+
 from __future__ import annotations
 
 from unittest.mock import MagicMock, patch
@@ -17,9 +18,11 @@ def _enable(monkeypatch):
 class TestGenerationCoverPoints:
     def test_ai_cover_cost(self):
         from packages.domain.points_rules import calculate_points_cost
+
         assert calculate_points_cost("ai_cover", is_member=False) == 2
         assert calculate_points_cost("ai_cover", is_member=True, member_type="yearly") >= 0
 
     def test_decorator_attached(self):
         from app.api.routes.generation_cover import generate_cover
+
         assert hasattr(generate_cover, "__wrapped__"), "missing @points_gate"

tests/unit/test_generation_preview.py

@@ -583,7 +583,6 @@ def _disable_points_gate(monkeypatch):
     yield
 
 
-
 def _make_user(user_id="test_user_001"):
     """构造 mock AuthenticatedUser"""
     mock_user = MagicMock()

tests/unit/test_generation_preview_points.py

@@ -1,4 +1,5 @@
 """视频预览生成 积分扣点单元测试 (#1895 P2 step 2.5)"""
+
 from __future__ import annotations
 
 from unittest.mock import MagicMock, patch
@@ -17,13 +18,14 @@ def _enable(monkeypatch):
 class TestGenerationPreviewPoints:
     def test_ai_video_cost(self):
         from packages.domain.points_rules import calculate_points_cost
+
         assert calculate_points_cost("ai_video", is_member=False) == 4
         assert calculate_points_cost("ai_video", is_member=True, member_type="monthly") == 2
 
     def test_insufficient_raises_402(self):
-        from fastapi import HTTPException
         from app.api.routes.generation_preview import create_preview_generation_task
         from app.schemas.generation_task import CreatePreviewGenerationTaskRequest
+        from fastapi import HTTPException
 
         db = MagicMock()
         cu = MagicMock()
@@ -38,7 +40,9 @@ class TestGenerationPreviewPoints:
             MS.return_value = svc
             with pytest.raises(HTTPException) as ei:
                 create_preview_generation_task(
-                    request=req, authenticated_user=cu, db=db,
+                    request=req,
+                    authenticated_user=cu,
+                    db=db,
                     generation_task_repository=MagicMock(),
                     asset_repo=MagicMock(),
                 )
@@ -46,4 +50,5 @@ class TestGenerationPreviewPoints:
 
     def test_decorator_attached(self):
         from app.api.routes.generation_preview import create_preview_generation_task
+
         assert hasattr(create_preview_generation_task, "__wrapped__"), "missing @points_gate"

tests/unit/test_generation_tasks.py

@@ -6,6 +6,7 @@ from unittest.mock import MagicMock
 
 import pytest
 
+import packages.middleware.points_gate as _pg_module
 from packages.application.generation_tasks import (
     CreateGenerationTaskCommand,
     CreateGenerationTaskUseCase,
@@ -17,8 +18,6 @@ from packages.application.generation_tasks import (
 )
 from packages.domain import GenerationTask
 
-import packages.middleware.points_gate as _pg_module
-
 
 @pytest.fixture(autouse=True)
 def _disable_points_gate(monkeypatch):
@@ -27,7 +26,6 @@ def _disable_points_gate(monkeypatch):
     yield
 
 
-
 @pytest.fixture
 def mock_repo():
     return MagicMock()

tests/unit/test_generation_tasks_points.py

@@ -1,4 +1,5 @@
 """视频生成 积分扣点单元测试 (#1895 P2 step 2.4)"""
+
 from __future__ import annotations
 
 from unittest.mock import MagicMock, patch
@@ -17,19 +18,21 @@ def _enable(monkeypatch):
 class TestGenerationTasksPoints:
     def test_ai_video_base_cost(self):
         from packages.domain.points_rules import calculate_points_cost
+
         assert calculate_points_cost("ai_video", is_member=False) == 4
         assert calculate_points_cost("ai_video", is_member=True, member_type="monthly") == 2
 
     def test_ai_video_quantity_scales(self):
         from packages.domain.points_rules import calculate_points_cost
+
         c1 = calculate_points_cost("ai_video", is_member=False, quantity=1)
         c3 = calculate_points_cost("ai_video", is_member=False, quantity=3)
         assert c3 > c1
 
     def test_insufficient_raises_402(self):
-        from fastapi import HTTPException
         from app.api.routes.generation_tasks import create_generation_task
         from app.schemas.generation_task import CreateGenerationTaskRequest
+        from fastapi import HTTPException
 
         db = MagicMock()
         cu = MagicMock()
@@ -44,12 +47,17 @@ class TestGenerationTasksPoints:
             MS.return_value = svc
             with pytest.raises(HTTPException) as ei:
                 create_generation_task(
-                    request=req, authenticated_user=cu, db=db,
-                    generation_task_repository=MagicMock(), project_repository=MagicMock(),
-                    asset_library_repository=MagicMock(), asset_repository=MagicMock(),
+                    request=req,
+                    authenticated_user=cu,
+                    db=db,
+                    generation_task_repository=MagicMock(),
+                    project_repository=MagicMock(),
+                    asset_library_repository=MagicMock(),
+                    asset_repository=MagicMock(),
                 )
             assert ei.value.status_code == 402
 
     def test_decorator_attached(self):
         from app.api.routes.generation_tasks import create_generation_task
+
         assert hasattr(create_generation_task, "__wrapped__"), "missing @points_gate"