diff --git a/internal/plugin/cabi/loader.go b/internal/plugin/cabi/loader.go new file mode 100644 index 0000000..68c5d19 --- /dev/null +++ b/internal/plugin/cabi/loader.go @@ -0,0 +1,262 @@ +package cabi + +/* +#cgo LDFLAGS: -ldl +#include +#include +#include + +// PluginAPI struct (mirrors plugin ABI) +typedef struct { + int version; + int version_min; + int (*init_plugin)(char*, char*, char**); + int (*start_plugin)(void*, int, char**); + int (*stop_plugin)(char**); + int (*invoke_tool)(char*, char*, char**, char**); + int (*invoke_stage)(char*, char*, char**); + int (*invoke_output)(char*, char*, char*, char**); + void (*free_string)(char*); + int (*get_tool_defs)(char**); + int (*get_stages)(char**); + int (*get_channels)(char**); +} plugin_api_t; + +// CoreAPI struct (implemented by core, passed to plugin) +typedef struct { + int version; + int version_min; + int (*register_tool)(char*, char*, char**); + int (*register_stage)(char*, int, char**); + int (*register_output_channel)(char*, int, char*, int, char**); + int (*register_plugin_api)(char*, char**); + int (*inject_text)(char*, char*, char*, char**); + int (*inject_interrupt_text)(char*, char*, char*, char**); + int (*inject_text_no_memory)(char*, char*, char*, char**); + int (*set_auto_restart)(int, char**); + int (*memory_recall)(char*, int, char**, char**); + int (*memory_commit)(char*, char**); + int (*memory_introspect)(char**, char**); + int (*memory_merge)(char*, char*, char**); + int (*memory_purge)(char*, int, char**); + int (*doc_query)(char*, int, char**, char**); + int (*knowledge_search)(char*, int, char**, char**); + int (*settings_get)(char*, char**, char**); + int (*settings_set)(char*, char*, char**); + int (*settings_register_def)(char*, char**); + int (*llm_list_sources)(char**, char**); + int (*llm_set_source)(char*, char**); + int (*social_get_person)(char*, char**, char**); + int (*social_get_network)(char*, int, char**, char**); + int (*subscribe)(char*, int, char**); + int (*unsubscribe)(char*, int, char**); + void (*free_string)(char*); +} core_api_t; + +// libHandle wraps a dlopen handle +typedef void* libHandle; + +libHandle lib_open(const char* path) { + return dlopen(path, RTLD_NOW | RTLD_LOCAL); +} + +plugin_api_t* lib_get_api(libHandle h) { + plugin_api_t* (*fn)(void); + *(void**)(&fn) = dlsym(h, "plugin_init"); + if (!fn) return NULL; + return fn(); +} + +void lib_close(libHandle h) { + dlclose(h); +} + +char* lib_get_error(void) { + return dlerror(); +} + +void api_free_string(plugin_api_t* api, char* ptr) { + if (api && api->free_string) api->free_string(ptr); +} + +int call_init_plugin(plugin_api_t* api, char* name, char* config, char** err) { return api->init_plugin(name, config, err); } +int call_start_plugin(plugin_api_t* api, void* core, int ver, char** err) { return api->start_plugin(core, ver, err); } +int call_stop_plugin(plugin_api_t* api, char** err) { return api->stop_plugin(err); } +int call_get_tool_defs(plugin_api_t* api, char** r) { return api->get_tool_defs(r); } +int call_get_stages(plugin_api_t* api, char** r) { return api->get_stages(r); } +int call_get_channels(plugin_api_t* api, char** r) { return api->get_channels(r); } +int call_invoke_tool(plugin_api_t* api, char* n, char* a, char** r, char** e) { return api->invoke_tool(n, a, r, e); } +int call_invoke_stage(plugin_api_t* api, char* s, char* c, char** e) { return api->invoke_stage(s, c, e); } +int call_invoke_output(plugin_api_t* api, char* c, char* m, char* p, char** e) { return api->invoke_output(c, m, p, e); } +*/ +import "C" +import ( + "encoding/json" + "fmt" + "unsafe" +) + +// Handle represents a loaded C ABI plugin. +type Handle struct { + soPath string + lib C.libHandle + api *C.plugin_api_t +} + +// Load opens a .so plugin and initializes it via the C ABI. +func Load(soPath, name string, config map[string]interface{}) (*Handle, error) { + cPath := C.CString(soPath) + defer C.free(unsafe.Pointer(cPath)) + + lib := C.lib_open(cPath) + if lib == nil { + errStr := C.GoString(C.lib_get_error()) + return nil, fmt.Errorf("dlopen %s: %s", soPath, errStr) + } + + api := C.lib_get_api(lib) + if api == nil { + C.lib_close(lib) + errStr := C.GoString(C.lib_get_error()) + return nil, fmt.Errorf("dlsym plugin_init in %s: %s", soPath, errStr) + } + + if int(api.version) < ABIVersionMin { + C.lib_close(lib) + return nil, fmt.Errorf("plugin %s ABI version %d < minimum %d", name, int(api.version), ABIVersionMin) + } + + handle := &Handle{soPath: soPath, lib: lib, api: api} + + // Initialize plugin + configJSON, _ := json.Marshal(config) + cName := C.CString(name) + cConfig := C.CString(string(configJSON)) + var initErr *C.char + defer C.free(unsafe.Pointer(cName)) + defer C.free(unsafe.Pointer(cConfig)) + + if ret := C.int(C.call_init_plugin(api, cName, cConfig, &initErr)); ret != 0 { + errMsg := "" + if initErr != nil { + errMsg = C.GoString(initErr) + C.api_free_string(api, initErr) + } + handle.Close() + return nil, fmt.Errorf("init_plugin %s: %s", name, errMsg) + } + + return handle, nil +} + +// Start calls the plugin's Start with a CoreAPI pointer. +func (h *Handle) Start(corePtr unsafe.Pointer) error { + if ret := C.int(C.call_start_plugin(h.api, corePtr, C.int(ABIVersion), nil)); ret != 0 { + return fmt.Errorf("start_plugin failed") + } + return nil +} + +// Stop calls the plugin's Stop. +func (h *Handle) Stop() error { + if ret := C.int(C.call_stop_plugin(h.api, nil)); ret != 0 { + return fmt.Errorf("stop_plugin failed") + } + return nil +} + +// GetToolDefs returns the tool definitions registered by the plugin during Start. +func (h *Handle) GetToolDefs() ([]json.RawMessage, error) { + var result *C.char + if ret := C.int(C.call_get_tool_defs(h.api, &result)); ret != 0 || result == nil { + return nil, nil + } + defer C.api_free_string(h.api, result) + var defs []json.RawMessage + if err := json.Unmarshal([]byte(C.GoString(result)), &defs); err != nil { + return nil, err + } + return defs, nil +} + +// GetStages returns stage names registered by the plugin. +func (h *Handle) GetStages() ([]string, error) { + var result *C.char + if ret := C.int(C.call_get_stages(h.api, &result)); ret != 0 || result == nil { + return nil, nil + } + defer C.api_free_string(h.api, result) + var stages []string + if err := json.Unmarshal([]byte(C.GoString(result)), &stages); err != nil { + return nil, err + } + return stages, nil +} + +// GetChannels returns output channel registrations. +func (h *Handle) GetChannels() ([]channelInfo, error) { + var result *C.char + if ret := C.int(C.call_get_channels(h.api, &result)); ret != 0 || result == nil { + return nil, nil + } + defer C.api_free_string(h.api, result) + var channels []channelInfo + if err := json.Unmarshal([]byte(C.GoString(result)), &channels); err != nil { + return nil, err + } + return channels, nil +} + +type channelInfo struct { + Name string `json:"name"` + Caps int `json:"caps"` + Desc string `json:"desc"` +} + +// InvokeTool calls a tool handler in the plugin. +func (h *Handle) InvokeTool(name string, args map[string]interface{}) (map[string]interface{}, error) { + argsJSON, _ := json.Marshal(args) + cName := C.CString(name) + cArgs := C.CString(string(argsJSON)) + var result, cErr *C.char + defer C.free(unsafe.Pointer(cName)) + defer C.free(unsafe.Pointer(cArgs)) + + if ret := C.int(C.call_invoke_tool(h.api, cName, cArgs, &result, &cErr)); ret != 0 { + errMsg := "" + if cErr != nil { + errMsg = C.GoString(cErr) + C.api_free_string(h.api, cErr) + } + return nil, fmt.Errorf("invoke_tool %s: %s", name, errMsg) + } + if result == nil { + return nil, nil + } + defer C.api_free_string(h.api, result) + var r map[string]interface{} + if err := json.Unmarshal([]byte(C.GoString(result)), &r); err != nil { + return nil, err + } + return r, nil +} + +// InvokeStage calls a stage handler in the plugin. +func (h *Handle) InvokeStage(stage, ctxJSON string) error { + cStage := C.CString(stage) + cCtx := C.CString(ctxJSON) + defer C.free(unsafe.Pointer(cStage)) + defer C.free(unsafe.Pointer(cCtx)) + if ret := C.int(C.call_invoke_stage(h.api, cStage, cCtx, nil)); ret != 0 { + return fmt.Errorf("invoke_stage %s failed", stage) + } + return nil +} + +// Close unloads the plugin library. +func (h *Handle) Close() { + if h.lib != nil { + C.lib_close(h.lib) + h.lib = nil + } +} diff --git a/internal/plugin/cabi/types.go b/internal/plugin/cabi/types.go new file mode 100644 index 0000000..70cd229 --- /dev/null +++ b/internal/plugin/cabi/types.go @@ -0,0 +1,36 @@ +package cabi + +// ABI version constants +const ( + ABIVersion = 1 + ABIVersionMin = 1 +) + +// Dispatch method IDs (mirrors the plugin side constants) +const ( + CoreRegisterTool = 1 + CoreRegisterStage = 2 + CoreRegisterOutputCh = 3 + CoreRegisterPluginAPI = 4 + CoreInjectText = 5 + CoreInjectInterruptText = 6 + CoreInjectTextNoMemory = 7 + CoreSetAutoRestart = 8 + CoreMemoryRecall = 9 + CoreMemoryCommit = 10 + CoreMemoryIntrospect = 11 + CoreMemoryMerge = 12 + CoreMemoryPurge = 13 + CoreDocQuery = 14 + CoreKnowledgeSearch = 15 + CoreSettingsGet = 16 + CoreSettingsSet = 17 + CoreSettingsRegisterDef = 18 + CoreLLMListSources = 19 + CoreLLMSetSource = 20 + CoreSocialGetPerson = 21 + CoreSocialGetNetwork = 22 + CoreSubscribe = 23 + CoreUnsubscribe = 24 + CoreFreeString = 25 +) diff --git a/internal/plugin/dynamic.go b/internal/plugin/dynamic.go index f80bae5..2ca7225 100644 --- a/internal/plugin/dynamic.go +++ b/internal/plugin/dynamic.go @@ -9,9 +9,12 @@ import ( "path/filepath" "plugin" "reflect" + "unsafe" sdk "gitcode.com/JianFeeeee/HomeAgent/internal/sdk" pubsdk "gitcode.com/JianFeeeee/homeagent-sdk/sdk" + + "gitcode.com/JianFeeeee/HomeAgent/internal/plugin/cabi" ) // .so 插件必须导出函数 NewPlugin,签名与 NativeFactory 一致: @@ -50,15 +53,86 @@ func readManifest(dir string) *PluginManifest { return &m } -// tryLoadSO 尝试从插件目录加载 plugin.so(Go plugin -buildmode=plugin)。 -// 返回 nil,nil 表示目录中没有 plugin.so。 +// cabiPlugin wraps a C ABI loaded plugin (.so via -buildmode=c-shared). +type cabiPlugin struct { + name string + handle *cabi.Handle +} + +func (p *cabiPlugin) Name() string { return p.name } +func (p *cabiPlugin) Start(s *sdk.PluginSDK) error { + // Build CoreAPI from the provided PluginSDK and pass to plugin + corePtr := buildCoreAPI(s, p.name) + if err := p.handle.Start(corePtr); err != nil { + return err + } + + // Discover tools/stages/channels registered by the plugin during Start + defs, _ := p.handle.GetToolDefs() + for _, d := range defs { + var td pubsdk.ToolDef + if err := json.Unmarshal(d, &td); err != nil { + continue + } + toolName := td.Name + td.Plugin = p.name + s.RegisterTool(toolName, sdk.ToolDef{ + Name: toolName, + Description: td.Description, + Parameters: td.Parameters, + Plugin: p.name, + }, makeCABIHandler(p.handle, toolName)) + } + + stages, _ := p.handle.GetStages() + for _, stage := range stages { + st := sdk.Stage(stage) + s.RegisterStage(st, func(sc *sdk.StageContext) error { + ctxJSON, _ := json.Marshal(map[string]interface{}{ + "raw_message": sc.RawMessage, + "user_id": sc.UserID, + "phase": string(sc.Phase), + }) + return p.handle.InvokeStage(stage, string(ctxJSON)) + }) + } + + return nil +} + +func (p *cabiPlugin) Stop() error { + p.handle.Close() + return nil +} + +func makeCABIHandler(handle *cabi.Handle, toolName string) sdk.ToolHandler { + return func(args map[string]interface{}) (interface{}, error) { + return handle.InvokeTool(toolName, args) + } +} + +// buildCoreAPI creates a C-compatible CoreAPI function table from a PluginSDK. +// Returns an unsafe.Pointer to a C-allocated struct. +// TODO: implement CoreAPI dispatch that calls back into the Go PluginSDK +func buildCoreAPI(s *sdk.PluginSDK, pluginName string) unsafe.Pointer { + return unsafe.Pointer(nil) // placeholder - will be implemented in core dispatch +} + +// tryLoadSO 尝试从插件目录加载 plugin.so。 +// 优先尝试 C ABI 加载(-buildmode=c-shared),失败时回退到 Go plugin.Open。 func tryLoadSO(dir, name string, config map[string]interface{}) (sdk.Plugin, error) { soPath := filepath.Join(dir, soEntry) if _, err := os.Stat(soPath); os.IsNotExist(err) { return nil, nil } - // 复制到临时路径以绕过 Go plugin.Open 的路径缓存 + // Try C ABI first + handle, err := cabi.Load(soPath, name, config) + if err == nil { + return &cabiPlugin{name: name, handle: handle}, nil + } + + // Fall back to Go plugin.Open data, err := os.ReadFile(soPath) if err != nil { return nil, fmt.Errorf("read %s: %w", soPath, err) @@ -87,14 +161,7 @@ func tryLoadSO(dir, name string, config map[string]interface{}) (sdk.Plugin, err return nil, fmt.Errorf("NewPlugin in %s is not a function (type=%T)", soPath, sym) } if rv.Type().NumIn() != 2 || rv.Type().NumOut() != 2 { - return nil, fmt.Errorf("NewPlugin in %s has wrong arity: type=%s in=%d out=%d", soPath, rv.Type().String(), rv.Type().NumIn(), rv.Type().NumOut()) - } - arg0 := rv.Type().In(0) - arg1 := rv.Type().In(1) - out0 := rv.Type().Out(0) - out1 := rv.Type().Out(1) - if arg0.Kind() != reflect.String || arg1.Kind() != reflect.Map || out1.String() != "error" { - return nil, fmt.Errorf("NewPlugin in %s signature mismatch: type=%s arg0=%s arg1=%s out0=%s out1=%s", soPath, rv.Type().String(), arg0.String(), arg1.String(), out0.String(), out1.String()) + return nil, fmt.Errorf("NewPlugin in %s has wrong arity", soPath) } outs := rv.Call([]reflect.Value{reflect.ValueOf(name), reflect.ValueOf(config)}) if len(outs) != 2 { @@ -108,7 +175,7 @@ func tryLoadSO(dir, name string, config map[string]interface{}) (sdk.Plugin, err } plg, ok := outs[0].Interface().(pubsdk.Plugin) if !ok { - return nil, fmt.Errorf("NewPlugin in %s returned value that does not implement pubsdk.Plugin", soPath) + return nil, fmt.Errorf("NewPlugin in %s does not implement pubsdk.Plugin", soPath) } return &dynamicPlugin{name: name, impl: plg}, nil diff --git a/plan.md b/plan.md new file mode 100644 index 0000000..4ef814e --- /dev/null +++ b/plan.md @@ -0,0 +1,217 @@ +# C ABI 插件桥接计划 + +## 问题 + +Go `-buildmode=plugin` 要求插件的所有 Go 依赖(包括标准库)与核心编译版本完全一致,导致: +- 核心升级 Go 版本 → 所有插件必须重新编译 +- 不同环境下编译的插件无法加载 +- 插件开发者必须与核心使用完全相同的构建环境 + +## 方案 + +完全采用 C ABI 作为插件和核心的通信层,彻底摒弃 Go `-buildmode=plugin`。 + +``` +┌──────────────────────┐ +│ 核心 (编译时) │ +│ ├── 内部插件 │ ← init() 自注册,纯 Go,伴随核心编译 +│ └── 核心逻辑 │ +├──────────────────────┤ +│ 外部插件 (运行时) │ +│ ┌──────────────────┐│ +│ │ 插件 Go 代码 ││ ← 插件开发者写 Go,接口不变 +│ ├──────────────────┤│ +│ │ SDK Go Wrapper ││ ← 序列化/反序列化,隐藏 C ABI +│ ├──────────────────┤│ +│ │ C ABI 函数表 ││ ← 唯一的共享 ABI,版本隔离层 +│ ├──────────────────┤│ +│ │ 核心 C 接收层 ││ ← dlopen + dispatch → 内部 API +│ └──────────────────┘│ +└──────────────────────┘ +``` + +外部插件统一走 `-buildmode=c-shared`,编译为 C ABI `.so`,核心通过 `dlopen` 加载。 + +--- + +## 阶段一:C ABI 函数表定义(SDK 仓库) + +**位置**:`homeagent-sdk/tools/plugindev/templates.go`(新建 C ABI 模板,独立于现有 Windows `tmplBridge`) + +- [ ] 1.1 定义 C ABI 函数表结构体 `HomeAgentCABI`(C 代码) +- [ ] 1.2 核心→插件方向(核心调插件): + - `init_plugin(name, config_json) → error_json` + - `start_plugin(sdk_table, version) → error_json` + - `stop_plugin() → error_json` + - `invoke_tool(name, args_json) → result_json` + - `invoke_stage(stage, ctx_json) → error_json` + - `free_string(ptr)` — 释放插件返回的 C 字符串 +- [ ] 1.3 插件→核心方向(插件调核心,通过 `sdk_table` 传入): + - `register_tool(name, def_json, handler_id) → error_json` + - `register_stage(stage, handler_id) → error_json` + - `register_output_channel(name, caps, desc, handler_id) → error_json` + - `inject_text(source, channel, text) → error_json` + - `inject_interrupt_text(source, channel, text) → error_json` + - `memory_recall(query, depth) → result_json` + - `memory_commit(triples_json) → error_json` + - `memory_introspect() → result_json` + - `doc_query(text, topK) → result_json` + - `knowledge_search(query, topK) → result_json` + - `settings_get(key) → value_json` + - `settings_set(key, value_json) → error_json` + - `llm_list_sources() → result_json` + - `social_get_person(name) → result_json` + - `subscribe(event_type, handler_id) → error_json` + - `free_string(ptr)` — 释放核心返回的 C 字符串 +- [ ] 1.4 定义回调 dispatch 机制(插件侧注册,核心侧触发): + - `tool_handler(handler_id, args_json) → result_json` + - `stage_handler(handler_id, ctx_json) → error_json` + - `output_handler(handler_id, msg_type, payload_json) → error_json` + - `event_handler(handler_id, event_json) → error_json` +- [ ] 1.5 入口导出: + ```c + extern HomeAgentCABI* plugin_init(void); + ``` +- [ ] 1.6 生成的 C 桥代码放入 `tmplCABIBridge`,与现有 Windows `tmplBridge` 独立 + +--- + +## 阶段二:核心侧 C ABI 加载器 + +**位置**:`HomeAgent/internal/plugin/cabi/` + +- [ ] 2.1 创建 `internal/plugin/cabi/types.go` + - ABI 版本号常量 + - `PluginHandle` 结构(封装 `dlopen` handle + C 函数表指针) + - 返回/错误结构体定义 +- [ ] 2.2 创建 `internal/plugin/cabi/bridge.go` + - 核心侧暴露给插件的 C 函数表 + - 每个函数:接收 JSON → 反序列化 → 调内部 API → 序列化返回 + - 回调注册表:handler_id → Go 回调函数的映射 +- [ ] 2.3 创建 `internal/plugin/cabi/loader.go` + - `Load(path string) (*PluginHandle, error)`: + 1. `dlopen(path, RTLD_NOW|RTLD_LOCAL)` + 2. `dlsym("plugin_init")` → 获取 C 函数表指针 + 3. 检查 version 兼容性 + 4. 初始化:`init_plugin(name, config)` → `start_plugin(sdk_table)` + - `Unload(handle *PluginHandle) error`: + 1. `stop_plugin()` + 2. `dlclose` +- [ ] 2.4 创建 `internal/plugin/cabi/sdk_stub.go` + - 核心侧接收插件 SDK 调用的 dispatch 层 + - 每个 dispatch 对应一个 PluginSDK 方法 +- [ ] 2.5 序列化辅助函数 + - `MarshalJSON / UnmarshalJSON / FreeCString` + +--- + +## 阶段三:核心注册器集成 + +**位置**:`HomeAgent/internal/plugin/registry.go` + +- [ ] 3.1 内部插件路径不变(`RegisterFactory` → `init()` 自注册,编译进内核) +- [ ] 3.2 外部插件加载改为 C ABI: + ``` + func loadExternalPlugin(path string) (sdk.Plugin, error) { + return cabi.Load(path) + } + ``` +- [ ] 3.3 实现 `cabiPlugin` 适配器(实现 `sdk.Plugin` 接口): + - `Name()` → 从 manifest 读取 + - `Start(sdk)` → 核心创建 PluginSDK 实例传入 C ABI + - `Stop()` → 调用 `stop_plugin` +- [ ] 3.4 移除 Go `plugin.Open` / `Lookup` 代码路径(仅影响外部插件加载) +- [ ] 3.5 动态插件结果验证:加载 / 调用工具 / 卸载全流程测试 + +--- + +## 阶段四:SDK 侧 C ABI dispatch + +**位置**:`homeagent-sdk/sdk/plugin.go` + 新增 `sdk/cabi.go` + +- [ ] 4.1 创建 `sdk/cabi.go` + - 定义 C ABI dispatch 结构体和客户端 + - 序列化/反序列化辅助函数 + - 回调注册表(handler_id → handler 映射) +- [ ] 4.2 修改 `PluginSDK` 结构,移除所有 Go 接口引用,改为 C ABI dispatch: + ```go + type PluginSDK struct { + abi *CABI + } + + func (s *PluginSDK) RegisterTool(name string, def ToolDef, handler ToolHandler) error { + // register handler in callback table → get handler_id + // marshal(def) → call("register_tool", name, def_json, handler_id) → unmarshal result + } + ``` +- [ ] 4.3 入口函数导出: + ```go + //export plugin_init + func plugin_init() *C.HomeAgentCABI { + return &C.HomeAgentCABI{...} + } + ``` +- [ ] 4.4 构建约束: + - `//go:build cgo` — 所有调用 cgo 的代码 + - plugin 入口文件 `main.go` 去掉 `!windows` 约束 + +--- + +## 阶段五:plugindev 工具链适配 + +**位置**:`homeagent-sdk/tools/plugindev/` + +- [ ] 5.1 `cmd_build.go` — Linux/macOS 默认 `-buildmode=c-shared`: + ```go + // 不再有 -buildmode=plugin 选项 + // 默认 target=linux/amd64 → -buildmode=c-shared → plugin.so + C ABI bridge + // Windows → -buildmode=c-shared → plugin.dll + C ABI bridge + ``` +- [ ] 5.2 `cmd_init.go` — 生成的 `plg.json` 不再包含 `abi` 字段(统一 C ABI) +- [ ] 5.3 `templates.go` — 移除 `tmplBridge`(Windows 专用)与 `tmplCABIBridge` 合并为统一桥 +- [ ] 5.4 移除现有的 `//go:build !windows || !cgo` / `//go:build windows && cgo` 分支 + +--- + +## 阶段六:示例插件迁移 + +- [ ] 6.1 逐个验证所有 example 插件在 C ABI 模式下编译通过 +- [ ] 6.2 部署测试:编译 → 安装 → 加载 → 功能验证 +- [ ] 6.3 压力测试:反复加载/卸载 / 并发工具调用 + +--- + +## 阶段七:文档 + +- [ ] 7.1 更新 `homeagent-sdk/README.md` — 构建说明 +- [ ] 7.2 更新核心 `docs/zh/PLUGIN_DEV.md` 和 `docs/en/PLUGIN_DEV.md` +- [ ] 7.3 更新核心 `docs/zh/ARCHITECTURE.md` 和 `docs/en/ARCHITECTURE.md` +- [ ] 7.4 移除所有关于 Go plugin 的文档描述 + +--- + +## 向后兼容策略 + +因零存量,无需兼容旧格式。C ABI 版本号仅用于核心和插件间的接口协商。 + +```c +typedef struct { + int version; // ABI 版本号 + int version_min; // 兼容的最低版本号 + // ... 函数指针表 +} HomeAgentCABI; +``` + +加载时: +- 核心 `version >= plugin.version_min` → 加载 +- 核心 `version < plugin.version_min` → 拒绝加载,报明确错误信息 + +--- + +## 风险与权衡 + +| 风险 | 缓解 | +|------|------| +| C ABI 序列化开销(JSON 编解码) | 非性能关键路径,可接受;后期可切 MessagePack | +| cgo 调用开销(~1-2µs/次) | 相对于 LLM 调用(秒级)可忽略 | +| 回调桥接(ToolDef.Handler 从插件侧回调核心) | handler ID 表 + goroutine 桥接 |