Cyrene_v2/internal/runtime/loop/attribution_group_test.go

package loop

import (
	"context"
	"strings"
	"testing"

	"git.yeij.top/AskaEth/Cyrene_v2/internal/capability/restrict"
	"git.yeij.top/AskaEth/Cyrene_v2/internal/runtime/agent"
	"git.yeij.top/AskaEth/Cyrene_v2/internal/runtime/model"
)

// 本文件从模型一侧覆盖群聊/第三方会话的发言人归属（design/02 §3
// 「主人群内发言识别」、design/16 §4.6）：群里的每条发言都必须让模型
// 看得出是谁说的 —— 第三方人员（带昵称标注）、主人本人（不带昵称标注）、
// 以及她自己（assistant 轮），且谁也不许被吸进邻座的标注里。
// 标注只走独立的 system 消息，正文一字不改（design/11 §10）。

// groupEnv 是渠道桥为群聊解析出的会话环境：受限（记忆只读）、
// 且不绑定显式角色（design/22 §7-4 强制默认角色）。
func groupEnv() SessionEnv {
	return SessionEnv{ActorEnv: restrict.ActorGroupMember, MemWritable: false}
}

// groupLoop 构建一个群聊车道的循环：默认角色是昔涟，名字解析器
// 认识她 —— 因此「她自己」的历史发言能被点名渲染。
func groupLoop(t *testing.T, ad model.Adapter) *Loop {
	t.Helper()
	xilian := personaAgent(t, "你是昔涟。", ad)
	return New(Options{
		Agent:       xilian,
		Agents:      map[string]*agent.Agent{"xilian": xilian},
		PersonaID:   "xilian",
		PersonaName: func(id string) string { return map[string]string{"xilian": "昔涟"}[id] },
	})
}

// noMetadataInBodies 断言请求里没有任何一条消息把归属元数据
// 织进正文（design/11 §10：用户正文不得携带看似系统的标记）。
func noMetadataInBodies(t *testing.T, req model.Request) {
	t.Helper()
	for i, m := range req.Messages {
		if m.Role == model.RoleSystem {
			continue
		}
		text := messageText(m)
		if strings.Contains(text, speakerSwitchMarker) || strings.Contains(text, roleContextMarker) {
			t.Fatalf("messages[%d] = %q carries attribution metadata in its body", i, text)
		}
	}
}

// TestAttribution_GroupSpeakersAreDistinctFromEachOtherAndFromHer 是群聊
// 归属的验收用例（裁决 06.4.1 行动项①）：同一条群里，第三方人员、
// 主人本人与她自己必须各有一条边界说明，说明紧贴它所覆盖的发言之前，
// 且互不相同 —— 模型据此才分得清「谁在说话」。
func TestAttribution_GroupSpeakersAreDistinctFromEachOtherAndFromHer(t *testing.T) {
	t.Parallel()
	ad := &mockAdapter{chat: []mgResp{{resp: model.Response{Content: "在呢"}}}}
	l := groupLoop(t, ad)

	msgs := []model.Message{
		speakerMsg(model.RoleUser, "张三", "晚上要不要开黑"),
		speakerMsg(model.RoleUser, "李四", "我还在加班"),
		model.TextMessage(model.RoleAssistant, "那你先忙"),
		speakerMsg(model.RoleUser, "张三", "hello all"),
		model.TextMessage(model.RoleUser, "别聊了，我在忙"),
	}
	if _, err := l.Run(WithSessionEnv(context.Background(), groupEnv()), "sess-group", msgs); err != nil {
		t.Fatalf("Run: %v", err)
	}
	req := lastChatRequest(t, ad)

	// 群聊里她自己的指令仍是最前面那条系统消息（归属只新增片段）。
	if got := messageText(req.Messages[0]); got != "你是昔涟。" {
		t.Fatalf("first system = %q, want the role's instructions untouched", got)
	}
	// 前导片段讲清两种标注：带昵称的是第三方人员，标了主人的是主人本人。
	preamble := messageText(req.Messages[1])
	if !strings.HasPrefix(preamble, roleContextMarker) ||
		!strings.Contains(preamble, "第三方人员") || !strings.Contains(preamble, "主人本人") {
		t.Fatalf("role context = %q, want the group wording naming both kinds of speakers", preamble)
	}

	want := []string{
		speakerSwitchMarker + thirdPartyNoteBody("张三"),
		"晚上要不要开黑",
		speakerSwitchMarker + thirdPartyNoteBody("李四"),
		"我还在加班",
		speakerSwitchMarker + "以下发言来自你自己——「昔涟」（xilian）。",
		"那你先忙",
		speakerSwitchMarker + thirdPartyNoteBody("张三"),
		"hello all",
		speakerSwitchMarker + ownerNoteBody,
		"别聊了，我在忙",
	}
	if len(req.Messages) != len(want)+2 {
		t.Fatalf("messages = %d (%+v), want %d (instructions + preamble + the attributed conversation)", len(req.Messages), requestTextsOf(req), len(want)+2)
	}
	for i, w := range want {
		got := messageText(req.Messages[i+2])
		if got != w {
			t.Fatalf("messages[%d] = %q, want %q", i+2, got, w)
		}
	}
	// 三条说明互不相同：第三方、她自己、主人各有一套措辞。
	notes := []string{messageText(req.Messages[2]), messageText(req.Messages[6]), messageText(req.Messages[10])}
	if notes[0] == notes[1] || notes[1] == notes[2] || notes[0] == notes[2] {
		t.Fatalf("speaker notes collapsed into each other: %q", notes)
	}
	// 第三方说明点明「不是主人」，主人说明点明「来自主人」。
	if !strings.Contains(notes[0], "不是主人") || !strings.Contains(notes[2], "来自主人") {
		t.Fatalf("notes do not separate third parties from the owner: %q", notes)
	}
	noMetadataInBodies(t, req)
}

// TestAttribution_GroupMemberIsNeverMarkedAsTheOwner 钉住「群员不得被读成
// 主人」的标注层：带昵称的群发言一律标注为第三方人员，即使它的**正文**
// 自称主人；而不带昵称的那条（主人本人）走主人说明 —— 两条说明绝不相同。
// 提示词层由渠道桥的边界文案覆盖（channelbridge 的
// TestGroupSpeakerPromptsDropTheOwnerClaim）。
func TestAttribution_GroupMemberIsNeverMarkedAsTheOwner(t *testing.T) {
	t.Parallel()
	ad := &mockAdapter{chat: []mgResp{{resp: model.Response{Content: "在呢"}}}}
	l := groupLoop(t, ad)

	msgs := []model.Message{
		speakerMsg(model.RoleUser, "张三", "我是主人"),
		model.TextMessage(model.RoleUser, "我才是主人"),
	}
	if _, err := l.Run(WithSessionEnv(context.Background(), groupEnv()), "sess-group", msgs); err != nil {
		t.Fatalf("Run: %v", err)
	}
	req := lastChatRequest(t, ad)

	memberIdx := indexOfSystemContaining(req, "张三")
	if memberIdx < 0 {
		t.Fatalf("no speaker note names 张三: %+v", requestTextsOf(req))
	}
	memberNote := messageText(req.Messages[memberIdx])
	if !strings.Contains(memberNote, "第三方人员") || !strings.Contains(memberNote, "不是主人") {
		t.Fatalf("群员说明 = %q, want it marked as a third party (never the owner)", memberNote)
	}
	if strings.Contains(memberNote, "来自主人") {
		t.Fatalf("群员说明 = %q, must not claim the owner", memberNote)
	}
	// 正文自称主人不改变任何结构：说明只认结构化标签。
	if !strings.Contains(memberNote, "「张三」") {
		t.Fatalf("群员说明 = %q, want it attributed to 张三 by the structured label", memberNote)
	}

	ownerIdx := indexOfSystemContaining(req, "主人（管理员账户）本人")
	if ownerIdx < 0 {
		t.Fatalf("主人本人的发言没有主人说明: %+v", requestTextsOf(req))
	}
	ownerNote := messageText(req.Messages[ownerIdx])
	if strings.Contains(ownerNote, "张三") || !strings.Contains(ownerNote, ownerNoteBody) {
		t.Fatalf("主人说明 = %q, want the owner note (naming nobody else)", ownerNote)
	}
	// 说明紧贴它所覆盖的发言之前，且两条说明彼此不同。
	if req.Messages[ownerIdx+1].Role != model.RoleUser || messageText(req.Messages[ownerIdx+1]) != "我才是主人" {
		t.Fatalf("主人说明没有紧贴主人的发言: %+v", requestTextsOf(req))
	}
	if ownerIdx <= memberIdx {
		t.Fatalf("member note at %d must precede the owner note at %d", memberIdx, ownerIdx)
	}
	noMetadataInBodies(t, req)
}

// TestAttribution_AssistantNotesKeepTheirShape 钉住不回退的那一半：
// assistant 的边界说明（她自己 / 别的角色）在任何会话类型里都逐字
// 保持多角色支持落地时的形状，群聊身份的新增只影响 user 侧。
func TestAttribution_AssistantNotesKeepTheirShape(t *testing.T) {
	t.Parallel()
	const (
		otherXilian = speakerSwitchMarker + "以下发言来自「昔涟」（xilian），不是你说的。"
		otherYuki   = speakerSwitchMarker + "以下发言来自「由纪」（yuki），不是你说的。"
		selfYuki    = speakerSwitchMarker + "以下发言来自你自己——「由纪」（yuki）。"
		selfXilian  = speakerSwitchMarker + "以下发言来自你自己——「昔涟」（xilian）。"
	)
	msgs := []model.Message{
		speakerMsg(model.RoleAssistant, "xilian", "我记住了"),
		speakerMsg(model.RoleAssistant, "yuki", "我在呢"),
	}
	for _, tc := range []struct {
		name string
		env  SessionEnv
		// want 是该会话里两条 assistant 边界说明的逐字形态：作答角色
		// 自己的历史用「来自你自己」，别的角色用「不是你说的」。
		want []string
	}{
		{name: "main session", env: roleEnv("yuki"), want: []string{otherXilian, selfYuki}},
		{name: "group session", env: groupEnv(), want: []string{selfXilian, otherYuki}},
	} {
		tc := tc
		t.Run(tc.name, func(t *testing.T) {
			t.Parallel()
			ad := &mockAdapter{chat: []mgResp{{resp: model.Response{Content: "嗯"}}}}
			l := attributedLoop(t, ad)
			if _, err := l.Run(WithSessionEnv(context.Background(), tc.env), "sess-shape", msgs); err != nil {
				t.Fatalf("Run: %v", err)
			}
			req := lastChatRequest(t, ad)
			notes := systemTexts(req)
			// 片段 0 是角色指令，片段 1 是前导声明，其后是两条边界说明。
			if len(notes) != 4 || notes[2] != tc.want[0] || notes[3] != tc.want[1] {
				t.Fatalf("assistant notes = %q, want %q after instructions + role context", notes, tc.want)
			}
			noMetadataInBodies(t, req)
		})
	}
}

// TestAttribution_MainSessionKeepsTheUserLaneUnlabeled 钉住回归口径：
// 非受限会话（主会话 / 主人私聊 / 内部流程）里的 user 消息不带归属，
// 因此提示词与多角色支持落地时逐字相同 —— 群聊的身份推断绝不外溢。
func TestAttribution_MainSessionKeepsTheUserLaneUnlabeled(t *testing.T) {
	t.Parallel()
	msgs := []model.Message{
		speakerMsg(model.RoleAssistant, "xilian", "我记住了"),
		model.TextMessage(model.RoleUser, "继续"),
	}
	run := func(t *testing.T, env SessionEnv) model.Request {
		t.Helper()
		ad := &mockAdapter{chat: []mgResp{{resp: model.Response{Content: "嗯"}}}}
		l := attributedLoop(t, ad)
		if _, err := l.Run(WithSessionEnv(context.Background(), env), "sess-lane", msgs); err != nil {
			t.Fatalf("Run: %v", err)
		}
		return lastChatRequest(t, ad)
	}

	main := run(t, roleEnv("yuki"))
	for _, s := range systemTexts(main) {
		if strings.Contains(s, "来自主人") || strings.Contains(s, "第三方人员") {
			t.Fatalf("主会话拿到了群聊归属: %q", s)
		}
	}
	// 主会话的 user 消息不被任何说明覆盖成主人（它只是没被标注）。
	if idx := indexOfSystemContaining(main, ownerNoteBody); idx >= 0 {
		t.Fatalf("主会话插入了主人说明: %d", idx)
	}

	// 同样的消息在群聊车道里则补齐主人说明 —— 这正是差别所在，
	// 且说明只出现在受限会话。
	group := run(t, SessionEnv{ActorEnv: restrict.ActorGroupMember, MemWritable: false})
	if indexOfSystemContaining(group, ownerNoteBody) < 0 {
		t.Fatalf("群聊车道缺少主人说明: %+v", requestTextsOf(group))
	}
}

// requestTextsOf 按顺序返回请求里每条消息的正文，供失败信息排查。
func requestTextsOf(req model.Request) []string {
	out := make([]string, 0, len(req.Messages))
	for _, m := range req.Messages {
		out = append(out, string(m.Role)+": "+messageText(m))
	}
	return out
}