test: add comprehensive test suite for core business logic

Cover RSS engine, downloader, renamer, auth, notifications, search,
config, API endpoints, and end-to-end integration flows. When all
210 tests pass, the program's key behavioral contracts are verified.

Generated with [Claude Code](https://claude.ai/code)
via [Happy](https://happy.engineering)

Co-Authored-By: Claude <noreply@anthropic.com>
Co-Authored-By: Happy <yesreply@happy.engineering>

Author: 3 people

CHANGELOG.md

@@ -14,6 +14,23 @@
 - 数据库迁移机制重构：使用 `schema_version` 表替代仅依赖应用版本号的迁移策略
 - 启动时始终检查并执行未完成的迁移，防止迁移中断后无法恢复
 
+### Tests
+
+- 新增全面的测试套件，覆盖核心业务逻辑：
+  - RSS 引擎测试：pull_rss、match_torrent、refresh_rss、add_rss 全流程
+  - 下载客户端测试：init_downloader、set_rule、add_torrent（磁力/文件）、rename
+  - 路径工具测试：save_path 生成、文件分类、is_ep 深度检查
+  - 重命名器测试：gen_path 命名方法（pn/advance/none/subtitle）、单文件/集合重命名
+  - 认证测试：JWT 创建/解码/验证、密码哈希、get_current_user
+  - 通知测试：getClient 工厂、send_msg 成功/失败、poster 查询
+  - 搜索测试：URL 构建、关键词清洗、special_url
+  - 配置测试：默认值、序列化、迁移、环境变量覆盖
+  - Bangumi API 测试：CRUD 端点 + 认证要求
+  - RSS API 测试：CRUD/批量端点 + 刷新
+  - 集成测试：RSS→下载全流程、重命名全流程、数据库一致性
+- 新增 `pytest-mock` 开发依赖
+- 新增共享测试 fixtures（`conftest.py`）和数据工厂（`factories.py`）
+
 ---
 
 # [3.1] - 2023-08

backend/pyproject.toml

@@ -30,6 +30,7 @@ dependencies = [
 dev = [
     "pytest>=8.0.0",
     "pytest-asyncio>=0.23.0",
+    "pytest-mock>=3.12.0",
     "ruff>=0.1.0",
     "black>=24.0.0",
     "pre-commit>=3.0.0",

backend/src/test/conftest.py

@@ -0,0 +1,82 @@
+"""Shared test fixtures for AutoBangumi test suite."""
+
+import pytest
+from unittest.mock import AsyncMock, patch
+
+from sqlmodel import Session, SQLModel, create_engine
+
+from module.models.config import Config
+
+
+# ---------------------------------------------------------------------------
+# Database Fixtures
+# ---------------------------------------------------------------------------
+
+
+@pytest.fixture
+def db_engine():
+    """Create an in-memory SQLite engine for testing."""
+    engine = create_engine("sqlite://", echo=False)
+    SQLModel.metadata.create_all(engine)
+    yield engine
+    SQLModel.metadata.drop_all(engine)
+
+
+@pytest.fixture
+def db_session(db_engine):
+    """Provide a fresh database session per test."""
+    with Session(db_engine) as session:
+        yield session
+
+
+# ---------------------------------------------------------------------------
+# Settings Fixtures
+# ---------------------------------------------------------------------------
+
+
+@pytest.fixture
+def test_settings():
+    """Provide a Config object with predictable test defaults."""
+    return Config()
+
+
+@pytest.fixture
+def mock_settings(test_settings):
+    """Patch module.conf.settings globally with test defaults."""
+    with patch("module.conf.settings", test_settings):
+        with patch("module.conf.config.settings", test_settings):
+            yield test_settings
+
+
+# ---------------------------------------------------------------------------
+# Download Client Mock
+# ---------------------------------------------------------------------------
+
+
+@pytest.fixture
+def mock_qb_client():
+    """Mock QbDownloader that simulates qBittorrent API responses."""
+    client = AsyncMock()
+    client.auth.return_value = True
+    client.logout.return_value = None
+    client.check_host.return_value = True
+    client.torrents_info.return_value = []
+    client.torrents_files.return_value = []
+    client.torrents_rename_file.return_value = True
+    client.add_torrents.return_value = True
+    client.torrents_delete.return_value = None
+    client.torrents_pause.return_value = None
+    client.torrents_resume.return_value = None
+    client.rss_set_rule.return_value = None
+    client.prefs_init.return_value = None
+    client.add_category.return_value = None
+    client.get_app_prefs.return_value = {"save_path": "/downloads"}
+    client.move_torrent.return_value = None
+    client.rss_add_feed.return_value = None
+    client.rss_remove_item.return_value = None
+    client.rss_get_feeds.return_value = {}
+    client.get_download_rule.return_value = {}
+    client.get_torrent_path.return_value = "/downloads/Bangumi"
+    client.set_category.return_value = None
+    client.remove_rule.return_value = None
+    return client

backend/src/test/factories.py

@@ -0,0 +1,54 @@
+"""Test data factories for creating model instances with sensible defaults."""
+
+from module.models import Bangumi, RSSItem, Torrent
+
+
+def make_bangumi(**overrides) -> Bangumi:
+    """Create a Bangumi instance with sensible test defaults."""
+    defaults = dict(
+        official_title="Test Anime",
+        year="2024",
+        title_raw="Test Anime Raw",
+        season=1,
+        season_raw="",
+        group_name="TestGroup",
+        dpi="1080p",
+        source="Web",
+        subtitle="CHT",
+        eps_collect=False,
+        offset=0,
+        filter="720",
+        rss_link="https://mikanani.me/RSS/test",
+        poster_link="/test/poster.jpg",
+        added=True,
+        rule_name="[TestGroup] Test Anime S1",
+        save_path="/downloads/Bangumi/Test Anime (2024)/Season 1",
+        deleted=False,
+    )
+    defaults.update(overrides)
+    return Bangumi(**defaults)
+
+
+def make_torrent(**overrides) -> Torrent:
+    """Create a Torrent instance with sensible test defaults."""
+    defaults = dict(
+        name="[TestGroup] Test Anime Raw - 01 [1080p].mkv",
+        url="https://example.com/test.torrent",
+        homepage="https://mikanani.me/Home/Episode/test",
+        downloaded=False,
+    )
+    defaults.update(overrides)
+    return Torrent(**defaults)
+
+
+def make_rss_item(**overrides) -> RSSItem:
+    """Create an RSSItem instance with sensible test defaults."""
+    defaults = dict(
+        name="Test RSS Feed",
+        url="https://mikanani.me/RSS/MyBangumi?token=test",
+        aggregate=True,
+        parser="mikan",
+        enabled=True,
+    )
+    defaults.update(overrides)
+    return RSSItem(**defaults)

backend/src/test/test_api_bangumi.py

@@ -0,0 +1,220 @@
+"""Tests for Bangumi API endpoints."""
+
+import pytest
+from unittest.mock import patch, MagicMock, AsyncMock
+from datetime import timedelta
+
+from fastapi import FastAPI
+from fastapi.testclient import TestClient
+
+from module.api import v1
+from module.models import Bangumi, BangumiUpdate, ResponseModel
+from module.security.api import get_current_user, active_user
+from module.security.jwt import create_access_token
+
+from test.factories import make_bangumi
+
+
+# ---------------------------------------------------------------------------
+# Fixtures
+# ---------------------------------------------------------------------------
+
+
+@pytest.fixture
+def app():
+    """Create a FastAPI app with v1 routes for testing."""
+    app = FastAPI()
+    app.include_router(v1, prefix="/api")
+    return app
+
+
+@pytest.fixture
+def authed_client(app):
+    """TestClient with auth dependency overridden."""
+    async def mock_user():
+        return "testuser"
+
+    app.dependency_overrides[get_current_user] = mock_user
+    client = TestClient(app)
+    yield client
+    app.dependency_overrides.clear()
+
+
+@pytest.fixture
+def unauthed_client(app):
+    """TestClient without auth (no override)."""
+    return TestClient(app)
+
+
+# ---------------------------------------------------------------------------
+# Auth requirement
+# ---------------------------------------------------------------------------
+
+
+class TestAuthRequired:
+    def test_get_all_unauthorized(self, unauthed_client):
+        """GET /bangumi/get/all without auth returns 401."""
+        response = unauthed_client.get("/api/v1/bangumi/get/all")
+        assert response.status_code == 401
+
+    def test_get_by_id_unauthorized(self, unauthed_client):
+        """GET /bangumi/get/1 without auth returns 401."""
+        response = unauthed_client.get("/api/v1/bangumi/get/1")
+        assert response.status_code == 401
+
+    def test_delete_unauthorized(self, unauthed_client):
+        """DELETE /bangumi/delete/1 without auth returns 401."""
+        response = unauthed_client.delete("/api/v1/bangumi/delete/1")
+        assert response.status_code == 401
+
+
+# ---------------------------------------------------------------------------
+# GET endpoints
+# ---------------------------------------------------------------------------
+
+
+class TestGetBangumi:
+    def test_get_all(self, authed_client):
+        """GET /bangumi/get/all returns list of Bangumi."""
+        mock_bangumi = [make_bangumi(id=1), make_bangumi(id=2, title_raw="Other")]
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.bangumi.search_all.return_value = mock_bangumi
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            response = authed_client.get("/api/v1/bangumi/get/all")
+
+        assert response.status_code == 200
+        data = response.json()
+        assert len(data) == 2
+
+    def test_get_by_id(self, authed_client):
+        """GET /bangumi/get/{id} returns single Bangumi."""
+        bangumi = make_bangumi(id=1, official_title="Found Anime")
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.search_one.return_value = bangumi
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            response = authed_client.get("/api/v1/bangumi/get/1")
+
+        assert response.status_code == 200
+
+
+# ---------------------------------------------------------------------------
+# PATCH/UPDATE endpoints
+# ---------------------------------------------------------------------------
+
+
+class TestUpdateBangumi:
+    def test_update_success(self, authed_client):
+        """PATCH /bangumi/update/{id} updates and returns success."""
+        resp_model = ResponseModel(
+            status=True, status_code=200, msg_en="Updated.", msg_zh="已更新。"
+        )
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.update_rule = AsyncMock(return_value=resp_model)
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            # BangumiUpdate requires all fields
+            update_data = {
+                "official_title": "New Title",
+                "title_raw": "new_raw",
+                "season": 1,
+                "year": "2024",
+                "season_raw": "",
+                "group_name": "Group",
+                "dpi": "1080p",
+                "source": "Web",
+                "subtitle": "CHT",
+                "eps_collect": False,
+                "offset": 0,
+                "filter": "720",
+                "rss_link": "https://test.com/rss",
+                "poster_link": None,
+                "added": True,
+                "rule_name": None,
+                "save_path": None,
+                "deleted": False,
+            }
+            response = authed_client.patch(
+                "/api/v1/bangumi/update/1",
+                json=update_data,
+            )
+
+        assert response.status_code == 200
+
+
+# ---------------------------------------------------------------------------
+# DELETE endpoints
+# ---------------------------------------------------------------------------
+
+
+class TestDeleteBangumi:
+    def test_delete_success(self, authed_client):
+        """DELETE /bangumi/delete/{id} removes bangumi."""
+        resp_model = ResponseModel(
+            status=True, status_code=200, msg_en="Deleted.", msg_zh="已删除。"
+        )
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.delete_rule = AsyncMock(return_value=resp_model)
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            response = authed_client.delete("/api/v1/bangumi/delete/1")
+
+        assert response.status_code == 200
+
+    def test_disable_rule(self, authed_client):
+        """DELETE /bangumi/disable/{id} marks as deleted."""
+        resp_model = ResponseModel(
+            status=True, status_code=200, msg_en="Disabled.", msg_zh="已禁用。"
+        )
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.disable_rule = AsyncMock(return_value=resp_model)
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            response = authed_client.delete("/api/v1/bangumi/disable/1")
+
+        assert response.status_code == 200
+
+    def test_enable_rule(self, authed_client):
+        """GET /bangumi/enable/{id} re-enables rule."""
+        resp_model = ResponseModel(
+            status=True, status_code=200, msg_en="Enabled.", msg_zh="已启用。"
+        )
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.enable_rule.return_value = resp_model
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            response = authed_client.get("/api/v1/bangumi/enable/1")
+
+        assert response.status_code == 200
+
+
+# ---------------------------------------------------------------------------
+# Reset
+# ---------------------------------------------------------------------------
+
+
+class TestResetBangumi:
+    def test_reset_all(self, authed_client):
+        """GET /bangumi/reset/all deletes all bangumi."""
+        with patch("module.api.bangumi.TorrentManager") as MockManager:
+            mock_mgr = MagicMock()
+            mock_mgr.bangumi.delete_all.return_value = None
+            MockManager.return_value.__enter__ = MagicMock(return_value=mock_mgr)
+            MockManager.return_value.__exit__ = MagicMock(return_value=False)
+
+            response = authed_client.get("/api/v1/bangumi/reset/all")
+
+        assert response.status_code == 200