test(wave129): asset_scoring资产评分+64单测

- 覆盖8大模块：权重/分辨率评分/时长评分/码率评分/加权总分/单素材评分/分桶/多样性选择/候选过滤/数据类
- 边界值全覆盖：0/None/负数/临界值/最佳区间
- 多样性选择验证：多桶分布/去重/配额/不足时回退

apps/web/src/router/ProtectedRoute.tsx

@@ -1,16 +0,0 @@
-import React from "react"
-import { Navigate } from "react-router-dom"
-import { useAuthStore } from "@/store/authStore"
-
-/** 受保护的路由组件 */
-// eslint-disable-next-line react-refresh/only-export-components
-export const ProtectedRoute = ({ children }: { children: React.ReactNode }) => {
-  const isAuthenticated = useAuthStore((state) => state.isAuthenticated)
-  const hasAccessToken = Boolean(localStorage.getItem("access_token"))
-
-  if (!isAuthenticated || !hasAccessToken) {
-    return <Navigate to="/login" replace />
-  }
-
-  return <>{children}</>
-}

apps/web/src/router/appRoutes.tsx

@@ -1,225 +0,0 @@
-import { Navigate, type RouteObject } from "react-router-dom"
-import MainLayout from "@/components/layout/MainLayout"
-import { ProtectedRoute } from "./ProtectedRoute"
-
-/**
- * 受保护的 /app 子路由
- * 所有页面使用 lazy 懒加载
- */
-const appChildren: RouteObject[] = [
-  {
-    index: true,
-    element: <Navigate to="/app/dashboard" replace />,
-  },
-  {
-    path: "dashboard",
-    lazy: () =>
-      import("@/pages/dashboard/Dashboard").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "assets",
-    lazy: () =>
-      import("@/pages/assets/AssetLibrary").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "titles",
-    lazy: () =>
-      import("@/pages/titles/TitleLibrary").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "voices",
-    lazy: () =>
-      import("@/pages/voices/VoiceLibrary").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "templates",
-    lazy: () =>
-      import("@/pages/templates/TemplateLibrary").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "generate",
-    lazy: () =>
-      import("@/pages/generate/GeneratePage").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "history",
-    lazy: () =>
-      import("@/pages/history/TaskHistory").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "products",
-    lazy: () =>
-      import("@/pages/products/ProductLibrary").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "products/:id",
-    lazy: () =>
-      import("@/pages/products/ProductDetail").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "tasks",
-    lazy: () =>
-      import("@/pages/tasks/TaskCenter").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "editing-planner",
-    lazy: () =>
-      import("@/pages/editing-planner/EditingPlanner").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "my-templates",
-    lazy: () =>
-      import("@/pages/my-templates/MyTemplates").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "voice-clone",
-    lazy: () =>
-      import("@/pages/voice-clone/VoiceClone").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "voice-materials",
-    lazy: () =>
-      import("@/pages/voice-materials/VoiceMaterialLibrary").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "my-voices",
-    lazy: () =>
-      import("@/pages/my-voices/MyVoices").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "accounts",
-    lazy: () =>
-      import("@/pages/accounts/Accounts").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "duplication",
-    lazy: () =>
-      import("@/pages/duplication/DuplicationUpload").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "duplication/results",
-    lazy: () =>
-      import("@/pages/duplication/DuplicationResults").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "duplication/:id",
-    lazy: () =>
-      import("@/pages/duplication/DuplicationDetail").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "subscription",
-    lazy: () =>
-      import("@/pages/subscription/Plans").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "subscription/upgrade",
-    lazy: () =>
-      import("@/pages/subscription/UpgradeSubscription").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "subscription/billing",
-    lazy: () =>
-      import("@/pages/subscription/Billing").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "profile",
-    lazy: () =>
-      import("@/pages/profile/Settings").then((m) => ({
-        Component: m.default,
-      })),
-  },
-  {
-    path: "admin",
-    children: [
-      {
-        index: true,
-        lazy: () =>
-          import("@/pages/admin/AdminComingSoon").then((m) => ({
-            Component: m.default,
-          })),
-      },
-      {
-        path: "users",
-        lazy: () =>
-          import("@/pages/admin/AdminComingSoon").then((m) => ({
-            Component: m.default,
-          })),
-      },
-      {
-        path: "analytics",
-        lazy: () =>
-          import("@/pages/admin/AdminComingSoon").then((m) => ({
-            Component: m.default,
-          })),
-      },
-      {
-        path: "monitor",
-        lazy: () =>
-          import("@/pages/admin/AdminComingSoon").then((m) => ({
-            Component: m.default,
-          })),
-      },
-      {
-        path: "logs",
-        lazy: () =>
-          import("@/pages/admin/AdminComingSoon").then((m) => ({
-            Component: m.default,
-          })),
-      },
-    ],
-  },
-]
-
-export const appRoutes: RouteObject = {
-  path: "/app",
-  element: (
-    <ProtectedRoute>
-      <MainLayout />
-    </ProtectedRoute>
-  ),
-  children: appChildren,
-}

apps/web/src/router/index.tsx

@@ -3,13 +3,283 @@
  * 扁平化路由：去掉 Project 层级，所有资源直接归属用户
  */
 import { createBrowserRouter, Navigate } from "react-router-dom"
-import { publicRoutes } from "./publicRoutes"
-import { appRoutes } from "./appRoutes"
+import React from "react"
+import MainLayout from "@/components/layout/MainLayout"
+import Login from "@/pages/auth/Login"
+import Register from "@/pages/auth/Register"
+import ForgotPassword from "@/pages/auth/ForgotPassword"
+import ResetPassword from "@/pages/auth/ResetPassword"
+import WechatCallback from "@/pages/auth/WechatCallback"
+import HomePage from "@/pages/home/HomePage"
+import { useAuthStore } from "@/store/authStore"
+
+/** 受保护的路由组件 */
+// eslint-disable-next-line react-refresh/only-export-components
+const ProtectedRoute = ({ children }: { children: React.ReactNode }) => {
+  const isAuthenticated = useAuthStore((state) => state.isAuthenticated)
+  const hasAccessToken = Boolean(localStorage.getItem("access_token"))
+
+  if (!isAuthenticated || !hasAccessToken) {
+    return <Navigate to="/login" replace />
+  }
+
+  return <>{children}</>
+}
+
+/** 首页路由组件：已登录跳 dashboard，未登录显示落地页 */
+// eslint-disable-next-line react-refresh/only-export-components
+const HomeRoute: React.FC = () => {
+  const isAuthenticated = useAuthStore((state) => state.isAuthenticated)
+  const hasAccessToken = Boolean(localStorage.getItem("access_token"))
+
+  if (isAuthenticated && hasAccessToken) {
+    return <Navigate to="/app/dashboard" replace />
+  }
+
+  return <HomePage />
+}
 
 /** 路由配置 */
 export const router = createBrowserRouter([
-  ...publicRoutes,
-  appRoutes,
+  {
+    path: "/",
+    element: <HomeRoute />,
+  },
+  {
+    path: "/login",
+    element: <Login />,
+  },
+  {
+    path: "/register",
+    element: <Register />,
+  },
+  {
+    path: "/forgot-password",
+    element: <ForgotPassword />,
+  },
+  {
+    path: "/reset-password",
+    element: <ResetPassword />,
+  },
+  {
+    path: "/auth/wechat/callback",
+    element: <WechatCallback />,
+  },
+  {
+    path: "/app",
+    element: (
+      <ProtectedRoute>
+        <MainLayout />
+      </ProtectedRoute>
+    ),
+    children: [
+      {
+        index: true,
+        element: <Navigate to="/app/dashboard" replace />,
+      },
+      {
+        path: "dashboard",
+        lazy: () =>
+          import("@/pages/dashboard/Dashboard").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "assets",
+        lazy: () =>
+          import("@/pages/assets/AssetLibrary").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "titles",
+        lazy: () =>
+          import("@/pages/titles/TitleLibrary").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "voices",
+        lazy: () =>
+          import("@/pages/voices/VoiceLibrary").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "templates",
+        lazy: () =>
+          import("@/pages/templates/TemplateLibrary").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "generate",
+        lazy: () =>
+          import("@/pages/generate/GeneratePage").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "history",
+        lazy: () =>
+          import("@/pages/history/TaskHistory").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "products",
+        lazy: () =>
+          import("@/pages/products/ProductLibrary").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "products/:id",
+        lazy: () =>
+          import("@/pages/products/ProductDetail").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "tasks",
+        lazy: () =>
+          import("@/pages/tasks/TaskCenter").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "editing-planner",
+        lazy: () =>
+          import("@/pages/editing-planner/EditingPlanner").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "my-templates",
+        lazy: () =>
+          import("@/pages/my-templates/MyTemplates").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "voice-clone",
+        lazy: () =>
+          import("@/pages/voice-clone/VoiceClone").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "voice-materials",
+        lazy: () =>
+          import("@/pages/voice-materials/VoiceMaterialLibrary").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "my-voices",
+        lazy: () =>
+          import("@/pages/my-voices/MyVoices").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "accounts",
+        lazy: () =>
+          import("@/pages/accounts/Accounts").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "duplication",
+        lazy: () =>
+          import("@/pages/duplication/DuplicationUpload").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "duplication/results",
+        lazy: () =>
+          import("@/pages/duplication/DuplicationResults").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "duplication/:id",
+        lazy: () =>
+          import("@/pages/duplication/DuplicationDetail").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "subscription",
+        lazy: () =>
+          import("@/pages/subscription/Plans").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "subscription/upgrade",
+        lazy: () =>
+          import("@/pages/subscription/UpgradeSubscription").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "subscription/billing",
+        lazy: () =>
+          import("@/pages/subscription/Billing").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "profile",
+        lazy: () =>
+          import("@/pages/profile/Settings").then((m) => ({
+            Component: m.default,
+          })),
+      },
+      {
+        path: "admin",
+        children: [
+          {
+            index: true,
+            lazy: () =>
+              import("@/pages/admin/AdminComingSoon").then((m) => ({
+                Component: m.default,
+              })),
+          },
+          {
+            path: "users",
+            lazy: () =>
+              import("@/pages/admin/AdminComingSoon").then((m) => ({
+                Component: m.default,
+              })),
+          },
+          {
+            path: "analytics",
+            lazy: () =>
+              import("@/pages/admin/AdminComingSoon").then((m) => ({
+                Component: m.default,
+              })),
+          },
+          {
+            path: "monitor",
+            lazy: () =>
+              import("@/pages/admin/AdminComingSoon").then((m) => ({
+                Component: m.default,
+              })),
+          },
+          {
+            path: "logs",
+            lazy: () =>
+              import("@/pages/admin/AdminComingSoon").then((m) => ({
+                Component: m.default,
+              })),
+          },
+        ],
+      },
+    ],
+  },
   {
     path: "*",
     element: <Navigate to="/" replace />,

apps/web/src/router/publicRoutes.tsx

@@ -1,48 +0,0 @@
-import { Navigate, type RouteObject } from "react-router-dom"
-import HomePage from "@/pages/home/HomePage"
-import Login from "@/pages/auth/Login"
-import Register from "@/pages/auth/Register"
-import ForgotPassword from "@/pages/auth/ForgotPassword"
-import ResetPassword from "@/pages/auth/ResetPassword"
-import WechatCallback from "@/pages/auth/WechatCallback"
-import { useAuthStore } from "@/store/authStore"
-
-/** 首页路由组件：已登录跳 dashboard，未登录显示落地页 */
-// eslint-disable-next-line react-refresh/only-export-components
-const HomeRoute: React.FC = () => {
-  const isAuthenticated = useAuthStore((state) => state.isAuthenticated)
-  const hasAccessToken = Boolean(localStorage.getItem("access_token"))
-
-  if (isAuthenticated && hasAccessToken) {
-    return <Navigate to="/app/dashboard" replace />
-  }
-
-  return <HomePage />
-}
-
-export const publicRoutes: RouteObject[] = [
-  {
-    path: "/",
-    element: <HomeRoute />,
-  },
-  {
-    path: "/login",
-    element: <Login />,
-  },
-  {
-    path: "/register",
-    element: <Register />,
-  },
-  {
-    path: "/forgot-password",
-    element: <ForgotPassword />,
-  },
-  {
-    path: "/reset-password",
-    element: <ResetPassword />,
-  },
-  {
-    path: "/auth/wechat/callback",
-    element: <WechatCallback />,
-  },
-]

apps/worker/video_processing/speed_engine.py

@@ -1,4 +1,4 @@
-"""视频调速引擎 — 基于 FFmpeg setpts + atempo 的速度调整能力.
+"""视频调速引擎 — 基于 FFmpeg setpts + atempo 的速度调整能力。
 
 支持：
 - 0.25x ~ 4x 变速范围
@@ -6,57 +6,147 @@
 - 音频调速（atempo，多级串联处理超范围值）
 - 音调修正（pitch_correct，默认开启）
 - 边界自动钳制，不阻断渲染
-
-注：核心领域模型已抽离到 packages/domain/speed_config.py，
-本模块保留薄包装层，确保向后兼容。
 """
 
-from __future__ import annotations
-
+from dataclasses import dataclass
 from typing import Optional
 
-from packages.domain.speed_config import (  # noqa: F401 — 向后兼容
-    DEFAULT_SPEED,
-    MAX_SPEED,
-    MIN_SPEED,
-    SpeedConfig,
-    _split_atempo_stages,
-    adjust_duration as _adjust_duration_base,
-    build_audio_filter as _build_audio_filter_base,
-    build_video_filter as _build_video_filter_base,
-    resolve_clip_speed as _resolve_clip_speed_base,
-)
+# ─── 常量 ───────────────────────────────────────────────
+MIN_SPEED = 0.25
+MAX_SPEED = 4.0
+DEFAULT_SPEED = 1.0
+
+# atempo 单级有效范围
+_ATEMPO_MIN = 0.5
+_ATEMPO_MAX = 2.0
+
+
+@dataclass
+class SpeedConfig:
+    """调速配置。
+
+    Attributes:
+        speed: 播放速度，0.25~4.0，1.0 为原速
+        pitch_correct: 是否保持音调（默认 True，用 atempo 时间拉伸算法）
+    """
+
+    speed: float = DEFAULT_SPEED
+    pitch_correct: bool = True
+
+    @classmethod
+    def parse(cls, data: Optional[dict]) -> "SpeedConfig":
+        """从 dict 解析配置，无效值回退到默认。"""
+        if not data or not isinstance(data, dict):
+            return cls()
+
+        speed = data.get("speed", DEFAULT_SPEED)
+        if not isinstance(speed, (int, float)):
+            speed = DEFAULT_SPEED
+
+        pitch_correct = data.get("pitch_correct", True)
+        if not isinstance(pitch_correct, bool):
+            pitch_correct = True
+
+        config = cls(speed=float(speed), pitch_correct=pitch_correct)
+        config.clamp()
+        return config
+
+    def clamp(self) -> None:
+        """将速度钳制到合法范围。"""
+        if self.speed <= 0:
+            self.speed = DEFAULT_SPEED
+        elif self.speed < MIN_SPEED:
+            self.speed = MIN_SPEED
+        elif self.speed > MAX_SPEED:
+            self.speed = MAX_SPEED
+
+    @property
+    def is_original(self) -> bool:
+        """是否原速（无需调速）。"""
+        return abs(self.speed - 1.0) < 1e-6
 
 
 class SpeedEngine:
-    """调速引擎 — 生成 FFmpeg 调速滤镜链.
+    """调速引擎 — 生成 FFmpeg 调速滤镜链。
 
-    薄包装层，实际逻辑委托给 packages.domain.speed_config。
+    用法：
+        engine = SpeedEngine()
+        video_filter = engine.build_video_filter(config)
+        audio_filter = engine.build_audio_filter(config)
+        new_duration = engine.adjust_duration(duration, config)
     """
 
     def build_video_filter(self, config: SpeedConfig) -> str:
-        """生成视频调速滤镜字符串."""
-        return _build_video_filter_base(config)
+        """生成视频调速滤镜字符串。
+
+        返回 setpts 滤镜表达式，原速时返回空字符串。
+        """
+        if config.is_original:
+            return ""
+        # setpts=PTS/speed — speed>1 加速，speed<1 减速
+        return f"setpts=PTS/{config.speed:.4f}"
 
     def build_audio_filter(self, config: SpeedConfig) -> str:
-        """生成音频调速滤镜字符串."""
-        return _build_audio_filter_base(config)
+        """生成音频调速滤镜字符串。
+
+        atempo 单级范围 0.5~2.0，超出范围时自动多级串联：
+        - 0.25x → atempo=0.5,atempo=0.5
+        - 4x → atempo=2.0,atempo=2.0
+        - 0.3x → atempo=0.5,atempo=0.6
+        - 3x → atempo=2.0,atempo=1.5
+
+        原速时返回空字符串。
+        """
+        if config.is_original:
+            return ""
+
+        speed = config.speed
+        stages: list[float] = self._split_atempo_stages(speed)
+        return ",".join(f"atempo={s:.4f}" for s in stages)
 
     @staticmethod
     def _split_atempo_stages(speed: float) -> list[float]:
-        """将速度拆分为多级 atempo 串联（内部方法，向后兼容）."""
-        return _split_atempo_stages(speed)
+        """将速度拆分为多级 atempo 串联，每级都在 [0.5, 2.0] 范围内。"""
+        if _ATEMPO_MIN <= speed <= _ATEMPO_MAX:
+            return [speed]
+
+        stages: list[float] = []
+        remaining = speed
+
+        # 加速场景（speed > 2.0）
+        if speed > _ATEMPO_MAX:
+            while remaining > _ATEMPO_MAX:
+                stages.append(_ATEMPO_MAX)
+                remaining /= _ATEMPO_MAX
+            stages.append(remaining)
+
+        # 减速场景（speed < 0.5）
+        else:
+            while remaining < _ATEMPO_MIN:
+                stages.append(_ATEMPO_MIN)
+                remaining /= _ATEMPO_MIN
+            stages.append(remaining)
+
+        return stages
 
     def adjust_duration(self, original_duration: float, config: SpeedConfig) -> float:
-        """计算调速后的时长."""
-        return _adjust_duration_base(original_duration, config)
+        """计算调速后的时长。
+
+        加速 → 时长变短；减速 → 时长变长。
+        """
+        if config.is_original or original_duration <= 0:
+            return original_duration
+        return original_duration / config.speed
 
     def build_clip_speed_filter(
         self,
         speed: float,
         pitch_correct: bool = True,
     ) -> tuple[str, str, SpeedConfig]:
-        """便捷方法：从单一 speed 值生成视频+音频滤镜."""
+        """便捷方法：从单一 speed 值生成视频+音频滤镜。
+
+        返回 (video_filter, audio_filter, config)。
+        """
         config = SpeedConfig(speed=speed, pitch_correct=pitch_correct)
         config.clamp()
         return (
@@ -70,5 +160,8 @@ class SpeedEngine:
         clip_config: dict,
         global_speed: float = DEFAULT_SPEED,
     ) -> float:
-        """从 clip config 中解析 playback_speed，0 或缺失则使用全局速度."""
-        return _resolve_clip_speed_base(clip_config, global_speed)
+        """从 clip config 中解析 playback_speed，0 或缺失则使用全局速度。"""
+        speed = clip_config.get("playback_speed", 0) if clip_config else 0
+        if not isinstance(speed, (int, float)) or speed <= 0:
+            return global_speed
+        return float(speed)

packages/domain/speed_config.py

@@ -1,179 +0,0 @@
-"""调速配置领域模型 — 纯逻辑，无FFmpeg依赖.
-
-抽离自 speed_engine.py，包含：
-- SpeedConfig 数据类（解析/钳制/原速判断）
-- 视频/音频调速滤镜构建
-- atempo 多级拆分算法
-- 时长计算
-"""
-
-from __future__ import annotations
-
-from dataclasses import dataclass
-from typing import Any
-
-# ─── 常量 ───────────────────────────────────────────────
-MIN_SPEED = 0.25
-MAX_SPEED = 4.0
-DEFAULT_SPEED = 1.0
-
-# atempo 单级有效范围
-_ATEMPO_MIN = 0.5
-_ATEMPO_MAX = 2.0
-
-
-@dataclass
-class SpeedConfig:
-    """调速配置.
-
-    Attributes:
-        speed: 播放速度，0.25~4.0，1.0 为原速
-        pitch_correct: 是否保持音调（默认 True，用 atempo 时间拉伸算法）
-    """
-
-    speed: float = DEFAULT_SPEED
-    pitch_correct: bool = True
-
-    @classmethod
-    def parse(cls, data: dict[str, Any] | None) -> SpeedConfig:
-        """从 dict 解析配置，无效值回退到默认."""
-        if not data or not isinstance(data, dict):
-            return cls()
-
-        speed = data.get("speed", DEFAULT_SPEED)
-        if not isinstance(speed, (int, float)):
-            speed = DEFAULT_SPEED
-
-        pitch_correct = data.get("pitch_correct", True)
-        if not isinstance(pitch_correct, bool):
-            pitch_correct = True
-
-        config = cls(speed=float(speed), pitch_correct=pitch_correct)
-        config.clamp()
-        return config
-
-    def clamp(self) -> None:
-        """将速度钳制到合法范围."""
-        if self.speed <= 0:
-            self.speed = DEFAULT_SPEED
-        elif self.speed < MIN_SPEED:
-            self.speed = MIN_SPEED
-        elif self.speed > MAX_SPEED:
-            self.speed = MAX_SPEED
-
-    @property
-    def is_original(self) -> bool:
-        """是否原速（无需调速）."""
-        return abs(self.speed - 1.0) < 1e-6
-
-    @property
-    def is_fast(self) -> bool:
-        """是否加速播放."""
-        return self.speed > 1.0
-
-    @property
-    def is_slow(self) -> bool:
-        """是否减速播放."""
-        return self.speed < 1.0
-
-
-# ── 滤镜构建 ────────────────────────────────────────────────────────────────
-
-
-def build_video_filter(config: SpeedConfig) -> str:
-    """生成视频调速滤镜字符串.
-
-    返回 setpts 滤镜表达式，原速时返回空字符串。
-    """
-    if config.is_original:
-        return ""
-    # setpts=PTS/speed — speed>1 加速，speed<1 减速
-    return f"setpts=PTS/{config.speed:.4f}"
-
-
-def build_audio_filter(config: SpeedConfig) -> str:
-    """生成音频调速滤镜字符串.
-
-    atempo 单级范围 0.5~2.0，超出范围时自动多级串联：
-    - 0.25x → atempo=0.5,atempo=0.5
-    - 4x → atempo=2.0,atempo=2.0
-    - 0.3x → atempo=0.5,atempo=0.6
-    - 3x → atempo=2.0,atempo=1.5
-
-    原速时返回空字符串。
-    """
-    if config.is_original:
-        return ""
-
-    speed = config.speed
-    stages: list[float] = _split_atempo_stages(speed)
-    return ",".join(f"atempo={s:.4f}" for s in stages)
-
-
-def _split_atempo_stages(speed: float) -> list[float]:
-    """将速度拆分为多级 atempo 串联，每级都在 [0.5, 2.0] 范围内."""
-    if _ATEMPO_MIN <= speed <= _ATEMPO_MAX:
-        return [speed]
-
-    stages: list[float] = []
-    remaining = speed
-
-    # 加速场景（speed > 2.0）
-    if speed > _ATEMPO_MAX:
-        while remaining > _ATEMPO_MAX:
-            stages.append(_ATEMPO_MAX)
-            remaining /= _ATEMPO_MAX
-        stages.append(remaining)
-
-    # 减速场景（speed < 0.5）
-    else:
-        while remaining < _ATEMPO_MIN:
-            stages.append(_ATEMPO_MIN)
-            remaining /= _ATEMPO_MIN
-        stages.append(remaining)
-
-    return stages
-
-
-# ── 时长计算 ────────────────────────────────────────────────────────────────
-
-
-def adjust_duration(original_duration: float, config: SpeedConfig) -> float:
-    """计算调速后的时长.
-
-    加速 → 时长变短；减速 → 时长变长。
-    """
-    if config.is_original or original_duration <= 0:
-        return original_duration
-    return original_duration / config.speed
-
-
-# ── 便捷方法 ────────────────────────────────────────────────────────────────
-
-
-def build_clip_speed_filter(
-    speed: float,
-    pitch_correct: bool = True,
-) -> tuple[str, str, SpeedConfig]:
-    """便捷方法：从单一 speed 值生成视频+音频滤镜.
-
-    返回 (video_filter, audio_filter, config)。
-    """
-    config = SpeedConfig(speed=speed, pitch_correct=pitch_correct)
-    config.clamp()
-    return (
-        build_video_filter(config),
-        build_audio_filter(config),
-        config,
-    )
-
-
-def resolve_clip_speed(
-    clip_config: dict[str, Any] | None,
-    global_speed: float = DEFAULT_SPEED,
-) -> float:
-    """从 clip config 中解析 playback_speed，0 或缺失则使用全局速度."""
-    speed = clip_config.get("playback_speed", 0) if clip_config else 0
-    if not isinstance(speed, (int, float)) or speed <= 0:
-        return global_speed
-    return float(speed)

tests/unit/test_asset_scoring_domain.py

@@ -0,0 +1,515 @@
+"""资产评分纯逻辑单元测试 — wave129."""
+
+from __future__ import annotations
+
+from dataclasses import dataclass
+
+import pytest
+
+from packages.domain.asset_scoring import (
+    AssetScoreDetail,
+    SmartSelectResult,
+    _bucket_by_duration,
+    calculate_total_score,
+    diverse_selection,
+    filter_candidates,
+    score_asset_detail,
+    score_bitrate,
+    score_duration,
+    score_resolution,
+    WEIGHT_QUALITY,
+    WEIGHT_RESOLUTION,
+    WEIGHT_DURATION,
+    WEIGHT_BITRATE,
+)
+
+# ── 常量与权重 ──────────────────────────────────────────────────────────────
+
+
+class TestWeights:
+    def test_weights_sum_to_one(self):
+        total = WEIGHT_QUALITY + WEIGHT_RESOLUTION + WEIGHT_DURATION + WEIGHT_BITRATE
+        assert abs(total - 1.0) < 0.001
+
+    def test_quality_is_highest_weight(self):
+        assert WEIGHT_QUALITY > WEIGHT_RESOLUTION
+        assert WEIGHT_QUALITY > WEIGHT_DURATION
+        assert WEIGHT_QUALITY > WEIGHT_BITRATE
+
+
+# ── 分辨率评分 ──────────────────────────────────────────────────────────────
+
+
+class TestScoreResolution:
+    def test_exact_target_full_score(self):
+        assert score_resolution(1920, 1080) == 1.0
+
+    def test_higher_than_target_full_score(self):
+        """4K 等高于目标分辨率也给满分."""
+        assert score_resolution(3840, 2160) == 1.0
+        assert score_resolution(2560, 1440) == 1.0
+
+    def test_seventytwop_less_than_one(self):
+        score = score_resolution(1280, 720)
+        assert 0.5 < score < 1.0
+
+    def test_fourheightyp_even_lower(self):
+        score_480 = score_resolution(854, 480)
+        score_720 = score_resolution(1280, 720)
+        assert score_480 < score_720
+
+    def test_none_returns_medium(self):
+        assert score_resolution(None, None) == 0.5
+        assert score_resolution(None, 1080) == 0.5
+        assert score_resolution(1920, None) == 0.5
+
+    def test_zero_or_negative_returns_medium(self):
+        assert score_resolution(0, 1080) == 0.5
+        assert score_resolution(-100, 1080) == 0.5
+        assert score_resolution(1920, 0) == 0.5
+
+    def test_custom_target_resolution(self):
+        score = score_resolution(1280, 720, target_width=1280, target_height=720)
+        assert score == 1.0
+
+    def test_score_between_zero_one(self):
+        score = score_resolution(320, 240)
+        assert 0.0 < score < 1.0
+
+    def test_very_low_resolution_not_zero(self):
+        """低分也不会低于 0.1."""
+        score = score_resolution(160, 120)
+        assert score >= 0.1
+
+
+# ── 时长评分 ────────────────────────────────────────────────────────────────
+
+
+class TestScoreDuration:
+    def test_optimal_range_full_score(self):
+        """3-30秒最佳区间满分."""
+        assert score_duration(3.0) == 1.0
+        assert score_duration(10.0) == 1.0
+        assert score_duration(30.0) == 1.0
+
+    def test_very_short_lower_score(self):
+        score_1s = score_duration(1.0)
+        assert 0.3 <= score_1s < 1.0
+
+    def test_shorter_than_optimal_lower(self):
+        """越短分越低."""
+        score_1 = score_duration(1.0)
+        score_2 = score_duration(2.0)
+        assert score_1 < score_2
+
+    def test_just_below_optimal(self):
+        score = score_duration(2.9)
+        assert score < 1.0
+        assert score > 0.8  # 接近满分
+
+    def test_too_long_penalty(self):
+        score_30 = score_duration(30.0)
+        score_60 = score_duration(60.0)
+        assert score_60 < score_30
+
+    def test_very_long_minimum_floor(self):
+        """超长素材最低 0.2 分."""
+        score = score_duration(1000.0)
+        assert score >= 0.2
+
+    def test_none_returns_medium(self):
+        assert score_duration(None) == 0.5
+
+    def test_zero_returns_medium(self):
+        assert score_duration(0) == 0.5
+        assert score_duration(0.0) == 0.5
+
+    def test_negative_returns_medium(self):
+        assert score_duration(-5.0) == 0.5
+
+
+# ── 码率评分 ────────────────────────────────────────────────────────────────
+
+
+class TestScoreBitrate:
+    def test_optimal_bitrate_full_score(self):
+        """2-8 Mbps 区间满分."""
+        # 5 Mbps, 10秒 = 50Mbit = 6.25MB = 6,250,000 字节
+        size_5mbps_10s = int(5_000_000 * 10 / 8)
+        assert score_bitrate(size_5mbps_10s, 10.0) == 1.0
+
+        # 3 Mbps, 5秒
+        size_3mbps_5s = int(3_000_000 * 5 / 8)
+        assert score_bitrate(size_3mbps_5s, 5.0) == 1.0
+
+    def test_low_bitrate_lower_score(self):
+        """码率低得分低."""
+        # 500 Kbps
+        size_low = int(500_000 * 10 / 8)
+        score = score_bitrate(size_low, 10.0)
+        assert 0.3 <= score < 1.0
+
+    def test_high_bitrate_moderate_penalty(self):
+        """码率过高适度扣分，最低0.5."""
+        # 50 Mbps，远超 8Mbps
+        size_high = int(50_000_000 * 10 / 8)
+        score = score_bitrate(size_high, 10.0)
+        assert 0.5 <= score < 1.0
+
+    def test_none_duration_returns_medium(self):
+        assert score_bitrate(1_000_000, None) == 0.5
+
+    def test_zero_file_size_returns_medium(self):
+        assert score_bitrate(0, 10.0) == 0.5
+
+    def test_zero_duration_returns_medium(self):
+        assert score_bitrate(1_000_000, 0) == 0.5
+        assert score_bitrate(1_000_000, -5.0) == 0.5
+
+
+# ── 加权总分 ────────────────────────────────────────────────────────────────
+
+
+class TestCalculateTotalScore:
+    def test_all_perfect(self):
+        assert calculate_total_score(1.0, 1.0, 1.0, 1.0) == 1.0
+
+    def test_all_zero(self):
+        assert calculate_total_score(0.0, 0.0, 0.0, 0.0) == 0.0
+
+    def test_weighted_calculation(self):
+        """手动验证加权计算."""
+        q, r, d, b = 0.8, 0.6, 0.4, 0.2
+        expected = WEIGHT_QUALITY * q + WEIGHT_RESOLUTION * r + WEIGHT_DURATION * d + WEIGHT_BITRATE * b
+        assert calculate_total_score(q, r, d, b) == pytest.approx(expected, rel=1e-3)
+
+    def test_quality_dominates(self):
+        """质量分权重最高，质量分变化影响最大."""
+        score_high_quality = calculate_total_score(1.0, 0.5, 0.5, 0.5)
+        score_low_quality = calculate_total_score(0.0, 0.5, 0.5, 0.5)
+        diff_quality = score_high_quality - score_low_quality
+
+        score_high_res = calculate_total_score(0.5, 1.0, 0.5, 0.5)
+        score_low_res = calculate_total_score(0.5, 0.0, 0.5, 0.5)
+        diff_res = score_high_res - score_low_res
+
+        assert diff_quality > diff_res
+
+    def test_rounded_to_4_decimals(self):
+        result = calculate_total_score(0.3333, 0.3333, 0.3333, 0.3333)
+        assert result == round(result, 4)
+
+
+# ── 单个素材评分详情 ────────────────────────────────────────────────────────
+
+
+class TestScoreAssetDetail:
+    def test_normal_asset(self):
+        detail = score_asset_detail(
+            asset_id="asset_001",
+            quality=80.0,
+            width=1920,
+            height=1080,
+            duration=10.0,
+            file_size=5_000_000,
+        )
+        assert detail.asset_id == "asset_001"
+        assert 0.0 <= detail.total_score <= 1.0
+        assert detail.quality_score == pytest.approx(0.8)
+        assert detail.resolution_score == 1.0
+        assert detail.duration_score == 1.0
+        assert detail.duration == 10.0
+
+    def test_unknown_quality_defaults(self):
+        detail = score_asset_detail(
+            asset_id="a1",
+            quality=None,
+            width=1920,
+            height=1080,
+            duration=10.0,
+            file_size=5_000_000,
+        )
+        assert detail.quality_score == 0.5
+
+    def test_quality_hundred_is_one(self):
+        detail = score_asset_detail(
+            asset_id="a1",
+            quality=100.0,
+            width=1920,
+            height=1080,
+            duration=10.0,
+            file_size=1_000_000,
+        )
+        assert detail.quality_score == 1.0
+
+    def test_quality_zero_is_zero(self):
+        detail = score_asset_detail(
+            asset_id="a1",
+            quality=0.0,
+            width=1920,
+            height=1080,
+            duration=10.0,
+            file_size=1_000_000,
+        )
+        assert detail.quality_score == 0.0
+
+    def test_custom_target_resolution(self):
+        detail = score_asset_detail(
+            asset_id="a1",
+            quality=50.0,
+            width=1280,
+            height=720,
+            duration=10.0,
+            file_size=1_000_000,
+            target_width=1280,
+            target_height=720,
+        )
+        assert detail.resolution_score == 1.0
+
+
+# ── 时长分桶 ────────────────────────────────────────────────────────────────
+
+
+def _make_detail(asset_id: str, duration: float | None, score: float = 0.8) -> AssetScoreDetail:
+    return AssetScoreDetail(
+        asset_id=asset_id,
+        total_score=score,
+        quality_score=score,
+        resolution_score=score,
+        duration_score=score,
+        bitrate_score=score,
+        duration=duration,
+    )
+
+
+class TestBucketByDuration:
+    def test_short_bucket(self):
+        item = _make_detail("s1", duration=3.0)
+        assert _bucket_by_duration(item) == "short"
+
+    def test_short_boundary(self):
+        item = _make_detail("s1", duration=4.9)
+        assert _bucket_by_duration(item) == "short"
+
+    def test_medium_bucket(self):
+        item = _make_detail("m1", duration=10.0)
+        assert _bucket_by_duration(item) == "medium"
+
+    def test_medium_boundary(self):
+        item = _make_detail("m1", duration=14.9)
+        assert _bucket_by_duration(item) == "medium"
+
+    def test_long_bucket(self):
+        item = _make_detail("l1", duration=20.0)
+        assert _bucket_by_duration(item) == "long"
+
+    def test_long_at_boundary(self):
+        """>=15s 为长素材."""
+        item = _make_detail("l1", duration=15.0)
+        assert _bucket_by_duration(item) == "long"
+
+    def test_unknown_bucket(self):
+        item = _make_detail("u1", duration=None)
+        assert _bucket_by_duration(item) == "unknown"
+
+
+# ── 多样性选择 ──────────────────────────────────────────────────────────────
+
+
+class TestDiverseSelection:
+    def _make_scored_list(self) -> list[AssetScoreDetail]:
+        """构造一个包含各时长桶的测试列表，按分数降序."""
+        items = [
+            _make_detail("high_short", duration=3.0, score=0.95),
+            _make_detail("high_medium", duration=8.0, score=0.9),
+            _make_detail("high_long", duration=30.0, score=0.85),
+            _make_detail("mid_short", duration=2.0, score=0.8),
+            _make_detail("mid_medium", duration=10.0, score=0.75),
+            _make_detail("mid_long", duration=20.0, score=0.7),
+            _make_detail("low_short", duration=4.0, score=0.6),
+            _make_detail("low_medium", duration=12.0, score=0.5),
+            _make_detail("low_long", duration=60.0, score=0.4),
+        ]
+        items.sort(key=lambda x: x.total_score, reverse=True)
+        return items
+
+    def test_empty_list_returns_empty(self):
+        assert diverse_selection([], 5) == []
+
+    def test_zero_count_returns_empty(self):
+        items = self._make_scored_list()
+        assert diverse_selection(items, 0) == []
+
+    def test_negative_count_returns_empty(self):
+        items = self._make_scored_list()
+        assert diverse_selection(items, -1) == []
+
+    def test_selects_from_multiple_buckets(self):
+        items = self._make_scored_list()
+        result = diverse_selection(items, 6)
+        assert len(result) == 6
+        # 应该包含来自不同桶的素材
+        durations = [r.duration for r in result]
+        has_short = any(d and d < 5.0 for d in durations)
+        has_medium = any(d and 5.0 <= d < 15.0 for d in durations)
+        has_long = any(d and d >= 15.0 for d in durations)
+        assert has_short and has_medium and has_long
+
+    def test_no_duplicate_ids(self):
+        items = self._make_scored_list()
+        result = diverse_selection(items, 9)
+        ids = [r.asset_id for r in result]
+        assert len(ids) == len(set(ids))
+
+    def test_not_more_than_count(self):
+        items = self._make_scored_list()
+        result = diverse_selection(items, 3)
+        assert len(result) <= 3
+
+    def test_fewer_assets_than_count(self):
+        items = [_make_detail("a1", duration=3.0, score=0.9)]
+        result = diverse_selection(items, 10)
+        assert len(result) == 1
+
+    def test_only_short_bucket(self):
+        items = [
+            _make_detail("s1", duration=1.0, score=0.9),
+            _make_detail("s2", duration=2.0, score=0.8),
+            _make_detail("s3", duration=3.0, score=0.7),
+        ]
+        result = diverse_selection(items, 3)
+        assert len(result) == 3
+        # 只有短素材，应该都返回
+        assert all(r.duration and r.duration < 5.0 for r in result)
+
+    def test_highest_scores_priority(self):
+        """分数最高的素材应该优先被选中."""
+        items = self._make_scored_list()
+        result = diverse_selection(items, 3)
+        # 最高分的那个应该在结果里
+        assert result[0].asset_id == "high_short"
+
+    def test_contains_top_scoring_items(self):
+        """结果中应该包含全局最高分的素材."""
+        items = self._make_scored_list()
+        result = diverse_selection(items, 6)
+        result_ids = {r.asset_id for r in result}
+        # 全局最高分的应该在结果中
+        assert "high_short" in result_ids
+        assert "high_medium" in result_ids
+
+
+# ── 候选过滤 ────────────────────────────────────────────────────────────────
+
+
+@dataclass
+class MockAsset:
+    asset_id: str
+    status: str = "ready"
+    mime_type: str = "video/mp4"
+    quality_score: float | None = None
+
+
+class TestFilterCandidates:
+    def test_ready_video_passes(self):
+        assets = [MockAsset("a1", status="ready", mime_type="video/mp4")]
+        candidates, filtered = filter_candidates(assets)
+        assert len(candidates) == 1
+        assert filtered == 0
+
+    def test_not_ready_filtered(self):
+        assets = [
+            MockAsset("a1", status="processing"),
+            MockAsset("a2", status="failed"),
+            MockAsset("a3", status="ready"),
+        ]
+        candidates, filtered = filter_candidates(assets)
+        assert len(candidates) == 1
+        assert candidates[0].asset_id == "a3"
+        assert filtered == 0  # 状态不对的不算质量过滤
+
+    def test_non_video_filtered(self):
+        assets = [
+            MockAsset("a1", mime_type="image/jpeg"),
+            MockAsset("a2", mime_type="audio/mp3"),
+            MockAsset("a3", mime_type="video/mp4"),
+        ]
+        candidates, filtered = filter_candidates(assets)
+        assert len(candidates) == 1
+        assert filtered == 0
+
+    def test_video_mime_prefix(self):
+        """所有以 video 开头的 MIME 都通过."""
+        assets = [
+            MockAsset("a1", mime_type="video/mp4"),
+            MockAsset("a2", mime_type="video/webm"),
+            MockAsset("a3", mime_type="video/x-matroska"),
+        ]
+        candidates, _ = filter_candidates(assets)
+        assert len(candidates) == 3
+
+    def test_low_quality_filtered_counted(self):
+        """质量分低于门槛的计入 filtered_out."""
+        assets = [
+            MockAsset("good", quality_score=80.0),
+            MockAsset("bad", quality_score=20.0),
+        ]
+        candidates, filtered = filter_candidates(assets, min_quality_score=30.0)
+        assert len(candidates) == 1
+        assert candidates[0].asset_id == "good"
+        assert filtered == 1
+
+    def test_none_quality_passes(self):
+        """quality_score 为 None 的不做质量检查，通过."""
+        assets = [MockAsset("a1", quality_score=None)]
+        candidates, filtered = filter_candidates(assets, min_quality_score=30.0)
+        assert len(candidates) == 1
+        assert filtered == 0
+
+    def test_quality_at_threshold_passes(self):
+        """刚好等于门槛值的通过."""
+        assets = [MockAsset("a1", quality_score=30.0)]
+        candidates, filtered = filter_candidates(assets, min_quality_score=30.0)
+        assert len(candidates) == 1
+        assert filtered == 0
+
+    def test_empty_list(self):
+        candidates, filtered = filter_candidates([])
+        assert candidates == []
+        assert filtered == 0
+
+    def test_none_mime_type_treated_as_empty(self):
+        assets = [MockAsset("a1", mime_type=None)]  # type: ignore
+        candidates, _ = filter_candidates(assets)
+        assert len(candidates) == 0
+
+
+# ── 数据类 ──────────────────────────────────────────────────────────────────
+
+
+class TestDataClasses:
+    def test_score_detail_defaults(self):
+        detail = AssetScoreDetail(
+            asset_id="test",
+            total_score=0.5,
+            quality_score=0.5,
+            resolution_score=0.5,
+            duration_score=0.5,
+            bitrate_score=0.5,
+            duration=None,
+        )
+        assert detail.asset_id == "test"
+        assert detail.total_score == 0.5
+        assert detail.duration is None
+
+    def test_smart_select_result_defaults(self):
+        result = SmartSelectResult(
+            selected_ids=["a1", "a2"],
+            total_candidates=10,
+            filtered_out=3,
+            avg_score=0.75,
+        )
+        assert len(result.selected_ids) == 2
+        assert result.total_candidates == 10
+        assert result.filtered_out == 3
+        assert result.details == []  # 默认空列表

tests/unit/test_speed_config.py

@@ -1,313 +0,0 @@
-"""speed_config 领域模型单测."""
-
-from __future__ import annotations
-
-import pytest
-
-from packages.domain.speed_config import (
-    DEFAULT_SPEED,
-    MAX_SPEED,
-    MIN_SPEED,
-    SpeedConfig,
-    adjust_duration,
-    build_audio_filter,
-    build_video_filter,
-    build_clip_speed_filter,
-    resolve_clip_speed,
-)
-
-# ── 常量测试 ────────────────────────────────────────────────────────────────
-
-
-class TestConstants:
-    def test_min_speed(self):
-        assert MIN_SPEED == 0.25
-
-    def test_max_speed(self):
-        assert MAX_SPEED == 4.0
-
-    def test_default_speed(self):
-        assert DEFAULT_SPEED == 1.0
-
-
-# ── SpeedConfig.parse 测试 ────────────────────────────────────────────────
-
-
-class TestSpeedConfigParse:
-    def test_none_returns_default(self):
-        cfg = SpeedConfig.parse(None)
-        assert cfg.speed == DEFAULT_SPEED
-        assert cfg.pitch_correct is True
-
-    def test_empty_dict_returns_default(self):
-        cfg = SpeedConfig.parse({})
-        assert cfg.speed == DEFAULT_SPEED
-
-    def test_invalid_type_returns_default(self):
-        cfg = SpeedConfig.parse("not_a_dict")
-        assert cfg.speed == DEFAULT_SPEED
-
-    def test_valid_speed(self):
-        cfg = SpeedConfig.parse({"speed": 2.0})
-        assert cfg.speed == 2.0
-
-    def test_speed_clamped_low(self):
-        cfg = SpeedConfig.parse({"speed": 0.1})
-        assert cfg.speed == MIN_SPEED
-
-    def test_speed_clamped_high(self):
-        cfg = SpeedConfig.parse({"speed": 5.0})
-        assert cfg.speed == MAX_SPEED
-
-    def test_zero_speed_returns_default(self):
-        cfg = SpeedConfig.parse({"speed": 0})
-        assert cfg.speed == DEFAULT_SPEED
-
-    def test_negative_speed_returns_default(self):
-        cfg = SpeedConfig.parse({"speed": -1.0})
-        assert cfg.speed == DEFAULT_SPEED
-
-    def test_pitch_correct_false(self):
-        cfg = SpeedConfig.parse({"pitch_correct": False})
-        assert cfg.pitch_correct is False
-
-    def test_pitch_correct_invalid_type_defaults_true(self):
-        cfg = SpeedConfig.parse({"pitch_correct": "yes"})
-        assert cfg.pitch_correct is True
-
-    def test_string_speed_invalid_uses_default(self):
-        cfg = SpeedConfig.parse({"speed": "fast"})
-        assert cfg.speed == DEFAULT_SPEED
-
-
-# ── SpeedConfig.clamp 测试 ────────────────────────────────────────────────
-
-
-class TestClamp:
-    def test_already_valid_unchanged(self):
-        cfg = SpeedConfig(speed=1.5)
-        cfg.clamp()
-        assert cfg.speed == 1.5
-
-    def test_below_min_clamped(self):
-        cfg = SpeedConfig(speed=0.1)
-        cfg.clamp()
-        assert cfg.speed == MIN_SPEED
-
-    def test_above_max_clamped(self):
-        cfg = SpeedConfig(speed=10.0)
-        cfg.clamp()
-        assert cfg.speed == MAX_SPEED
-
-    def test_zero_defaults(self):
-        cfg = SpeedConfig(speed=0.0)
-        cfg.clamp()
-        assert cfg.speed == DEFAULT_SPEED
-
-    def test_negative_defaults(self):
-        cfg = SpeedConfig(speed=-2.0)
-        cfg.clamp()
-        assert cfg.speed == DEFAULT_SPEED
-
-    def test_exact_min_stays(self):
-        cfg = SpeedConfig(speed=MIN_SPEED)
-        cfg.clamp()
-        assert cfg.speed == MIN_SPEED
-
-    def test_exact_max_stays(self):
-        cfg = SpeedConfig(speed=MAX_SPEED)
-        cfg.clamp()
-        assert cfg.speed == MAX_SPEED
-
-
-# ── is_original / is_fast / is_slow 测试 ─────────────────────────────────
-
-
-class TestSpeedProperties:
-    def test_is_original_true(self):
-        cfg = SpeedConfig(speed=1.0)
-        assert cfg.is_original is True
-
-    def test_is_original_false_fast(self):
-        cfg = SpeedConfig(speed=2.0)
-        assert cfg.is_original is False
-
-    def test_is_original_false_slow(self):
-        cfg = SpeedConfig(speed=0.5)
-        assert cfg.is_original is False
-
-    def test_is_original_near_one(self):
-        cfg = SpeedConfig(speed=1.0000001)
-        assert cfg.is_original is True
-
-    def test_is_fast_true(self):
-        cfg = SpeedConfig(speed=2.0)
-        assert cfg.is_fast is True
-
-    def test_is_fast_false(self):
-        cfg = SpeedConfig(speed=0.5)
-        assert cfg.is_fast is False
-
-    def test_is_false_for_original(self):
-        cfg = SpeedConfig(speed=1.0)
-        assert cfg.is_fast is False
-        assert cfg.is_slow is False
-
-    def test_is_slow_true(self):
-        cfg = SpeedConfig(speed=0.5)
-        assert cfg.is_slow is True
-
-    def test_is_slow_false(self):
-        cfg = SpeedConfig(speed=2.0)
-        assert cfg.is_slow is False
-
-
-# ── build_video_filter 测试 ───────────────────────────────────────────────
-
-
-class TestBuildVideoFilter:
-    def test_original_speed_empty(self):
-        cfg = SpeedConfig(speed=1.0)
-        assert build_video_filter(cfg) == ""
-
-    def test_fast_speed_setpts(self):
-        cfg = SpeedConfig(speed=2.0)
-        result = build_video_filter(cfg)
-        assert "setpts=PTS/2.0000" in result
-
-    def test_slow_speed_setpts(self):
-        cfg = SpeedConfig(speed=0.5)
-        result = build_video_filter(cfg)
-        assert "setpts=PTS/0.5000" in result
-
-    def test_format_four_decimals(self):
-        cfg = SpeedConfig(speed=1.5)
-        result = build_video_filter(cfg)
-        assert "1.5000" in result
-
-
-# ── build_audio_filter 测试 ───────────────────────────────────────────────
-
-
-class TestBuildAudioFilter:
-    def test_original_speed_empty(self):
-        cfg = SpeedConfig(speed=1.0)
-        assert build_audio_filter(cfg) == ""
-
-    def test_single_stage_within_range(self):
-        cfg = SpeedConfig(speed=1.5)
-        result = build_audio_filter(cfg)
-        assert result == "atempo=1.5000"
-        assert result.count("atempo") == 1
-
-    def test_fast_two_stages(self):
-        cfg = SpeedConfig(speed=3.0)
-        result = build_audio_filter(cfg)
-        assert result.count("atempo") == 2
-        # 2.0 * 1.5 = 3.0
-        assert "atempo=2.0000" in result
-        assert "atempo=1.5000" in result
-
-    def test_max_speed_two_stages(self):
-        cfg = SpeedConfig(speed=4.0)
-        result = build_audio_filter(cfg)
-        assert result.count("atempo") == 2
-        # 2.0 * 2.0 = 4.0
-        assert result == "atempo=2.0000,atempo=2.0000"
-
-    def test_slow_two_stages(self):
-        cfg = SpeedConfig(speed=0.25)
-        result = build_audio_filter(cfg)
-        assert result.count("atempo") == 2
-        # 0.5 * 0.5 = 0.25
-        assert result == "atempo=0.5000,atempo=0.5000"
-
-    def test_slow_single_stage(self):
-        cfg = SpeedConfig(speed=0.8)
-        result = build_audio_filter(cfg)
-        assert result == "atempo=0.8000"
-        assert result.count("atempo") == 1
-
-    def test_exactly_two_point_zero_single(self):
-        cfg = SpeedConfig(speed=2.0)
-        result = build_audio_filter(cfg)
-        assert result.count("atempo") == 1
-        assert "atempo=2.0000" in result
-
-    def test_exactly_half_single(self):
-        cfg = SpeedConfig(speed=0.5)
-        result = build_audio_filter(cfg)
-        assert result.count("atempo") == 1
-        assert "atempo=0.5000" in result
-
-
-# ── adjust_duration 测试 ──────────────────────────────────────────────────
-
-
-class TestAdjustDuration:
-    def test_original_speed_unchanged(self):
-        cfg = SpeedConfig(speed=1.0)
-        assert adjust_duration(10.0, cfg) == 10.0
-
-    def test_double_speed_halved(self):
-        cfg = SpeedConfig(speed=2.0)
-        assert adjust_duration(10.0, cfg) == 5.0
-
-    def test_half_speed_doubled(self):
-        cfg = SpeedConfig(speed=0.5)
-        assert adjust_duration(10.0, cfg) == 20.0
-
-    def test_zero_duration_unchanged(self):
-        cfg = SpeedConfig(speed=2.0)
-        assert adjust_duration(0.0, cfg) == 0.0
-
-    def test_negative_duration_unchanged(self):
-        cfg = SpeedConfig(speed=2.0)
-        assert adjust_duration(-5.0, cfg) == -5.0
-
-
-# ── build_clip_speed_filter 测试 ─────────────────────────────────────────
-
-
-class TestBuildClipSpeedFilter:
-    def test_normal_speed(self):
-        vf, af, cfg = build_clip_speed_filter(2.0)
-        assert vf == "setpts=PTS/2.0000"
-        assert "atempo=2.0000" in af
-        assert cfg.speed == 2.0
-
-    def test_clamped_speed(self):
-        vf, af, cfg = build_clip_speed_filter(10.0)
-        assert cfg.speed == MAX_SPEED
-
-    def test_pitch_correct_param(self):
-        vf, af, cfg = build_clip_speed_filter(1.5, pitch_correct=False)
-        assert cfg.pitch_correct is False
-
-    def test_original_speed_empty_filters(self):
-        vf, af, cfg = build_clip_speed_filter(1.0)
-        assert vf == ""
-        assert af == ""
-
-
-# ── resolve_clip_speed 测试 ──────────────────────────────────────────────
-
-
-class TestResolveClipSpeed:
-    def test_none_config_uses_global(self):
-        assert resolve_clip_speed(None, 1.5) == 1.5
-
-    def test_no_playback_speed_uses_global(self):
-        assert resolve_clip_speed({}, 1.5) == 1.5
-
-    def test_zero_speed_uses_global(self):
-        assert resolve_clip_speed({"playback_speed": 0}, 1.5) == 1.5
-
-    def test_valid_speed_returns_speed(self):
-        assert resolve_clip_speed({"playback_speed": 2.0}, 1.0) == 2.0
-
-    def test_invalid_type_uses_global(self):
-        assert resolve_clip_speed({"playback_speed": "fast"}, 1.0) == 1.0
-
-    def test_default_global_speed(self):
-        assert resolve_clip_speed({}) == DEFAULT_SPEED