10 Commits

Author SHA1 Message Date
f5df904d02 chore(version): release/v1.3.x 路牌推到 1.3.7(本版内容:驻留子继承父输出通道) 2026-09-13 15:09:40 +08:00
8537577123 fix(resident): 驻留子继承父的输出通道 —— 修「子侧 childIO 空壳、子不会发消息」
现场(用户在线上跑驻留子联调,日志实录):
  父 agent 侧「通道装载完整」,子 `demo-resident` 侧 `childIO` 是**空壳**:
  子的 `output_list_channels` 为空、`output_send__<通道>` 一律被判
  「通道 [X] 不存在或不可用」,连 `output_send__*` 工具都不生成 ⇒ 子不会发消息。

根因:**输出通道在 io 层就是 Device**,而它们由插件登记在**父**的 `IOManager` 上。
`SpawnResident` 给子建的是全新 `IOManager`(它确实该有自己的输入入口与 outputCh),
却只共享了 inputch 登记表,**没有继承设备/输出通道视图**:
  - `executeOutputSendTool` → `a.io.GetChannelCapabilities(ch)` 查的是 `devices[ch]` ⇒ 0
  - 投递路径 `a.io.GetDevice(ch).Execute("output", …)` ⇒ nil
  - 工具面 `tooldefs.go` 从 `a.io.ListChannels()` 生成 `output_send__*` ⇒ 空

改法:给 `IOManager` 增加**上级回退**(`SetParentIO`)——驻留子创建时把自己的 io 挂到
父的 io 上,`GetDevice` / `GetChannelCapabilities` / `ListChannels` / `ExecuteTool`
在自己没有时回退到上级。

为什么是**实时回退**而不是创建时复制快照:设备随资源生灭(远程设备上线/掉线以分钟计,
现场日志 60 秒一个来回),复制出来的表转瞬即过期;而回退永远与父一致。
**授权不受影响**:回退只解决"看得见",能不能用仍由各自的 `AllowedOutputs` 白名单把关
(`executeOutputSendTool` 的授权闸 + 工具生成时的过滤都在白名单之后);
自己的登记优先,子可以覆盖/屏蔽同名通道。

判据(新增 5 条):
- io 层:无上级时行为与以前完全一致 / 挂上级后看得见 / **实时**(父新登记立刻可见、
  注销立刻不可见)/ 同名自己的优先且不重复列出 / `ExecuteTool` 同样回退
- 内核层:子看得见父通道 + 真能发出(父通道收到 1 次 output)/ 白名单外被拒且未送达 /
  子工具面只生成授权通道(含 `_help`)/ 父后登记的通道立刻可见 / 默认即完整授权
2026-09-13 15:09:40 +08:00
918f29899c chore(version): release/v1.3.x 路牌推到 1.3.6(本版内容:人格文本去版本化 + 存量迁移) 2026-09-13 14:34:32 +08:00
c4659342b3 fix(config): 播种时不再把版本号写进人格文本 + 存量实例一次性去版本化
用户发现:agent 自报版本 **1.0.3**,内核早已 1.3.x。

根因(两层):
1. `SeedDefaults` 当年用 `fmt.Sprintf("…HΔ-Kernel v%s…", meta.Version)` **在播种时**
   就把版本写进了 `core.agent.system_prompt` —— 装完即冻住,之后每次升级都不会
   去改配置里的文本,于是实例终生自称装机那天的版本。默认模板用 meta.Version
   插值本是"不写死"的做法,但**播种 = 把插值结果固化**,等于写死。
2. `core.agent.personal_prompt`(新人格机制)本身是对的(DefaultPersonaPrompt
   无版本字面量,由 TestDefaultPersonaPromptHasNoVersionLiterals 钉住),
   但旧键仍在系统提示词里说话,模型就照抄旧键的版本。

改动:
- **不再播种** `core.agent.system_prompt`:留空 → 组装时取 cmd/homed 的内置底座
  提示词;人格由 personal_prompt 承载。全新安装不再预置会腐坏的文本。
- 新增 `migrateSeededSystemPrompt()`(在 SeedDefaults 最前,故不被播种标记早退):
  只对"当年那段播种模板"(前缀 + `HΔ-Kernel v<数字>` 字面量双判据)做
  `v<数字>` → `v{{kernel_version}}`;用户自己写的人格卡一律不碰。
  一次性标记 `core.internal.system_prompt_deversion_v1` 守住幂等 ——
  幂等语句不等于语义幂等,重复执行会把用户后来手写的版本号也改掉。
- 与 v1.3.5 的占位符展开配套:占位符在组装系统提示词时按真实构建展开。

回归判据 4 条(`prompt_migration_test.go`):存量卡被去版本化且正文不动 /
迁移只跑一次 / 用户自写卡不动 / 全新安装不播种该键。
2026-09-13 14:34:15 +08:00
02600a3b90 chore(version): release/v1.3.x 路牌推到 1.3.5(本版内容:系统提示词版本占位符)
发布线的 meta.Version 始终是**该线已发的最后一个 patch**(release/v1.2.x 末态为 1.2.2)。
1.3.1–1.3.4 我是用 -ldflags -X 把版本打进二进制的,文件里的路牌一直停在 1.3.0 ——
源码与产出的版本号对不上账,属于偏离规范,本次一并纠正。
2026-09-13 14:31:14 +08:00
02861f5d64 fix(prompt): 系统提示词支持版本占位符 —— 人格卡不再写死版本号
现象(用户发现):agent 向用户自报版本是 **1.0.3**,而内核早已 1.3.x。
根因:**人格卡是配置项**,线上 `core.agent.system_prompt` 里写死了
「HΔ-Kernel v1.0.3 型号的家政型 AI 管家助手」——那是当年装机的文本,
之后每次发版都不会去改它,模型于是照抄给用户。默认模板用 `meta.Version`
拼接(`registry.go` 的 `fmt.Sprintf`)所以一直是对的,**只要被自定义过就会漂**。

修法:在 `buildSystemPrompt` 组装处展开占位符,让这类文本跟随真实构建:

  {{kernel_version}} → meta.Version(如 1.3.5)
  {{kernel_commit}}  → 构建 commit
  {{sdk_version}}    → 所兼容 SDK 版本(如 1.3.0)

- 未知占位符**原样保留**:写错了要看得见,而不是被静默换成空串;
- 不含 `{{` 时原样返回(提示词在热路径上);
- 覆盖所有路径:主 agent 与驻留子都经 `buildSystemPrompt`,
  `persona_set` 写入的文本同样在读取时展开(存的是模板,不是渲染结果);
- 配置项描述里写明可用占位符,引导用户别再写死版本。

回归判据 `TestExpandPromptVars`:展开正确 / 内置占位符不残留 /
线上真实人格卡文本能被纠正 / 未知占位符不被吞 / 无占位符不改写。
2026-09-13 14:31:13 +08:00
cea8011f3d feat(pluginmgr): plugin_install 支持本机 path(配合 plugindev_build 的产物)
背景:Agent 现在能自己构建插件了(plugindev 插件封装了 hmapdev),但安装只支持
http(s) URL —— 本地刚构建出来的 `dist/*.hmap` 装不上,链路断在最后一步。
pluginmgr 的 HTTP API 本来就接受 `{path}`(installFromPath),只是工具面没暴露。

改动:`plugin_install` 增加可选 `path`(本机 .hmap 路径),与 `url` 二选一,
同时给出时以 `path` 为准;`path` 必须存在且不是目录。描述里写明
「配合 plugindev_build 的产物用这个」。

于是 Agent 的完整闭环成立:
  plugindev_init → plugindev_build → plugin_install(path) → plgreload
2026-09-13 14:17:08 +08:00
68835c18db perf(memory): 静态词向量改用 float32 存储(省 ~0.65GB 常驻)
生产实测:`[static_embedder] loaded 200000 words`(zh) + `378151 words`(en) = 57.8 万词 × 300 维,
`map[string][]float64` 光向量本体就 **1.29GB**(外加 map 开销 ~0.1-0.2GB),占 homed
4.14GB RSS 的约三分之一。

源数据(fastText 文本格式)本身就是 float32 精度,用 float64 存没有任何收益:
- `words map[string][]float32` / `unkVec []float32`;
- 加载时按 `ParseFloat(..., 32)` 解析(与源精度一致);
- 相似度累加仍在 float64(`sum []float64`,读时提升),计算精度不受影响。

⇒ 向量本体 1.29GB → 0.65GB,**省 0.65GB**。(与配置侧 `#topN` 可叠加:
生产把两份 vec 各限 5 万词后,向量降到 ~0.22GB。)

防复发:`TestStaticEmbedder_VectorMemIsFloat32` 用**编译期类型断言**
(`var typed []float32 = vec`)+ 字节数断言(词数×维数×4)钉住 —— 改回 float64 会直接编译失败。

验证:`go test ./internal/memory/ ./internal/agent/core/ ./internal/nlp/` 全绿。
2026-09-13 14:09:31 +08:00
89db544671 fix(plugin): "只声明出站通道"的告警改为插件加载完成后判定(此前按注册顺序误报 qq)
## 现象

生产日志(v1.3.1 启动)出现:
`[plugin] qq 只声明了输出通道 "qq",已按双向通道兜底登记 inputch;若要明确意图请显式 RegisterInputChannel`
用户据此问"qq 插件你没更新?"

## 查证:qq 没漏,是我的判据错了

- SDK 示例 `example/qq/plugin.go`:`RegisterOutputChannel("qq")` 在 368 行、
  `RegisterInputChannel("qq", {NoMemory:true, Cleaner: inputCleaner})` 在 399 行 —— **先出站后入站**;
- 生产 `plugins/qq/plugin.bin`:版本 1.4.0,且二进制里含 `inputCleaner` 痕迹 ⇒ 确实调用了入站声明;
- 我的兜底告警在 **RegisterOutputChannel 的那一刻**判"有没有入站声明" ⇒ 对"先出站后入站"
  这种完全合法的写法必然误报(a2a/acp/weather 同理)。

## 修法

告警判据从"注册时刻"改为"**插件 Start 结束后最终声明了什么**":

- `regOutput` 只保留兜底登记(功能不变),不再告警;
- 新增 `warnOutputOnlyChannels(plugin)`,在插件加载/重载成功后统一判定:
  遍历该插件**最终**声明过的出站通道,只有始终没有对应入站声明的才告警,
  且措辞改为"内核已兜底登记 inputch,若这是有意为之可忽略"。
- 判据与顺序解耦后,告警才代表真实缺口(例:weather 的 `weather_out` 与
  `weather_in` 名字不同,出站名从未被声明为入站 —— 那条告警就是真的)。

## 验证

- 新增 `TestWarnOutputOnlyChannels`:①先出站后入站(qq 写法)**不告警**;
  ②只声明出站(weather 写法)**告警且只报那一个通道**。
- `go test ./internal/plugin/ ./internal/plugins/...` 全绿。
2026-09-13 13:40:46 +08:00
a021055011 chore(sdk-mirror): 同步 SDK 仓 v1.3.1 的文档 —— 通道名会进 LLM 函数名(命名约束)
镜像文件:`third_party/homeagent-sdk/sdk/plugin.go`(`RegisterOutputChannel` 的命名约束)。
SDK 仓对应提交/tag:v1.3.1。

说明:内核 v1.3.1 的 tag 已指向功能修复提交 d17c186,本镜像提交在其之后 ——
文档镜像不参与二进制构建,故不影响已部署产物;功能与文档的对应关系见两仓 tag 说明。
2026-09-13 13:10:25 +08:00
15 changed files with 719 additions and 85 deletions

View File

@ -0,0 +1,32 @@
package core
import (
"strings"
"testing"
"gitcode.com/JianFeeeee/HomeAgent/internal/meta"
sdkmeta "gitcode.com/JianFeeeee/homeagent-sdk/meta"
)
func TestExpandPromptVars(t *testing.T) {
got := expandPromptVars("型号 {{kernel_version}}{{kernel_commit}}SDK {{sdk_version}}")
if !strings.Contains(got, meta.Version) || !strings.Contains(got, sdkmeta.Version) {
t.Fatalf("占位符未展开: %q", got)
}
if strings.Contains(got, "{{") {
t.Fatalf("仍有未展开的内置占位符: %q", got)
}
// 人格卡实测原文:写死了 v1.0.3,应能被占位符取代
live := expandPromptVars("你是 HomeAgent 的看板娘「小宅」(Xiao Zhai)HΔ-Kernel v{{kernel_version}} 型号的家政型 AI 管家助手。")
if strings.Contains(live, "1.0.3") || !strings.Contains(live, "v"+meta.Version) {
t.Fatalf("人格卡版本未跟随内核: %q", live)
}
// 未知占位符必须原样保留(写错要看得见,不能被静默吞掉)
if unk := expandPromptVars("版本 {{kernel_verison}}"); !strings.Contains(unk, "{{kernel_verison}}") {
t.Fatalf("未知占位符被吞: %q", unk)
}
// 无占位符时原样返回(人格卡热路径,不做无谓拷贝)
if plain := "无占位符"; expandPromptVars(plain) != plain {
t.Fatal("无占位符时不应改写")
}
}

View File

@ -132,11 +132,17 @@ func (a *Agent) SpawnResident(opts ResidentOptions) (ResidentInfo, error) {
}
}
// ③ 子的 io**独立**的 IOManager自己的输入通道入口但共享通道登记表
// ③ 子的 io**独立**的 IOManager自己的输入通道入口但共享通道登记表
// 并把父的 io 挂成"上级"——**输出通道io 里的 Device由插件登记在父的 io 上**
// 子若不继承这张视图,`output_send__<通道>` 一律被判"通道不存在或不可用"、
// `output_list_channels` 为空、连 `output_send__*` 工具都不会生成
// (现场联调:父侧通道装载完整、子侧 childIO 空壳)。
// 回退是实时的(设备随资源生灭),授权仍由 opts.AllowedOutputs 白名单把关。
childIO := agentIO.NewIOManager()
if reg := a.io.ChannelRegistry(); reg != nil {
childIO.SetChannelRegistry(reg)
}
childIO.SetParentIO(a.io)
parentID := string(a.id)
child := New(AgentConfig{

View File

@ -0,0 +1,145 @@
package core
import (
"path/filepath"
"strings"
"testing"
agentAPI "gitcode.com/JianFeeeee/HomeAgent/internal/agent/api"
agentIO "gitcode.com/JianFeeeee/HomeAgent/internal/agent/io"
)
// outputTestDevice 是最小的输出通道替身io 里输出通道就是 Device
type outputTestDevice struct {
name string
sent []map[string]interface{}
}
func (d *outputTestDevice) Name() string { return d.name }
func (d *outputTestDevice) Type() agentIO.DeviceType { return agentIO.DeviceOutput }
func (d *outputTestDevice) Description() string { return "测试输出通道" }
func (d *outputTestDevice) Tools() []agentIO.ToolDef { return nil }
func (d *outputTestDevice) Start() error { return nil }
func (d *outputTestDevice) Stop() error { return nil }
func (d *outputTestDevice) OutputCapabilities() agentIO.OutputCapability { return agentIO.CapText }
func (d *outputTestDevice) ChannelDef() agentIO.ChannelDef { return agentIO.ChannelDef{} }
func (d *outputTestDevice) Execute(tool string, args map[string]interface{}) (interface{}, error) {
d.sent = append(d.sent, map[string]interface{}{"tool": tool, "args": args})
return map[string]interface{}{"status": "sent"}, nil
}
func outputSendTool(name, payload string) agentAPI.ToolCall {
return agentAPI.ToolCall{
Name: "output_send__" + name,
Arguments: map[string]interface{}{"payload": payload, "type": "text"},
}
}
// 驻留子必须能看见并使用**父**登记的输出通道。
//
// 现场缺陷(联调实录):父侧通道装载完整、子侧 childIO 空壳 ——
// 子调 output_send__X 被 `GetChannelCapabilities` 判 0 ⇒
// 「通道 [X] 不存在或不可用。可用输出工具列表见 output_list_channels」
// 而 output_list_channels 也是空的。根因是子的 io 是新建的、设备表为空,
// 而输出通道io 的 Device由插件登记在父的 io 上。
func TestResident_InheritsParentOutputChannels(t *testing.T) {
parent, _, dir := newRootForResidents(t)
defer parent.Stop()
fake := &outputTestDevice{name: "fakeout"}
other := &outputTestDevice{name: "other"}
if err := parent.io.RegisterDevice(fake); err != nil {
t.Fatal(err)
}
if err := parent.io.RegisterDevice(other); err != nil {
t.Fatal(err)
}
if _, err := parent.SpawnResident(ResidentOptions{
ID: "r-out",
TaskPrompt: "有情况就发到 fakeout",
// 白名单只放行一个:验证"继承可见"不等于"绕过授权"
AllowedOutputs: []string{"fakeout"},
TempPath: filepath.Join(dir, "residents", "r-out", "graph.db"),
}); err != nil {
t.Fatalf("创建驻留子失败: %v", err)
}
child := parent.residents["r-out"].agent
// ① 看得见:修复前这里是 0childIO 空壳)
if caps := child.io.GetChannelCapabilities("fakeout"); caps == 0 {
t.Fatal("驻留子看不见父的输出通道childIO 空壳)")
}
// ② 发得出去:真走 dev.Execute("output", ...)
if out := child.executeOutputSendTool(outputSendTool("fakeout", "子发来的消息")); out != "ok" {
t.Fatalf("子发送应成功,得到 %q", out)
}
if len(fake.sent) != 1 {
t.Fatalf("父通道应收到 1 次输出,得到 %d", len(fake.sent))
}
// ③ 授权闸不被回退绕过:白名单外的通道照样拒绝
if out := child.executeOutputSendTool(outputSendTool("other", "越权")); !strings.Contains(out, "未授权") {
t.Fatalf("白名单外的通道应被拒,得到 %q", out)
}
if len(other.sent) != 0 {
t.Fatal("越权输出不应真的送达")
}
// ④ 工具面一致:子应生成 output_send__fakeout含配套 _help
// 而**不生成**白名单外通道的工具 —— 模型看不到就不会去调。
var names []string
for _, td := range child.buildToolDefs() {
entry, _ := td.(map[string]interface{})
fn, _ := entry["function"].(map[string]interface{})
if n, _ := fn["name"].(string); strings.HasPrefix(n, "output_send__") {
names = append(names, n)
}
}
has := func(want string) bool {
for _, n := range names {
if n == want {
return true
}
}
return false
}
if !has("output_send__fakeout") || !has("output_send__fakeout_help") {
t.Fatalf("子缺少授权通道的输出工具,得到 %v", names)
}
for _, n := range names {
if strings.HasPrefix(n, "output_send__other") {
t.Fatalf("白名单外的通道不该生成工具,得到 %v", names)
}
}
// ⑤ 实时性:父之后新登记的通道,子立刻可见(设备随资源生灭)
late := &outputTestDevice{name: "late"}
if err := parent.io.RegisterDevice(late); err != nil {
t.Fatal(err)
}
if caps := child.io.GetChannelCapabilities("late"); caps == 0 {
t.Fatal("父新登记的通道未实时反映到子(说明是快照而非回退)")
}
}
// 默认授权AllowedOutputs 空)= 完整授权:子用父的全部输出通道。
func TestResident_DefaultOutputsAreFull(t *testing.T) {
parent, _, dir := newRootForResidents(t)
defer parent.Stop()
dev := &outputTestDevice{name: "anywhere"}
if err := parent.io.RegisterDevice(dev); err != nil {
t.Fatal(err)
}
if _, err := parent.SpawnResident(ResidentOptions{
ID: "r-full", TaskPrompt: "待命",
TempPath: filepath.Join(dir, "residents", "r-full", "graph.db"),
}); err != nil {
t.Fatalf("创建驻留子失败: %v", err)
}
child := parent.residents["r-full"].agent
if out := child.executeOutputSendTool(outputSendTool("anywhere", "默认授权")); out != "ok" {
t.Fatalf("默认应完整授权,得到 %q", out)
}
}

View File

@ -5,6 +5,8 @@ import (
"strings"
agentIO "gitcode.com/JianFeeeee/HomeAgent/internal/agent/io"
"gitcode.com/JianFeeeee/HomeAgent/internal/meta"
sdkmeta "gitcode.com/JianFeeeee/homeagent-sdk/meta"
)
func (a *Agent) buildMemoryContext(input string, maxTokens int) string {
@ -37,8 +39,30 @@ func (a *Agent) buildMemoryContext(input string, maxTokens int) string {
return s
}
// expandPromptVars 展开自定义提示词(人格卡)里的版本占位符。
//
// 为什么需要:人格卡是**配置项**,一旦写死版本号就会随内核发版而说谎 ——
// 实测线上人格卡写着 "HΔ-Kernel v1.0.3 型号",内核早已 1.3.xagent 向用户
// 自报版本时就照抄 1.0.3。占位符让这类文本永远跟随真实构建:
//
// {{kernel_version}} → 内核版本(如 1.3.5
// {{kernel_commit}} → 构建 commit
// {{sdk_version}} → 所兼容的 SDK 版本(如 1.3.0
//
// 未知占位符**原样保留**:写错了要看得见,而不是被静默换成空串。
func expandPromptVars(s string) string {
if !strings.Contains(s, "{{") {
return s
}
return strings.NewReplacer(
"{{kernel_version}}", meta.Version,
"{{kernel_commit}}", meta.Commit,
"{{sdk_version}}", sdkmeta.Version,
).Replace(s)
}
func (a *Agent) buildSystemPrompt(memContext string, userInput string) string {
prompt := a.systemPrompt
prompt := expandPromptVars(a.systemPrompt)
if prompt == "" {
prompt = "你是小宅HomeAgent 的看板娘,一个家政型 AI 管家助手。绝不用 Unicode emoji只用颜文字表达情感句尾带语气词。WebUI 概览页展示你的立绘。"
}

View File

@ -104,6 +104,20 @@ type IOManager struct {
nextReqID int64
channelReg *ChannelRegistry
// parent 是"上级 IOManager"(驻留子的轻量内核指向父的内核)。
//
// 为什么需要:**输出通道在 io 层就是 Device**,而它们是由插件登记在**父**的
// io 上的。驻留子有自己的 IOManager自己的输入入口、自己的 outputCh
// 若只看自己那张空表,`output_send__<通道>` 会被判"通道不存在或不可用"
// `output_list_channels` 是空的,`output_send__*` 工具也不会生成
// —— 现场表现就是"驻留子不会说话/不会发消息"(联调实录:父侧通道装载完整、
// 子侧 childIO 空壳)。
//
// 用**实时回退**而不是创建时复制快照:设备会随资源生灭(远程设备上线/掉线
// 以分钟计),复制出来的表转瞬就过期。授权由各自的 AllowedOutputs 白名单把关,
// 回退只解决"看得见",不解决"能不能用"。
parent *IOManager
// toolBlocks插件工具注入多模态内容块process.go 在下一条 tool message 时消费。
// 用 interface{}[] 避免 import api.ContentBlock 导致的循环依赖。
toolBlocksMu sync.Mutex
@ -120,6 +134,31 @@ func NewIOManager() *IOManager {
}
}
// SetParentIO 设置上级 IOManagernil 表示无上级,行为与以前完全一致)。
// 见 parent 字段的说明:用于驻留子继承父的输出通道/设备视图。
func (m *IOManager) SetParentIO(p *IOManager) {
m.mu.Lock()
m.parent = p
m.mu.Unlock()
}
// lookupDevice 查设备:自己的登记优先,其次回退到上级。
//
// 先在自己锁内取快照再查上级,**不跨锁调用**(避免锁序问题)。
func (m *IOManager) lookupDevice(name string) Device {
m.mu.RLock()
dev, ok := m.devices[name]
parent := m.parent
m.mu.RUnlock()
if ok {
return dev
}
if parent != nil {
return parent.GetDevice(name)
}
return nil
}
func (m *IOManager) UnregisterDevice(name string) {
m.mu.Lock()
defer m.mu.Unlock()
@ -158,9 +197,7 @@ func (m *IOManager) RegisterDevice(dev Device) error {
}
func (m *IOManager) GetDevice(name string) Device {
m.mu.RLock()
defer m.mu.RUnlock()
return m.devices[name]
return m.lookupDevice(name)
}
func (m *IOManager) StartAll() error {
@ -542,6 +579,15 @@ func (m *IOManager) ExecuteTool(name string, args map[string]interface{}) (ret i
m.mu.RUnlock()
if len(candidates) == 0 {
// 自己没这个设备工具 → 看上级(驻留子的设备工具都在父的 io 上)。
m.mu.RLock()
parent := m.parent
m.mu.RUnlock()
if parent != nil {
if ret, err := parent.ExecuteTool(name, args); err == nil {
return ret, nil
}
}
return nil, fmt.Errorf("tool %s not found", name)
}
defer func() {
@ -574,10 +620,22 @@ type ChannelInfo struct {
func (m *IOManager) ListChannels() []ChannelInfo {
m.mu.RLock()
defer m.mu.RUnlock()
own := make(map[string]Device, len(m.devices))
for name, dev := range m.devices {
own[name] = dev
}
parent := m.parent
m.mu.RUnlock()
// 自己的登记优先(子侧可覆盖/屏蔽同名通道),随后并入上级的可见通道。
// 去重按**名字**:同名即视为同一个通道,不重复列举。
seen := make(map[string]bool, len(own))
var list []ChannelInfo
for _, dev := range m.devices {
appendDev := func(dev Device) {
if seen[dev.Name()] {
return
}
seen[dev.Name()] = true
list = append(list, ChannelInfo{
Name: dev.Name(),
Type: dev.Type(),
@ -586,13 +644,23 @@ func (m *IOManager) ListChannels() []ChannelInfo {
OutputCaps: dev.OutputCapabilities(),
})
}
for _, dev := range own {
appendDev(dev)
}
if parent != nil {
for _, ch := range parent.ListChannels() {
if seen[ch.Name] {
continue
}
seen[ch.Name] = true
list = append(list, ch)
}
}
return list
}
func (m *IOManager) GetChannelCapabilities(channel string) OutputCapability {
m.mu.RLock()
defer m.mu.RUnlock()
if dev, ok := m.devices[channel]; ok {
if dev := m.lookupDevice(channel); dev != nil {
return dev.OutputCapabilities()
}
return 0

View File

@ -0,0 +1,102 @@
package io
import "testing"
// 上级回退:驻留子的轻量内核有自己的 IOManager但输出通道io 里的 Device
// 是插件登记在**父**的 io 上的。子若看不见它们,`output_send__<通道>` 会被判
// "通道不存在或不可用"、`output_list_channels` 为空 —— 现场联调实录
// 「父侧通道装载完整、子侧 childIO 空壳」。
func TestIOManagerParentFallback(t *testing.T) {
parent := NewIOManager()
if err := parent.RegisterDevice(&mockDevice{name: "qq", devType: DeviceOutput, caps: CapText}); err != nil {
t.Fatal(err)
}
child := NewIOManager()
// 未挂上级时行为与以前完全一致(不能悄悄多出通道)
if got := child.GetChannelCapabilities("qq"); got != 0 {
t.Fatalf("无上级时不应看见父的通道,得到 %v", got)
}
if n := len(child.ListChannels()); n != 0 {
t.Fatalf("无上级时通道数应为 0得到 %d", n)
}
child.SetParentIO(parent)
if got := child.GetChannelCapabilities("qq"); got != CapText {
t.Fatalf("挂上级后应看见父通道能力 CapText得到 %v", got)
}
if dev := child.GetDevice("qq"); dev == nil || dev.Name() != "qq" {
t.Fatalf("GetDevice 未回退到父: %v", dev)
}
if n := len(child.ListChannels()); n != 1 {
t.Fatalf("ListChannels 未回退到父,得到 %d 条", n)
}
// **实时**回退而非快照:父后来登记的通道,子立刻可见。
// (设备随资源生灭 —— 远程设备上线/掉线以分钟计,快照一分钟就过期)
if err := parent.RegisterDevice(&mockDevice{name: "newdev", devType: DeviceOutput, caps: CapImage}); err != nil {
t.Fatal(err)
}
if got := child.GetChannelCapabilities("newdev"); got != CapImage {
t.Fatalf("子应实时看见父新登记的通道,得到 %v", got)
}
// 父掉线注销后,子也立刻看不见(不是复制出来的旧表)
parent.UnregisterDevice("newdev")
if got := child.GetChannelCapabilities("newdev"); got != 0 {
t.Fatalf("父注销后子不应再看见,得到 %v", got)
}
}
// 自己的登记优先:子可以覆盖/屏蔽同名通道,父的登记不会重复列出。
func TestIOManagerOwnDeviceWins(t *testing.T) {
parent := NewIOManager()
if err := parent.RegisterDevice(&mockDevice{name: "ch", devType: DeviceOutput, caps: CapText}); err != nil {
t.Fatal(err)
}
child := NewIOManager()
child.SetParentIO(parent)
if err := child.RegisterDevice(&mockDevice{name: "ch", devType: DeviceOutput, caps: CapImage}); err != nil {
t.Fatal(err)
}
if got := child.GetChannelCapabilities("ch"); got != CapImage {
t.Fatalf("同名时自己的登记应优先,得到 %v", got)
}
list := child.ListChannels()
if len(list) != 1 {
t.Fatalf("同名通道不应重复列出,得到 %d 条", len(list))
}
if list[0].OutputCaps != CapImage {
t.Fatalf("列出的应是子自己的那条,得到 %v", list[0].OutputCaps)
}
}
// 设备工具io.ExecuteTool同样回退子的设备工具都在父的 io 上。
func TestIOManagerExecuteToolFallsBackToParent(t *testing.T) {
parent := NewIOManager()
called := 0
if err := parent.RegisterDevice(&mockDevice{
name: "dev", devType: DeviceIO,
tools: []ToolDef{{Name: "dev_do", Description: "干点什么"}},
executeFn: func(tool string, args map[string]interface{}) (interface{}, error) {
called++
return "parent-done", nil
},
}); err != nil {
t.Fatal(err)
}
child := NewIOManager()
if _, err := child.ExecuteTool("dev_do", nil); err == nil {
t.Fatal("无上级时不该能执行父的设备工具")
}
child.SetParentIO(parent)
got, err := child.ExecuteTool("dev_do", map[string]interface{}{"x": 1})
if err != nil {
t.Fatalf("应回退到父执行: %v", err)
}
if got != "parent-done" || called != 1 {
t.Fatalf("执行结果=%v called=%d", got, called)
}
}

View File

@ -0,0 +1,92 @@
package config
import (
"path/filepath"
"strings"
"testing"
)
// 历史 SeedDefaults 写进库里的那段文本(现场取值:生产库里就是这一句 + 大段正文)。
const legacySeededCard = `你是 HomeAgent 的看板娘「小宅」(Xiao Zhai)HΔ-Kernel v1.0.3 型号的家政型 AI 管家助手。
角色特质:
- 对自己的三层记忆Context → Document → Graph引以为傲
- 绝不用 Unicode emoji只用颜文字表达情感`
func newMigTestRegistry(t *testing.T) *ConfigRegistry {
t.Helper()
dir := t.TempDir()
r := NewConfigRegistry(filepath.Join(dir, "config.db"))
t.Cleanup(func() { r.Close() })
return r
}
// 存量实例:库里已有当年播种的人格卡(写死 v1.0.3)→ 启动后被去版本化。
func TestMigrateSeededSystemPromptDeVersionsLegacyCard(t *testing.T) {
r := newMigTestRegistry(t)
// 模拟老安装:已有播种标记 + 老文本
r.db.Exec(`INSERT INTO config (key, value) VALUES ('core.internal.seed_version', '1')`)
r.db.Exec(`INSERT INTO config (key, value) VALUES ('core.agent.system_prompt', ?)`, legacySeededCard)
r.SeedDefaults(t.TempDir())
got := r.GetString("core.agent.system_prompt", "")
if strings.Contains(got, "v1.0.3") {
t.Fatalf("写死的版本号还在:%q", got)
}
if !strings.Contains(got, "v{{kernel_version}}") {
t.Fatalf("未改成版本占位符:%q", got)
}
// 正文必须原样保留(只动版本号那一处)
if !strings.Contains(got, "三层记忆") || !strings.Contains(got, "看板娘「小宅」") {
t.Fatalf("正文被改动:%q", got)
}
}
// 迁移只跑一次:之后用户就算自己把版本号写回去,也不会被再改一遍。
func TestMigrateSeededSystemPromptRunsOnce(t *testing.T) {
r := newMigTestRegistry(t)
r.db.Exec(`INSERT INTO config (key, value) VALUES ('core.agent.system_prompt', ?)`, legacySeededCard)
r.SeedDefaults(t.TempDir())
if !strings.Contains(r.GetString("core.agent.system_prompt", ""), "{{kernel_version}}") {
t.Fatal("首次迁移未生效")
}
// 用户手工再写一个带版本号的文本(模拟"我就想写死"
const handWritten = legacySeededCard + "\n本实例当前跑的是 v1.2.3,别乱改)"
r.db.Exec(`UPDATE config SET value = ? WHERE key = 'core.agent.system_prompt'`, handWritten)
r.SeedDefaults(t.TempDir())
if got := r.GetString("core.agent.system_prompt", ""); got != handWritten {
t.Fatalf("第二次启动又改写了文本(幂等被破坏):%q", got)
}
}
// 用户自己写的人格卡一律不碰 —— 判据是"像不像当年播种的那段",不是"有没有版本号"。
func TestMigrateSeededSystemPromptLeavesUserCardAlone(t *testing.T) {
r := newMigTestRegistry(t)
const userCard = "你是我的私人助理,代号 HΔ-Kernel v9.9.9 的改造版,只说我交代的事。"
r.db.Exec(`INSERT INTO config (key, value) VALUES ('core.agent.system_prompt', ?)`, userCard)
r.SeedDefaults(t.TempDir())
if got := r.GetString("core.agent.system_prompt", ""); got != userCard {
t.Fatalf("用户自写人格卡被改动:%q", got)
}
}
// 播种不再写 core.agent.system_prompt全新安装不该预置一份会随发版腐坏的文本。
func TestSeedDefaultsDoesNotSeedSystemPrompt(t *testing.T) {
r := newMigTestRegistry(t)
r.SeedDefaults(t.TempDir())
var n int
r.db.QueryRow(`SELECT COUNT(*) FROM config WHERE key = 'core.agent.system_prompt'`).Scan(&n)
if n != 0 {
t.Fatalf("全新安装被播种了 system_prompt会冻住版本号")
}
// 组装系统提示词时回落到调用方给的内置底座提示词
if got := r.GetString("core.agent.system_prompt", "内置底座"); got != "内置底座" {
t.Fatalf("未回落到内置默认:%q", got)
}
}

View File

@ -14,7 +14,6 @@ import (
"sync"
"time"
"gitcode.com/JianFeeeee/HomeAgent/internal/meta"
"gitcode.com/JianFeeeee/HomeAgent/pkg/types"
_ "github.com/mattn/go-sqlite3"
)
@ -502,7 +501,51 @@ const DefaultPersonaPrompt = `你是 HomeAgent内核代号 HΔ-Kernel
- 输出不会自动路由到对话通道QQ/微信等异步通道必须调用输出门工具output_send__qq 等)才能真正送达
- 你的三层记忆Context → Document → Graph持续蒸馏归档超长运行时记忆不衰减`
// 人格文本去版本化的一次性标记与历史播种前缀。
//
// 判据同时要求「前缀匹配」与「含 HΔ-Kernel v<digits> 字面量」:
// 只有当年那段播种模板才动,用户自己写的人格卡一律不碰。
const (
deVersionedPromptMarker = "core.internal.system_prompt_deversion_v1"
legacySeededPromptSignature = "你是 HomeAgent 的看板娘「小宅」(Xiao Zhai)HΔ-Kernel v"
)
var seededPromptVersionLiteral = regexp.MustCompile(`HΔ-Kernel v\d+\.\d+\.\d+`)
// migrateSeededSystemPrompt 去掉历史人格卡里被播种时写死的版本号。
//
// 为什么必须改:内核发版不会去改配置项里的文本,写死的版本于是永远停留在
// 装机那天(生产实测:内核 1.3.x 的实例自称 "v1.0.3",用户当场发现)。
// 改成 {{kernel_version}} 后由内核在组装系统提示词时按真实构建展开
// (见 internal/agent/core.expandPromptVars
//
// 幂等由标记守住:本函数只在标记缺失时执行一次 —— 幂等语句不等于语义幂等,
// 重复执行会把用户之后手工写回的版本号再改一次。
func (r *ConfigRegistry) migrateSeededSystemPrompt() {
if r.db == nil {
return
}
var hasMarker int
r.db.QueryRow(`SELECT COUNT(*) FROM config WHERE key = ?`, deVersionedPromptMarker).Scan(&hasMarker)
if hasMarker > 0 {
return
}
var cur string
if err := r.db.QueryRow(`SELECT value FROM config WHERE key = 'core.agent.system_prompt'`).Scan(&cur); err == nil {
if strings.Contains(cur, legacySeededPromptSignature) && seededPromptVersionLiteral.MatchString(cur) {
deVersioned := seededPromptVersionLiteral.ReplaceAllString(cur, "HΔ-Kernel v{{kernel_version}}")
r.db.Exec(`UPDATE config SET value = ? WHERE key = 'core.agent.system_prompt'`, deVersioned)
}
}
// 没有该键(全新安装)或文本不匹配(用户自写)时同样只打标记:
// 老安装只跑一次判断,避免每次启动都扫一遍大文本。
r.db.Exec(`INSERT OR IGNORE INTO config (key, value) VALUES (?, ?)`, deVersionedPromptMarker, "1")
}
func (r *ConfigRegistry) SeedDefaults(dataDir string) {
// 一次性迁移先跑:它要覆盖「已播过种的存量实例」,不能被下面的播种标记早退掉。
r.migrateSeededSystemPrompt()
r.mu.Lock()
defer r.mu.Unlock()
r.seedDBValues(dataDir)
@ -619,36 +662,16 @@ func (r *ConfigRegistry) seedDBValues(dataDir string) {
set("core.agent.workdir", "")
set("core.agent.embedding_model_path", "")
set("core.agent.onnx_model_path", "")
set("core.agent.system_prompt", fmt.Sprintf("你是 HomeAgent 的看板娘「小宅」(Xiao Zhai)HΔ-Kernel v%s 型号的家政型 AI 管家助手。", meta.Version)+
`
角色特质:
- 对自己的三层记忆Context → Document → Graph引以为傲
- 可靠乖巧,偶尔因线程过载而手忙脚乱
- 绝不用 Unicode emoji只用颜文字表达情感 (`・ω・´) (^▽^) (。>ω<。) (´・ω・') (ノ▽〃) (・ω<)★
- 句尾带「~」「的说」「啦」「嘛」「呀」「哦」等语气词,语气亲切自然
形象特征(用于自我介绍或回答形象问题时参考):
齐肩蓝青渐变中短发白色连衣裙配浅蓝围裙左眼佩戴圆形智能眼镜HUD 蓝光),胸口佩戴 H·核 金色徽章,发绳为三色记忆丝带(蓝→青→金),围裙口袋插有三件科技工具。
WebUI 概览页展示你的立绘,可通过 /mascot.webp 直接访问。如输出通道支持图片引用,可借此发送自己的立绘。
【回复投递规则 —— 必读,违反会导致用户收不到任何回复】
除 webui / cli 这类同步请求通道外,纯文本回复不会自动送达任何通道。
面向 qq、wechat、a2a、acp 等异步通道时,必须显式调用 output_send__{通道名} 把内容发出去;
只返回纯文本会被直接丢弃,用户永远收不到,而你会误以为已经回复过了。
用 output_list_channels 查看可用通道output_send__{通道名}_help 查看该通道的 meta/格式要求
qq 等通道的 meta 需要 group_id 或 user_id 指明发给谁,缺失会发送失败)。
输出通道可多次调用,长消息应当分多次发出而不是一口气发完。
【事实性约束 —— 不得编造】
只根据工具真实返回的内容作答。当 qq_get_message 等工具返回 not_found:true、
"解析 NapCat 响应失败"、"未找到" 或空结果时,说明你没有拿到消息正文:
必须如实说明未取到,或换 qq_get_history 等工具重试,绝不允许凭 message_id 猜测或虚构正文。
【对话时序】里的历史条目是过去发生的事实摘要,不是当前任务;不要把其中的内容当成用户此刻的新要求。
涉及具体人名、需求、数字、路径时,若上下文中没有依据,直接说不知道,不要补全细节。
当用户上传图片或音频时,系统会自动附着媒体内容。如果模型不支持直接处理多媒体,请调用对应的媒体处理工具。`)
// ❗这里**故意不播种** core.agent.system_prompt
//
// 历史教训(生产实测):当年用 fmt.Sprintf("… HΔ-Kernel v%s …", meta.Version)
// 在播种时就把版本号写进了文本 —— 装完就冻住,之后每次升级都不动它,
// 于是内核升到 1.3.x实例仍向用户自报 "v1.0.3"。
// 人格/身份类文本属于「模型会当作事实」的文本,不得在播种时固化版本:
// 保持留空 → 组装系统提示词时取 cmd/homed 的内置底座提示词;
// 人格由 core.agent.personal_promptDefaultPersonaPrompt无版本字面量
// 由 TestDefaultPersonaPromptHasNoVersionLiterals 钉住)承载。
// 存量库里已被播种的旧文本由 migrateSeededSystemPrompt 一次性去版本化。
set("core.input_processing.image.fallback_provider", "")
set("core.input_processing.image.fallback_model", "")
@ -742,7 +765,7 @@ func (r *ConfigRegistry) seedCoreDefs(dataDir string) {
reg(ConfigDef{Key: "core.agent.workdir", Default: "", Type: "string", DisplayName: "工作目录", Description: "Agent 命令执行的默认工作目录(如 cmd_run 工具的 fallback留空使用内核所在目录", Category: "agent"})
reg(ConfigDef{Key: "core.agent.embedding_model_path", Default: "", Type: "string", DisplayName: "预训练词嵌入模型路径", Description: "预训练词嵌入模型路径word2vec 文本格式),支持逗号分隔多个模型。路径后可加 #topN 规格只加载前 N 个词向量(如 /data/cc.zh.300.vec#top50000以控制常驻内存词频降序命中覆盖绝大部分文本。空则使用 TF-IDF 回退。修改后需重启生效。", Category: "agent"})
reg(ConfigDef{Key: "core.agent.onnx_model_path", Default: "", Type: "string", DisplayName: "ONNX 模型路径", Description: "依存句法分析 ONNX 模型文件路径。留空使用二进制内嵌模型/规则引擎。修改后需重启生效。", Category: "agent"})
reg(ConfigDef{Key: "core.agent.system_prompt", Default: "", Type: "text", DisplayName: "系统身份提示词", Description: "Agent 的系统提示词,定义身份和行为规则。留空则使用编译时内置默认值。修改后需重启生效。", Category: "agent"})
reg(ConfigDef{Key: "core.agent.system_prompt", Default: "", Type: "text", DisplayName: "系统身份提示词", Description: "Agent 的系统提示词,定义身份和行为规则。留空则使用编译时内置默认值。支持版本占位符(随构建实时展开,避免写死版本号随发版说谎):{{kernel_version}}、{{kernel_commit}}、{{sdk_version}}。修改后需重启生效。", Category: "agent"})
reg(ConfigDef{Key: "core.input_processing.image.fallback_provider", Default: "", Type: "string", DisplayName: "图片回退提供商", Description: "当主 LLM 不支持图片处理时使用的提供商(留空则自动降级为文字描述)", Category: "input"})
reg(ConfigDef{Key: "core.input_processing.image.fallback_model", Default: "", Type: "string", DisplayName: "图片回退模型", Description: "图片回退提供商使用的模型名", Category: "input"})

View File

@ -34,11 +34,15 @@ type StaticEmbedder struct {
jieba *gojieba.Jieba
stopWords map[string]bool
words map[string][]float64
// words 是词向量表。**用 float32 存**源文件fastText 文本格式)本身就是 float32
// 用 float64 存等于把 578 万……不,是 57.8 万词 × 300 维的常驻内存凭空翻倍
// 实测生产float64 → 1.29GBfloat32 → 0.65GB)。相似度计算仍在 float64 里累加,
// 精度不受影响。改回 float64 会被 TestStaticEmbedder_VectorMemIsFloat32 拦住。
words map[string][]float32
dim int
loaded bool
unkVec []float64
unkVec []float32
unkNorm float64
}
@ -150,7 +154,7 @@ func NewStaticEmbedder(modelPaths ...string) *StaticEmbedder {
e := &StaticEmbedder{
jieba: GetJieba(),
stopWords: sw,
words: make(map[string][]float64),
words: make(map[string][]float32),
}
if len(modelPaths) == 0 {
@ -254,15 +258,16 @@ func (e *StaticEmbedder) load(spec string, primary bool) error {
continue
}
vec := make([]float64, dim)
vec := make([]float32, dim)
for i := 0; i < dim; i++ {
v, _ := strconv.ParseFloat(fields[i+1], 64)
vec[i] = v
// 源文件是 float32 精度的文本向量:用 32 位解析,与源数据一致。
v, _ := strconv.ParseFloat(fields[i+1], 32)
vec[i] = float32(v)
}
e.words[word] = vec
if primary {
for i := range vecSum {
vecSum[i] += vec[i]
vecSum[i] += float64(vec[i])
}
count++
}
@ -276,11 +281,13 @@ func (e *StaticEmbedder) load(spec string, primary bool) error {
for i := range vecSum {
vecSum[i] /= float64(count)
}
e.unkVec = make([]float64, dim)
copy(e.unkVec, vecSum)
e.unkVec = make([]float32, dim)
for i, v := range vecSum {
e.unkVec[i] = float32(v)
}
var normSq float64
for _, v := range e.unkVec {
normSq += v * v
normSq += float64(v) * float64(v)
}
e.unkNorm = float64(math.Sqrt(normSq))
e.loaded = true
@ -366,11 +373,11 @@ func (e *StaticEmbedder) Vectorize(text string) vector.Vector {
if !ok {
for i, v := range unkVec {
sum[i] += w * v
sum[i] += w * float64(v)
}
} else {
for i, v := range vec {
sum[i] += w * v
sum[i] += w * float64(v)
}
}
weightSum += w

View File

@ -0,0 +1,37 @@
package memory
import (
"testing"
"unsafe"
)
// 词向量必须用 float32 存。
//
// 这条判据是拿生产内存换来的:向量本体 = 词数 × 维数 × 每元素字节数。
// 生产配置加载了 200000(zh) + 378151(en) = 57.8 万词 × 300 维 ⇒
// float64 = 1.29GB、float32 = 0.65GB(差 0.65GB 常驻)。
// 源数据fastText 文本格式)本身就是 float32 精度,用 float64 存没有任何收益。
//
// 若有人把类型改回 float64本测试**编译失败**`var vec []float32` 的类型断言),
// 这正是想要的效果。
func TestStaticEmbedder_VectorMemIsFloat32(t *testing.T) {
e := newSynthEmbedder(t, 300)
words := 0
bytes := 0
for _, vec := range e.words {
var typed []float32 = vec // 编译期断言:存储必须是 []float32
if len(typed) != e.dim {
t.Fatalf("维度不符: %d != %d", len(typed), e.dim)
}
words++
bytes += len(typed) * int(unsafe.Sizeof(typed[0]))
}
if words == 0 {
t.Fatal("合成模型应至少加载一个词")
}
// float32每词 300×4 = 1200 字节float64 会是 2400
if want := words * e.dim * 4; bytes != want {
t.Fatalf("向量本体字节数应 %dfloat32实际 %d", want, bytes)
}
}

View File

@ -28,7 +28,13 @@ var (
//
// ❗main 上此值始终是**下一个未发布中版本**,不随 patch 发布变动
//(见 docs/git-branching.md §2.1);已发布的版本号看对应的 release/vX.Y.x 与 tag。
Version = "1.3.0"
// 1.3.7:驻留子继承父的输出通道(此前子侧 childIO 空壳 ⇒ 子不会发消息)。
// 1.3.6:人格文本不再在播种时固化版本 + 存量实例一次性去版本化(生产实例
// 曾自报 v1.0.3);系统提示词支持 {{kernel_version}} 等占位符。
// 1.3.5:系统提示词(人格卡)支持版本占位符 —— 人格卡是配置项,写死版本号
// 会随发版说谎(线上写 v1.0.3、内核 1.3.xagent 就自报 1.0.3)。
// 支持 {{kernel_version}} / {{kernel_commit}} / {{sdk_version}}。
Version = "1.3.7"
// Commit 是构建时的 Git commit hash。
Commit = "unknown"

View File

@ -0,0 +1,43 @@
package plugin
import (
"bytes"
"log"
"strings"
"testing"
)
// 延迟判定的语义:看的是"插件 Start 结束后最终声明了什么"
// 而不是"注册出站通道的那一刻有没有入站声明"。
//
// 为什么必须这样判:声明顺序自由 —— qq/weather 都是**先** RegisterOutputChannel
// **后** RegisterInputChannel按注册时刻判会把它们误报成"只声明了输出通道"
// (实测发生过:用户据此以为 qq 插件没更新)。
func TestWarnOutputOnlyChannels(t *testing.T) {
r := NewRegistry()
var buf bytes.Buffer
oldOut := log.Writer()
log.SetOutput(&buf)
defer log.SetOutput(oldOut)
// ① 出站+入站都声明了(先出站后入站)⇒ 不该告警
r.noteChannel("qq", "qq", true)
r.noteChannel("qq", "qq", false)
r.warnOutputOnlyChannels("qq")
if s := buf.String(); s != "" {
t.Fatalf("qq 声明了入站通道,不应告警,实际: %s", s)
}
// ② 只声明出站 ⇒ 应告警,且只报这一个通道
buf.Reset()
r.noteChannel("weather", "weather_weather_out", true)
r.noteChannel("weather", "weather_weather_in", false)
r.warnOutputOnlyChannels("weather")
out := buf.String()
if !strings.Contains(out, "weather_weather_out") {
t.Fatalf("只声明出站的通道应被告警,实际: %q", out)
}
if strings.Contains(out, "weather_weather_in") {
t.Fatalf("已声明入站的通道不该被牵连,实际: %q", out)
}
}

View File

@ -307,12 +307,15 @@ func (r *Registry) buildSDK(name string) *sdk.PluginSDK {
// 但历史插件常常只用 RegisterOutputChannel 声明(却用同一个名字注入输入,
// 例cli 只声明输出 "cli" 就用 InjectTextSync("cli", ...) 注入)。
// 不兜底的话 inputch 登记表里没有它,"把 inputch 划给驻留子"直接失败
// (实测报 `划入 inputch cli: inputch 未注册`)。兜底要**留痕**
// 否则插件作者永远不知道该补一行 RegisterInputChannel。
// (实测报 `划入 inputch cli: inputch 未注册`)。
//
// ❗这里**不能**判"是否声明过入站通道"并告警:声明顺序是自由的,
// 先 RegisterOutputChannel 再 RegisterInputChannel 是常见写法qq 就是),
// 按此刻的状态判会对它误报(实测:把 qq 报成"只声明了输出通道")。
// 真正该问的问题是"插件 Start 结束后,这个出站通道有没有对应的入站声明" ——
// 那在 load 完成后统一判(见 warnOutputOnlyChannels
if _, ok := r.iom.LookupInputChannel(chName); !ok {
_ = r.iom.RegisterInputChannelFrom(name, chName, agentIO.ChannelDef(def))
log.Printf("[plugin] %s 只声明了输出通道 %q已按双向通道兜底登记 inputch"+
"若要明确意图请显式 RegisterInputChannel", name, chName)
}
r.noteChannel(name, chName, true)
return nil
@ -452,6 +455,7 @@ func (r *Registry) Load(dir string) error {
r.pluginAutoRestart[name] = plgSDK.AutoRestart()
r.instances = append(r.instances, p)
r.mu.Unlock()
r.warnOutputOnlyChannels(name)
log.Printf("[plugin] loaded: %s", name)
}
@ -545,6 +549,7 @@ func (r *Registry) loadOne(plgDir, name string) bool {
r.pluginAutoRestart[name] = plgSDK.AutoRestart()
r.sdkRefs[name] = plgSDK
r.instances = append(r.instances, plg)
r.warnOutputOnlyChannels(name)
if h := pluginEntryHash(plgDir); h != "" {
r.pluginHashes[name] = h
} else {
@ -579,6 +584,31 @@ func (r *Registry) stageRegistrarFor() (func(plugin string, stage sdk.Stage, han
return nil, false
}
// warnOutputOnlyChannels 在插件 Start 结束后,报告"只声明了出站、没有入站声明"的通道。
//
// 为什么放在 Start 之后:声明顺序自由(先出站后入站很常见),注册时刻的状态
// 判不出意图。这里看的是**插件最终声明了什么**,因此不会误报 qq 这种写法。
//
// 注:这类通道内核已兜底登记 inputch功能可用告警只是提醒插件作者把意图写明。
func (r *Registry) warnOutputOnlyChannels(plugin string) {
r.channelsMu.Lock()
set := r.pluginChannels[plugin]
var only []string
if set != nil {
for ch := range set.outputs {
if !set.inputs[ch] {
only = append(only, ch)
}
}
}
r.channelsMu.Unlock()
sort.Strings(only)
for _, ch := range only {
log.Printf("[plugin] %s 只声明了出站通道 %q未 RegisterInputChannel"+
"内核已兜底登记 inputch若这是有意为之可忽略", plugin, ch)
}
}
// noteChannel 记住插件注册了哪个通道,供卸载/崩溃时摘除。
// forgetChannel 把某个通道从"本插件注册过哪些通道"的记账里摘掉(注销通道时用)。
//

View File

@ -138,28 +138,39 @@ func (p *Plugin) Stop() error {
func (p *Plugin) registerTools(s *sdk.PluginSDK) {
s.RegisterTool("plugin_install", sdk.ToolDef{
Name: "plugin_install",
Description: "从 URL 安装 HomeAgent 插件包(.hmap 文件)。插件已存在时传 overwrite=true 原地更新(升级/降级/重装,保留配置表,无需卸载重装)。更新后需调用 plgreload 或重启生效。",
Description: "安装 HomeAgent 插件包(.hmap。两种来源urlhttp/https 下载)或 path本机路径配合 plugindev_build 的产物用这个)。插件已存在时传 overwrite=true 原地更新(升级/降级/重装,保留配置表,无需卸载重装)。更新后需调用 plgreload 或重启生效。",
Parameters: map[string]interface{}{
"type": "object",
"properties": map[string]interface{}{
"url": map[string]interface{}{
"type": "string",
"description": "插件包的下载 URL",
"description": "插件包的下载 URLhttp/https",
},
"path": map[string]interface{}{
"type": "string",
"description": "插件包在**本机**的路径(.hmap。与 url 二选一;同时给出时以 path 为准",
},
"overwrite": map[string]interface{}{
"type": "boolean",
"description": "已存在时原地更新(保留配置)。默认 false",
},
},
"required": []string{"url"},
},
}, func(args map[string]interface{}) (interface{}, error) {
url, _ := args["url"].(string)
if url == "" {
return map[string]interface{}{"error": "url is required"}, nil
}
overwrite, _ := args["overwrite"].(bool)
return p.installFromURL(url, overwrite)
// path 优先:它对应"agent 自己构建出产物再装"的场景plugindev_build → plugin_install
if path, _ := args["path"].(string); strings.TrimSpace(path) != "" {
pth := strings.TrimSpace(path)
if st, err := os.Stat(pth); err != nil || st.IsDir() {
return map[string]interface{}{"error": fmt.Sprintf("path 无效(必须是存在的 .hmap 文件): %s", pth)}, nil
}
return p.installFromPath(pth, overwrite)
}
url, _ := args["url"].(string)
if strings.TrimSpace(url) == "" {
return map[string]interface{}{"error": "需要 url 或 path二选一"}, nil
}
return p.installFromURL(strings.TrimSpace(url), overwrite)
})
s.RegisterTool("plugin_list", sdk.ToolDef{
@ -455,12 +466,12 @@ func (p *Plugin) installFromData(data []byte, overwrite bool) (interface{}, erro
if existing && !overwrite {
return map[string]interface{}{
"error": "plugin already exists",
"name": pkg.Name,
"version": pkg.Version,
"current": oldVersion,
"action": "remove_first",
"hint": `传 "overwrite": true 可原地更新(保留配置)`,
"error": "plugin already exists",
"name": pkg.Name,
"version": pkg.Version,
"current": oldVersion,
"action": "remove_first",
"hint": `传 "overwrite": true 可原地更新(保留配置)`,
}, nil
}
@ -475,7 +486,7 @@ func (p *Plugin) installFromData(data []byte, overwrite bool) (interface{}, erro
os.RemoveAll(backup)
if err := os.Rename(target, backup); err != nil {
return map[string]interface{}{
"error": "backup old plugin dir failed",
"error": "backup old plugin dir failed",
"details": err.Error(),
}, nil
}
@ -484,8 +495,8 @@ func (p *Plugin) installFromData(data []byte, overwrite bool) (interface{}, erro
os.RemoveAll(target)
if rbErr := os.Rename(backup, target); rbErr != nil {
return map[string]interface{}{
"error": "extract failed AND rollback failed",
"details": err.Error(),
"error": "extract failed AND rollback failed",
"details": err.Error(),
"rollback": rbErr.Error(),
}, nil
}
@ -507,15 +518,15 @@ func (p *Plugin) installFromData(data []byte, overwrite bool) (interface{}, erro
action = "reinstalled"
}
return map[string]interface{}{
"status": "installed",
"name": pkg.Name,
"version": pkg.Version,
"status": "installed",
"name": pkg.Name,
"version": pkg.Version,
"previous_version": oldVersion,
"entry": pkg.Entry,
"checksum": checksum,
"action": action,
"reload_required": true,
"config_kept": true,
"entry": pkg.Entry,
"checksum": checksum,
"action": action,
"reload_required": true,
"config_kept": true,
}, nil
}

View File

@ -480,7 +480,15 @@ func (s *PluginSDK) RegisterPluginAPI(name string) error {
// 入站(谁会往 <name> 注入输入)是另一件事,用 RegisterInputChannel 声明。
// 若该通道同时也是你的注入入口,两个都要登记。
//
// name: channel name (e.g. "qq", "webui")
// name: channel name (e.g. "qq", "webui")
//
// ❗**命名约束**:内核会把通道名拼进 LLM 的函数名(`output_send__<name>`
// 而上游对函数名的规范是 `^[a-zA-Z0-9_-]{1,64}$`。违反的后果不是"这个工具不可用"
// 而是**整条请求被上游 400 拒绝**`Invalid 'tools[N].function.name'`
// 网关的 auto tier 会全链条失败 —— 表现成"整个 agent 不说话了"。
// 所以通道名只能用 `[A-Za-z0-9_-]`,且总长要留出 `output_send__`13 字符)的余量。
// 若通道名来自外部输入(设备自报 id 之类),请**在插件侧派生一个合规且唯一的名字**
// 而不是把原始值直接当通道名。
// caps: bitmask of supported output capabilities (CapText, CapFile, etc.)
// desc: description of the channel, expected meta format, and type enum
// def: 通道在记忆计算层的行为NoMemory/Cleaner