From 52127a3323fb8d9cfdb4b791e8138aae5b6d0cc9 Mon Sep 17 00:00:00 2001
From: HomeAgent Agent <agent@homeagent.local>
Date: Sun, 13 Sep 2026 21:59:10 +0800
Subject: [PATCH] =?UTF-8?q?fix(resident):=20CreateResident=20=E6=B3=A8?=
 =?UTF-8?q?=E5=86=8C=E5=85=A5=E7=AB=99=20inputch=20=E5=90=8E=E5=8A=A0=20de?=
 =?UTF-8?q?fer=20=E5=9B=9E=E6=BB=9A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

注册点与 residents 登记之间当前无可失败步骤，但缺回滚路径就是 child/<id>
残留那只 bug 的另一条入口。加 registered 标志 + defer：未走到成功返回就注销。
---
 internal/agent/core/resident.go | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/internal/agent/core/resident.go b/internal/agent/core/resident.go
index 1f83265..77b6d9b 100644
--- a/internal/agent/core/resident.go
+++ b/internal/agent/core/resident.go
@@ -168,6 +168,19 @@ func (a *Agent) SpawnResident(opts ResidentOptions) (ResidentInfo, error) {
 
 	// ④ 子 → 父的主动消息（**L3 中断**，带子标识）：投进父的 inputch。
 	parentInCh := a.residentInboundChannel(opts.ID)
+	// 登记了入站 inputch 就必须有回滚路径：注册点与 residents 登记之间
+	// 当前无可失败步骤，但一旦将来插入（或 child.Start 变更），早退会把这条
+	// 登记留在共享表里——就是 child/<id> 残留那只 bug 的另一条入口。
+	// defer 保证“只要没走到成功返回，就注销这条登记”。
+	registered := false
+	defer func() {
+		if registered {
+			return
+		}
+		if reg := a.io.ChannelRegistry(); reg != nil {
+			reg.Unregister(inboundChannelName(opts.ID))
+		}
+	}()
 	child.notifyParent = func(text string) {
 		a.io.InjectInterruptTextOpts(opts.ID, parentInCh, text,
 			agentIO.InjectOptions{Priority: "L3"})
@@ -191,6 +204,7 @@ func (a *Agent) SpawnResident(opts ResidentOptions) (ResidentInfo, error) {
 		child.io.InjectInputTo(a.residentParentSource(), parentInCh, "text",
 			map[string]interface{}{"content": opts.TaskPrompt})
 	}
+	registered = true
 	return rc.info(), nil
 }