1
0
Files
nex/openspec/specs/anthropic-protocol-proxy/spec.md
lanyuanxiaoyao f18904af1e feat: 实现分层架构,包含 domain、service、repository 和 pkg 层
- 新增 domain 层:model、provider、route、stats 实体
- 新增 service 层:models、providers、routing、stats 业务逻辑
- 新增 repository 层:models、providers、stats 数据访问
- 新增 pkg 工具包:errors、logger、validator
- 新增中间件:CORS、logging、recovery、request ID
- 新增数据库迁移:初始 schema 和索引
- 新增单元测试和集成测试
- 新增规范文档:config-management、database-migration、error-handling、layered-architecture、middleware-system、request-validation、structured-logging、test-coverage
- 移除 config 子包和 model_router(已迁移至分层架构)
2026-04-16 00:47:20 +08:00

2.7 KiB

Anthropic Protocol Proxy

MODIFIED Requirements

Requirement: 支持 Anthropic Messages API 端点

网关 SHALL 提供 Anthropic Messages API 端点 POST /v1/messages 供外部应用调用。

Scenario: 成功的非流式请求

  • WHEN 应用发送 POST 请求到 /v1/messages,携带有效的 Anthropic 请求格式(非流式)
  • THEN 网关 SHALL 将 Anthropic 请求转换为 OpenAI 格式
  • THEN 网关 SHALL 将转换后的请求转发到配置的供应商
  • THEN 网关 SHALL 将 OpenAI 响应转换回 Anthropic 格式
  • THEN 网关 SHALL 将转换后的响应返回给应用

Scenario: 成功的流式请求

  • WHEN 应用发送 POST 请求到 /v1/messages,携带 stream: true
  • THEN 网关 SHALL 将 Anthropic 请求转换为 OpenAI 格式
  • THEN 网关 SHALL 将转换后的请求转发给供应商
  • THEN 网关 SHALL 将 OpenAI 流事件转换为 Anthropic 流事件
  • THEN 网关 SHALL 使用 SSE 格式将转换后的事件流式返回给应用

变更说明: handler 通过 service 层调用,而非直接调用 config 和 provider 包。API 接口保持不变。

Requirement: 将 Anthropic 请求转换为 OpenAI 格式

网关 SHALL 将 Anthropic Messages API 请求转换为 OpenAI Chat Completions API 格式。

Scenario: System 消息转换

  • WHEN Anthropic 请求包含 system 字段
  • THEN 网关 SHALL 将其转换为 messages 数组中 role: "system" 的消息

Scenario: Messages 转换

  • WHEN Anthropic 请求包含 messages 数组
  • THEN 网关 SHALL 在转换后的 OpenAI 请求中保留这些消息
  • THEN 网关 SHALL 保留每条消息的 role 和 content

变更说明: 协议转换逻辑保持不变,仅调用方式改为通过 service 层。

ADDED Requirements

Requirement: 使用 service 层处理请求

Handler SHALL 通过 service 层处理业务逻辑。

Scenario: 调用 routing service

  • WHEN handler 收到请求并转换为 OpenAI 格式
  • THEN SHALL 调用 RoutingService.Route() 获取路由结果
  • THEN SHALL 使用路由结果中的供应商信息

Scenario: 调用 stats service

  • WHEN 请求成功完成
  • THEN SHALL 调用 StatsService.Record() 记录统计
  • THEN SHALL 异步记录统计(不阻塞响应)

Requirement: 使用结构化错误处理

Handler SHALL 使用结构化错误处理。

Scenario: 协议转换错误

  • WHEN 协议转换失败
  • THEN SHALL 返回结构化错误响应
  • THEN SHALL 包含详细的错误信息

Scenario: 路由错误处理

  • WHEN RoutingService 返回错误
  • THEN SHALL 转换为对应的 AppError
  • THEN SHALL 返回统一的错误响应