test(wave125): entities领域实体单测 +76

覆盖Asset/Project/AssetLibrary/IngestJob/AssetStatus兼容

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_entities.py

@@ -0,0 +1,510 @@
+"""entities 领域实体单测 — Asset/Project/AssetLibrary/IngestJob/AssetStatus."""
+
+from __future__ import annotations
+
+import pytest
+
+from packages.domain.classification import (
+    AssetLibraryKind,
+    ClassificationStatus,
+    IngestJobStatus,
+)
+from packages.domain.entities import (
+    Asset,
+    AssetLibrary,
+    AssetStatus,
+    IngestJob,
+    Project,
+)
+
+
+# ── AssetStatus 枚举兼容 ────────────────────────────────────────────────────
+
+
+class TestAssetStatus:
+    def test_basic_statuses(self):
+        assert AssetStatus.UPLOADING == "uploading"
+        assert AssetStatus.READY == "ready"
+        assert AssetStatus.PROCESSING == "processing"
+        assert AssetStatus.ERROR == "error"
+        assert AssetStatus.DELETED == "deleted"
+
+    def test_missing_uploaded_maps_to_ready(self):
+        # 兼容历史：uploaded → READY
+        assert AssetStatus("uploaded") == AssetStatus.READY
+
+    def test_missing_success_maps_to_ready(self):
+        assert AssetStatus("success") == AssetStatus.READY
+
+    def test_missing_ok_maps_to_ready(self):
+        assert AssetStatus("ok") == AssetStatus.READY
+
+    def test_missing_done_maps_to_ready(self):
+        assert AssetStatus("done") == AssetStatus.READY
+
+    def test_missing_complete_maps_to_ready(self):
+        assert AssetStatus("complete") == AssetStatus.READY
+
+    def test_missing_upload_maps_to_uploading(self):
+        assert AssetStatus("upload") == AssetStatus.UPLOADING
+
+    def test_missing_uploading_start_maps_to_uploading(self):
+        assert AssetStatus("uploading_start") == AssetStatus.UPLOADING
+
+    def test_missing_upload_start_maps_to_uploading(self):
+        assert AssetStatus("upload_start") == AssetStatus.UPLOADING
+
+    def test_missing_failed_maps_to_error(self):
+        assert AssetStatus("failed") == AssetStatus.ERROR
+
+    def test_missing_fail_maps_to_error(self):
+        assert AssetStatus("fail") == AssetStatus.ERROR
+
+    def test_missing_err_maps_to_error(self):
+        assert AssetStatus("err") == AssetStatus.ERROR
+
+    def test_missing_process_maps_to_processing(self):
+        assert AssetStatus("process") == AssetStatus.PROCESSING
+
+    def test_missing_running_maps_to_processing(self):
+        assert AssetStatus("running") == AssetStatus.PROCESSING
+
+    def test_missing_run_maps_to_processing(self):
+        assert AssetStatus("run") == AssetStatus.PROCESSING
+
+    def test_unknown_value_defaults_to_ready(self):
+        # 兜底：未知值 → READY，不阻塞业务
+        assert AssetStatus("some_weird_value") == AssetStatus.READY
+
+    def test_case_insensitive(self):
+        assert AssetStatus("READY") == AssetStatus.READY
+        assert AssetStatus("Ready") == AssetStatus.READY
+
+    def test_whitespace_stripped(self):
+        assert AssetStatus("  ready  ") == AssetStatus.READY
+
+
+# ── Project ────────────────────────────────────────────────────────────────
+
+
+class TestProject:
+    def test_create_basic(self):
+        p = Project.create(owner_user_id="user_1", name="我的项目")
+        assert p.id  # 自动生成
+        assert p.owner_user_id == "user_1"
+        assert p.name == "我的项目"
+        assert p.description == ""
+        assert p.shared_users == []
+
+    def test_create_with_description(self):
+        p = Project.create(owner_user_id="u1", name="P1", description="测试描述")
+        assert p.description == "测试描述"
+
+    def test_create_name_stripped(self):
+        p = Project.create(owner_user_id="u1", name="  我的项目  ")
+        assert p.name == "我的项目"
+
+    def test_create_empty_name_raises(self):
+        with pytest.raises(ValueError, match="项目名称不能为空"):
+            Project.create(owner_user_id="u1", name="")
+
+    def test_create_whitespace_name_raises(self):
+        with pytest.raises(ValueError, match="项目名称不能为空"):
+            Project.create(owner_user_id="u1", name="   ")
+
+    def test_is_owner_true(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        assert p.is_owner("u1") is True
+
+    def test_is_owner_false(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        assert p.is_owner("u2") is False
+
+    def test_is_shared_with_true(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        p.shared_users = ["u2", "u3"]
+        assert p.is_shared_with("u2") is True
+
+    def test_is_shared_with_false(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        assert p.is_shared_with("u2") is False
+
+    def test_can_access_owner(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        assert p.can_access("u1") is True
+
+    def test_can_access_shared_user(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        p.shared_users = ["u2"]
+        assert p.can_access("u2") is True
+
+    def test_can_access_stranger(self):
+        p = Project.create(owner_user_id="u1", name="P1")
+        assert p.can_access("u3") is False
+
+    def test_description_stripped(self):
+        p = Project.create(owner_user_id="u1", name="P1", description="  desc  ")
+        assert p.description == "desc"
+
+
+# ── AssetLibrary ───────────────────────────────────────────────────────────
+
+
+class TestAssetLibrary:
+    def test_create_basic(self):
+        lib = AssetLibrary.create(
+            project_id="proj_1",
+            name="视频素材",
+            kind=AssetLibraryKind.VIDEO,
+        )
+        assert lib.id
+        assert lib.project_id == "proj_1"
+        assert lib.name == "视频素材"
+        assert lib.kind == AssetLibraryKind.VIDEO
+        assert lib.asset_count == 0
+        assert lib.total_size == 0
+
+    def test_create_name_stripped(self):
+        lib = AssetLibrary.create(
+            project_id="p1", name="  我的素材库  ", kind=AssetLibraryKind.VOICE
+        )
+        assert lib.name == "我的素材库"
+
+    def test_create_empty_name_raises(self):
+        with pytest.raises(ValueError, match="素材库名称不能为空"):
+            AssetLibrary.create(project_id="p1", name="", kind=AssetLibraryKind.VIDEO)
+
+    def test_create_whitespace_name_raises(self):
+        with pytest.raises(ValueError, match="素材库名称不能为空"):
+            AssetLibrary.create(project_id="p1", name="  ", kind=AssetLibraryKind.VIDEO)
+
+    def test_create_with_string_kind(self):
+        lib = AssetLibrary.create(project_id="p1", name="L1", kind="video")
+        assert lib.kind == AssetLibraryKind.VIDEO
+
+
+# ── Asset ──────────────────────────────────────────────────────────────────
+
+
+class TestAssetCreate:
+    def test_create_basic(self):
+        asset = Asset.create(
+            project_id="p1",
+            library_id="lib1",
+            name="测试视频.mp4",
+            storage_key="videos/test.mp4",
+            mime_type="video/mp4",
+        )
+        assert asset.id
+        assert asset.project_id == "p1"
+        assert asset.library_id == "lib1"
+        assert asset.name == "测试视频.mp4"
+        assert asset.storage_key == "videos/test.mp4"
+        assert asset.mime_type == "video/mp4"
+        assert asset.status == AssetStatus.UPLOADING
+        assert asset.classification_status == ClassificationStatus.PENDING
+        assert asset.file_size == 0
+        assert asset.tag_ids == []
+        assert asset.metadata == {}
+
+    def test_create_name_stripped(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1",
+            name="  video.mp4  ",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        assert asset.name == "video.mp4"
+
+    def test_create_storage_key_stripped(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="  key1  ", mime_type="video/mp4",
+        )
+        assert asset.storage_key == "key1"
+
+    def test_create_mime_type_stripped(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="  video/mp4  ",
+        )
+        assert asset.mime_type == "video/mp4"
+
+    def test_create_empty_name_raises(self):
+        with pytest.raises(ValueError, match="素材名称不能为空"):
+            Asset.create(
+                project_id="p1", library_id="l1", name="",
+                storage_key="k1", mime_type="video/mp4",
+            )
+
+    def test_create_empty_storage_key_raises(self):
+        with pytest.raises(ValueError, match="storage_key 不能为空"):
+            Asset.create(
+                project_id="p1", library_id="l1", name="v.mp4",
+                storage_key="  ", mime_type="video/mp4",
+            )
+
+    def test_create_empty_mime_type_raises(self):
+        with pytest.raises(ValueError, match="mime_type 不能为空"):
+            Asset.create(
+                project_id="p1", library_id="l1", name="v.mp4",
+                storage_key="k1", mime_type="",
+            )
+
+    def test_create_with_file_size(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4", file_size=1024000,
+        )
+        assert asset.file_size == 1024000
+
+    def test_create_with_duration(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4", duration=30.5,
+        )
+        assert asset.duration == 30.5
+
+    def test_create_with_dimensions(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+            width=1080, height=1920, fps=30.0, codec="h264",
+        )
+        assert asset.width == 1080
+        assert asset.height == 1920
+        assert asset.fps == 30.0
+        assert asset.codec == "h264"
+
+    def test_create_with_metadata(self):
+        meta = {"bitrate": 5000, "codec": "h264"}
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4", metadata=meta,
+        )
+        assert asset.metadata == meta
+
+    def test_create_metadata_none_defaults_empty(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4", metadata=None,
+        )
+        assert asset.metadata == {}
+
+    def test_create_thumbnail_url_none(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4", thumbnail_url=None,
+        )
+        assert asset.thumbnail_url is None
+
+    def test_create_uploaded_by_stripped(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+            uploaded_by_user_id="  user1  ",
+        )
+        assert asset.uploaded_by_user_id == "user1"
+
+    def test_create_file_hash_stripped(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+            file_hash="  abc123  ",
+        )
+        assert asset.file_hash == "abc123"
+
+
+class TestAssetFileType:
+    def test_video_mime(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        assert asset.file_type == "video"
+
+    def test_audio_mime(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="a.mp3",
+            storage_key="k1", mime_type="audio/mpeg",
+        )
+        assert asset.file_type == "audio"
+
+    def test_image_mime(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="i.jpg",
+            storage_key="k1", mime_type="image/jpeg",
+        )
+        assert asset.file_type == "image"
+
+    def test_invalid_mime_returns_full(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="f.xxx",
+            storage_key="k1", mime_type="application/octet-stream",
+        )
+        assert asset.file_type == "application"
+
+
+class TestAssetTags:
+    def test_add_tag(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("tag_1")
+        assert "tag_1" in asset.tag_ids
+        assert len(asset.tag_ids) == 1
+
+    def test_add_tag_dedup(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("tag_1")
+        asset.add_tag("tag_1")
+        assert len(asset.tag_ids) == 1
+
+    def test_add_tag_empty_raises(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        with pytest.raises(ValueError, match="标签 ID 不能为空"):
+            asset.add_tag("")
+
+    def test_add_tag_whitespace_raises(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        with pytest.raises(ValueError, match="标签 ID 不能为空"):
+            asset.add_tag("   ")
+
+    def test_add_tag_strips_whitespace(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("  tag_1  ")
+        assert asset.tag_ids == ["tag_1"]
+
+    def test_remove_tag(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("tag_1")
+        asset.add_tag("tag_2")
+        asset.remove_tag("tag_1")
+        assert asset.tag_ids == ["tag_2"]
+
+    def test_remove_nonexistent_tag_no_error(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("tag_1")
+        asset.remove_tag("nonexistent")  # 幂等，不报错
+        assert asset.tag_ids == ["tag_1"]
+
+    def test_remove_tag_strips_whitespace(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("tag_1")
+        asset.remove_tag("  tag_1  ")
+        assert len(asset.tag_ids) == 0
+
+    def test_add_tag_updates_updated_at(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        old_updated = asset.updated_at
+        import time; time.sleep(0.001)
+        asset.add_tag("tag_1")
+        assert asset.updated_at > old_updated
+
+    def test_remove_tag_updates_updated_at(self):
+        asset = Asset.create(
+            project_id="p1", library_id="l1", name="v.mp4",
+            storage_key="k1", mime_type="video/mp4",
+        )
+        asset.add_tag("tag_1")
+        old_updated = asset.updated_at
+        import time; time.sleep(0.001)
+        asset.remove_tag("tag_1")
+        assert asset.updated_at > old_updated
+
+
+# ── IngestJob ──────────────────────────────────────────────────────────────
+
+
+class TestIngestJob:
+    def test_create_basic(self):
+        job = IngestJob.create(
+            project_id="p1",
+            library_id="lib1",
+            storage_key="videos/test.mp4",
+        )
+        assert job.id
+        assert job.project_id == "p1"
+        assert job.library_id == "lib1"
+        assert job.storage_key == "videos/test.mp4"
+        assert job.status == IngestJobStatus.PENDING
+        assert job.error_message == ""
+        assert job.result_asset_id == ""
+        assert job.file_hash == ""
+
+    def test_create_with_file_hash(self):
+        job = IngestJob.create(
+            project_id="p1", library_id="l1",
+            storage_key="k1", file_hash="abc123",
+        )
+        assert job.file_hash == "abc123"
+
+    def test_create_project_id_stripped(self):
+        job = IngestJob.create(
+            project_id="  p1  ", library_id="l1", storage_key="k1",
+        )
+        assert job.project_id == "p1"
+
+    def test_create_library_id_stripped(self):
+        job = IngestJob.create(
+            project_id="p1", library_id="  l1  ", storage_key="k1",
+        )
+        assert job.library_id == "l1"
+
+    def test_create_storage_key_stripped(self):
+        job = IngestJob.create(
+            project_id="p1", library_id="l1", storage_key="  k1  ",
+        )
+        assert job.storage_key == "k1"
+
+    def test_create_empty_project_id_raises(self):
+        with pytest.raises(ValueError, match="project_id 不能为空"):
+            IngestJob.create(project_id="", library_id="l1", storage_key="k1")
+
+    def test_create_empty_library_id_raises(self):
+        with pytest.raises(ValueError, match="library_id 不能为空"):
+            IngestJob.create(project_id="p1", library_id="", storage_key="k1")
+
+    def test_create_empty_storage_key_raises(self):
+        with pytest.raises(ValueError, match="storage_key 不能为空"):
+            IngestJob.create(project_id="p1", library_id="l1", storage_key="")
+
+    def test_create_whitespace_project_id_raises(self):
+        with pytest.raises(ValueError, match="project_id 不能为空"):
+            IngestJob.create(project_id="   ", library_id="l1", storage_key="k1")
+
+    def test_create_file_hash_stripped(self):
+        job = IngestJob.create(
+            project_id="p1", library_id="l1",
+            storage_key="k1", file_hash="  hash123  ",
+        )
+        assert job.file_hash == "hash123"
+
+    def test_created_at_auto_set(self):
+        job = IngestJob.create(project_id="p1", library_id="l1", storage_key="k1")
+        assert job.created_at is not None
+        assert job.updated_at is not None

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