fix: clear deleted knowledge bases from sessions

Author: he-yufeng

astrbot/dashboard/routes/knowledge_base.py

@@ -9,7 +9,7 @@
 import aiofiles
 from quart import request
 
-from astrbot.core import logger
+from astrbot.core import logger, sp
 from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
 from astrbot.core.provider.provider import EmbeddingProvider, RerankProvider
 from astrbot.core.utils.astrbot_path import get_astrbot_temp_path
@@ -69,6 +69,29 @@ def __init__(
     def _get_kb_manager(self):
         return self.core_lifecycle.kb_manager
 
+    @staticmethod
+    async def _remove_kb_from_session_configs(kb_id: str) -> int:
+        prefs = await sp.session_get(None, "kb_config")
+        updated = 0
+
+        for pref in prefs:
+            value = pref.value.get("val") if isinstance(pref.value, dict) else None
+            if not isinstance(value, dict):
+                continue
+
+            kb_ids = value.get("kb_ids")
+            if not isinstance(kb_ids, list) or kb_id not in kb_ids:
+                continue
+
+            new_value = {
+                **value,
+                "kb_ids": [item for item in kb_ids if item != kb_id],
+            }
+            await sp.session_put(pref.scope_id, "kb_config", new_value)
+            updated += 1
+
+        return updated
+
     def _init_task(self, task_id: str, status: str = "pending") -> None:
         self.upload_tasks[task_id] = {
             "status": status,
@@ -569,6 +592,12 @@ async def delete_kb(self):
             if not success:
                 return Response().error("知识库不存在").__dict__
 
+            updated_sessions = await self._remove_kb_from_session_configs(kb_id)
+            if updated_sessions:
+                logger.info(
+                    f"已从 {updated_sessions} 个会话配置中移除已删除知识库 {kb_id}",
+                )
+
             return Response().ok(message="删除知识库成功").__dict__
 
         except ValueError as e:

tests/test_kb_import.py

@@ -1,10 +1,12 @@
 import asyncio
+from types import SimpleNamespace
 from unittest.mock import AsyncMock, MagicMock
 
 import pytest
 import pytest_asyncio
 from quart import Quart
 
+import astrbot.dashboard.routes.knowledge_base as knowledge_base_route_module
 from astrbot.core import LogBroker
 from astrbot.core.core_lifecycle import AstrBotCoreLifecycle
 from astrbot.core.db.sqlite import SQLiteDatabase
@@ -117,6 +119,55 @@ async def authenticated_header(app: Quart, core_lifecycle_td: AstrBotCoreLifecyc
     return {"Authorization": f"Bearer {token}"}
 
 
+@pytest.mark.asyncio
+async def test_remove_deleted_kb_from_session_configs(monkeypatch: pytest.MonkeyPatch):
+    updates = []
+
+    class FakeSharedPreferences:
+        async def session_get(self, umo, key):
+            assert umo is None
+            assert key == "kb_config"
+            return [
+                SimpleNamespace(
+                    scope_id="platform:GroupMessage:group!alice",
+                    value={"val": {"kb_ids": ["kb-old", "kb-keep"], "top_k": 3}},
+                ),
+                SimpleNamespace(
+                    scope_id="platform:GroupMessage:group!bob",
+                    value={"val": {"kb_ids": ["kb-old"]}},
+                ),
+                SimpleNamespace(
+                    scope_id="platform:FriendMessage:charlie",
+                    value={"val": {"kb_ids": ["kb-keep"]}},
+                ),
+                SimpleNamespace(
+                    scope_id="platform:FriendMessage:broken",
+                    value={"val": {"kb_ids": "kb-old"}},
+                ),
+            ]
+
+        async def session_put(self, umo, key, value):
+            updates.append((umo, key, value))
+
+    monkeypatch.setattr(knowledge_base_route_module, "sp", FakeSharedPreferences())
+
+    updated = await KnowledgeBaseRoute._remove_kb_from_session_configs("kb-old")
+
+    assert updated == 2
+    assert updates == [
+        (
+            "platform:GroupMessage:group!alice",
+            "kb_config",
+            {"kb_ids": ["kb-keep"], "top_k": 3},
+        ),
+        (
+            "platform:GroupMessage:group!bob",
+            "kb_config",
+            {"kb_ids": []},
+        ),
+    ]
+
+
 @pytest.mark.asyncio
 async def test_import_documents(
     app: Quart, authenticated_header: dict, core_lifecycle_td: AstrBotCoreLifecycle