吉鑫升andClaude Fable 5
3d6f35391e
- 新增 POST /threads/count：与 /threads/search 同一套过滤（标题搜索、
系统会话排除），仅返回 {total}；ThreadMetaStore 增加 count 方法
（SQL 走 COUNT(*)，JSON 过滤分批扫描计数）
- 对话页面搜索框下常驻显示「共 N 条对话」，分页条显示 当前页/总页数
（useThreadsCount，仅随筛选条件变化，翻页不重复请求）
- 智能体右侧 SOUL 预览改为 40vh 上限自适应展开（不再全部展开）；
详情面板/卡片编辑/创建页的 SOUL 输入框统一为适中高度 + 可拖拽
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
115 lines
4.0 KiB
Python
115 lines
4.0 KiB
Python
"""Abstract interface for thread metadata storage.
|
|
|
|
Implementations:
|
|
- ThreadMetaRepository: SQL-backed (sqlite / postgres via SQLAlchemy)
|
|
- MemoryThreadMetaStore: wraps LangGraph BaseStore (memory mode)
|
|
|
|
All mutating and querying methods accept a ``user_id`` parameter with
|
|
three-state semantics (see :mod:`deerflow.runtime.user_context`):
|
|
|
|
- ``AUTO`` (default): resolve from the request-scoped contextvar.
|
|
- Explicit ``str``: use the provided value verbatim.
|
|
- Explicit ``None``: bypass owner filtering (migration/CLI only).
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import abc
|
|
|
|
from deerflow.runtime.user_context import AUTO, _AutoSentinel
|
|
|
|
|
|
class ThreadMetaStore(abc.ABC):
|
|
@abc.abstractmethod
|
|
async def create(
|
|
self,
|
|
thread_id: str,
|
|
*,
|
|
assistant_id: str | None = None,
|
|
user_id: str | None | _AutoSentinel = AUTO,
|
|
display_name: str | None = None,
|
|
metadata: dict | None = None,
|
|
) -> dict:
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def get(self, thread_id: str, *, user_id: str | None | _AutoSentinel = AUTO) -> dict | None:
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def search(
|
|
self,
|
|
*,
|
|
metadata: dict | None = None,
|
|
status: str | None = None,
|
|
limit: int = 100,
|
|
offset: int = 0,
|
|
user_id: str | None | _AutoSentinel = AUTO,
|
|
exclude_system: bool = False,
|
|
query: str | None = None,
|
|
) -> list[dict]:
|
|
"""Search threads ordered by ``updated_at`` desc.
|
|
|
|
``exclude_system=True`` drops threads whose ``metadata.system`` is
|
|
truthy (scheduler runs, roundtable workers, …) so user-facing
|
|
conversation lists are not crowded out by machine-created threads.
|
|
``query`` is a case-insensitive substring match on the thread title
|
|
(``display_name``). ``limit``/``offset`` apply to the *filtered*
|
|
result set.
|
|
"""
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def count(
|
|
self,
|
|
*,
|
|
metadata: dict | None = None,
|
|
status: str | None = None,
|
|
user_id: str | None | _AutoSentinel = AUTO,
|
|
exclude_system: bool = False,
|
|
query: str | None = None,
|
|
) -> int:
|
|
"""Count threads matching the same filters as :meth:`search`.
|
|
|
|
Backs pagination UIs that need a total alongside per-page results.
|
|
"""
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def update_display_name(self, thread_id: str, display_name: str, *, user_id: str | None | _AutoSentinel = AUTO) -> None:
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def update_status(self, thread_id: str, status: str, *, user_id: str | None | _AutoSentinel = AUTO) -> None:
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def update_assistant_id(self, thread_id: str, assistant_id: str, *, user_id: str | None | _AutoSentinel = AUTO) -> None:
|
|
"""Backfill ``assistant_id`` for a thread row.
|
|
|
|
Used by ``start_run`` when the row was pre-created via ``POST /threads``
|
|
without an assistant_id (the SDK's ``client.threads.create()`` doesn't
|
|
pass it), and the first run on the thread reveals the assistant. No-op
|
|
if the thread does not exist or the owner check fails.
|
|
"""
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def update_metadata(self, thread_id: str, metadata: dict, *, user_id: str | None | _AutoSentinel = AUTO) -> None:
|
|
"""Merge ``metadata`` into the thread's metadata field.
|
|
|
|
Existing keys are overwritten by the new values; keys absent from
|
|
``metadata`` are preserved. No-op if the thread does not exist
|
|
or the owner check fails.
|
|
"""
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def check_access(self, thread_id: str, user_id: str, *, require_existing: bool = False) -> bool:
|
|
"""Check if ``user_id`` has access to ``thread_id``."""
|
|
pass
|
|
|
|
@abc.abstractmethod
|
|
async def delete(self, thread_id: str, *, user_id: str | None | _AutoSentinel = AUTO) -> None:
|
|
pass
|