a77cd83e6a
## 新增功能 - 文件管理模块：分类树 + 文件上传/下载/删除 - 文件上传支持拖拽（Dragger）+ 手动上传（customRequest 模式） ## 页面布局统一（参照评测执行页） - 仪表盘/评测对象/评测场景/评测报告 全部改为全高 flex 布局 - 统一内联页头样式（h2 + 竖线分隔 + 描述） - 表格撑满高度、overflow 处理 - 每页添加刷新按钮 ## Bug 修复 - 分类树操作按钮 hover 不可见（CSS 规则缺失） - 文件上传失败（multipart boundary 缺失） - LLM API 响应 content blocks 数组格式支持（_extract_content_from_api_response） - response_time_max_ms 被静默忽略（隐式规则传空 params） - 空 messages 导致 IndexError 崩溃 - poll_reply 异常中止整个 run（缺 try/catch） - engine finally 未关闭 session - 3 个页面 UTC 时间戳解析偏差 8 小时 ## 后端 - EvalEngine: poll_reply 异常保护、空 dialog 保护、session 关闭 - LLM API 响应解析支持 content-block-array 格式 - 隐式 response_time 规则正确传递 max_ms 参数 ## 前端 - api.ts: 移除手动 Content-Type（让浏览器自动添加 boundary） - Files.tsx: customRequest 替代 beforeUpload、布局优化 - index.css: 分类树 hover 规则 - Targets/Scenarios/Home/Reports: 全高布局改造 - 3 个页面时间戳改用 formatDateTime()（修复 UTC 偏差） Co-Authored-By: Claude <noreply@anthropic.com>
61 lines
1.5 KiB
Python
61 lines
1.5 KiB
Python
"""Abstract base class for message channels."""
|
|
|
|
from abc import ABC, abstractmethod
|
|
from dataclasses import dataclass
|
|
from datetime import datetime
|
|
from typing import Any, Optional
|
|
|
|
|
|
@dataclass
|
|
class ChannelHealth:
|
|
ok: bool
|
|
message: str = ""
|
|
|
|
|
|
@dataclass
|
|
class SendResult:
|
|
ok: bool
|
|
question_msg_id: Optional[str] = None
|
|
raw_response: Optional[dict[str, Any]] = None
|
|
error: Optional[str] = None
|
|
|
|
|
|
@dataclass
|
|
class Reply:
|
|
question_msg_id: str
|
|
content: Any
|
|
sender_name: Optional[str] = None
|
|
msg_time: Optional[datetime] = None
|
|
raw_message: Optional[dict[str, Any]] = None
|
|
|
|
|
|
class EvalChannel(ABC):
|
|
"""Abstract message channel used to interact with an evaluation target.
|
|
|
|
All methods are async so push-based channels (WebSocket, SSE) and
|
|
poll-based channels (REST) share the same interface.
|
|
"""
|
|
|
|
@abstractmethod
|
|
async def health_check(self) -> ChannelHealth:
|
|
"""Verify the channel can reach the target."""
|
|
...
|
|
|
|
@abstractmethod
|
|
async def send(self, content: str, **kwargs: Any) -> SendResult:
|
|
"""Send a message to the target and return its question message id."""
|
|
...
|
|
|
|
@abstractmethod
|
|
async def poll_reply(
|
|
self,
|
|
question_msg_id: str,
|
|
timeout: float = 30.0,
|
|
poll_interval: float = 1.0,
|
|
) -> Optional[Reply]:
|
|
"""Wait for a reply to a previously sent message.
|
|
|
|
Implementations may poll (REST) or await a push event (WebSocket).
|
|
"""
|
|
...
|