eaiadminandClaude Code
c1af86c934
按用户指示做**一包提交**，不按工作流拆分。本提交刻意混合了多条并行线：
· 本地 ASR 接管：audio 成为与 chat/embed/image/video 同等的路由类别
（IsLocalRoute 单一判据、audio 健康探测、default_audio_route、
auto 占位、GET /api/ai/routes/audio、回退云端时界面明示「音频已出网」）
· LLM 调用层：ctx 贯穿、ToolCall/ToolSchema、EmptyCompletionError /
TransientUpstreamError（按错误类型而非文案判重试）
· 编排 Agent：general_assistant orchestrate/persistence/spec_driver
· 联网搜索：internal/search（playwright）
· 网盘：backend + 前端
· 前端 UI：导航/路由/工作台若干页
· 交付文档：DELIVERY.md / AR04 / 部署文档的「无 Python」表述据实改写，
新增 eai_agentplatform-asr.service、asr.env、clonezilla-cleanup 清 ~/asr-poc
不分拆的原因：dev 早期，粒度不该打断工作节奏。且实测过——这些改动
**在编译上是同一个单元**（llm.go 的 ctx 签名变更牵动 12 个调用点，
chat_message.go 的 ctx 改动又与编排重写同处一个 hunk），拆出来的中间态编不过。
详见 TOP_CODING_RULES.md G14.5 与 bugs_and_errors.md E09。
Co-Authored-By: Claude Code <noreply@anthropic.com>
83 lines
2.6 KiB
Go
83 lines
2.6 KiB
Go
package search
|
|
|
|
import "fmt"
|
|
|
|
// Engine 一个可插拔的搜索引擎源。
|
|
//
|
|
// 各源（SearXNG、搜狗 HTTP、真实浏览器、付费 SerpApi 等）通过实现该接口接入聚合 Client，
|
|
// 由 search_config.json 声明启用顺序与参数，替代此前写死在 Client.Search 里的硬编码回退链。
|
|
type Engine interface {
|
|
// Name 引擎唯一标识（与 search_config.json 中 engines 的 key 对应）。
|
|
Name() string
|
|
// Search 执行一次搜索。失败或无结果时返回 (nil, err)，由聚合 Client 降级到下一引擎。
|
|
Search(query string) ([]Result, error)
|
|
}
|
|
|
|
// searxngEngine 基于 SearXNG /search?format=json 的引擎。
|
|
type searxngEngine struct {
|
|
client *SearXNGClient
|
|
}
|
|
|
|
func (e *searxngEngine) Name() string { return "searxng" }
|
|
func (e *searxngEngine) Search(q string) ([]Result, error) {
|
|
return e.client.searchSearXNG(q)
|
|
}
|
|
|
|
// sogouEngine 基于搜狗 HTTP 抓取的引擎。
|
|
type sogouEngine struct {
|
|
client *SogouClient
|
|
}
|
|
|
|
func (e *sogouEngine) Name() string { return "sogou" }
|
|
func (e *sogouEngine) Search(q string) ([]Result, error) {
|
|
return e.client.Search(q)
|
|
}
|
|
|
|
// browserEngine 基于真实浏览器（Playwright + 系统 Chrome）的引擎。
|
|
type browserEngine struct {
|
|
searcher *BrowserSearcher
|
|
}
|
|
|
|
func (e *browserEngine) Name() string { return "browser" }
|
|
func (e *browserEngine) Search(q string) ([]Result, error) {
|
|
return e.searcher.Search(q)
|
|
}
|
|
|
|
// serpapiEngine 基于付费 SerpApi 的引擎。
|
|
type serpapiEngine struct {
|
|
client *SerpApiClient
|
|
}
|
|
|
|
func (e *serpapiEngine) Name() string { return "serpapi" }
|
|
func (e *serpapiEngine) Search(q string) ([]Result, error) {
|
|
return e.client.Search(q)
|
|
}
|
|
|
|
// dtsAIEngine 基于阿里云 DTS-AI WebSearch 的引擎。
|
|
type dtsAIEngine struct {
|
|
client *DtsAIClient
|
|
}
|
|
|
|
func (e *dtsAIEngine) Name() string { return "dtsai" }
|
|
func (e *dtsAIEngine) Search(q string) ([]Result, error) {
|
|
return e.client.Search(q)
|
|
}
|
|
|
|
// engineFromConfig 根据一条 EngineConfig 构建对应引擎；type 未知返回 error。
|
|
func engineFromConfig(name string, ec EngineConfig) (Engine, error) {
|
|
switch ec.Type {
|
|
case "searxng":
|
|
return &searxngEngine{client: NewSearXNGClient(ec.BaseURL)}, nil
|
|
case "sogou":
|
|
return &sogouEngine{client: NewSogouClient()}, nil
|
|
case "browser":
|
|
return &browserEngine{searcher: GetBrowserSearcher()}, nil
|
|
case "serpapi":
|
|
return &serpapiEngine{client: NewSerpApiClient(ec.APIKeyEnv)}, nil
|
|
case "dtsai":
|
|
return &dtsAIEngine{client: NewDtsAIClient(ec.APIKeyEnv, ec.Region, ec.BaseURL, ec.MaxResults, ec.TimeoutSec)}, nil
|
|
default:
|
|
return nil, fmt.Errorf("未知搜索引擎类型 %q（引擎 %q）", ec.Type, name)
|
|
}
|
|
}
|