package gateway

import (
	"context"
	"fmt"

	"git.yeij.top/AskaEth/Cyrene_v2/internal/channel/adapter"
	"git.yeij.top/AskaEth/Cyrene_v2/internal/runtime/history"
)

// 本文件承载主动推送的**落库**那一半（切片 P0「她主动找你」）。它从
// proactive.go 拆出来，好让「帧长什么样」与「记录怎么写」各自成篇
// （AGENTS §10 模块按职责拆源文件）。
//
// 为什么必须有这一半：修复前活跃客户端路由只把 `proactive_message` 帧
// 广播给在线连接（fire-and-forget），**一行都不写** ⇒ 刷新/重载后什么都补不回来，
// 界面既不显示气泡也补不出历史。主人的原话是「后台思考的主动推送一个都没推出来」。
// 主动消息是**她真实说过的一句话**，因此它必须与 IM 镜像路径走同一条去向：
// 主会话历史里的一条 assistant 消息。

// persistProactiveToMain 把一条主动消息写进主会话（`history.MainSessionID`），
// 并返回落库后的完整消息（含权威 id/时间戳），供帧载荷携带。
//
// 三条口径：
//   - **角色恒为 assistant**：这是她单方面开口说的话，不是主人的输入 —— 塞成
//     user 角色会污染「谁说了什么」，也会在历史里冒充主人发言（红线）。
//   - **正文用调用方已经净化并规整过的文本**（backthink 的 stripInternalMarkers 出口，
//     再过 `turnreply.NormalizeParagraphs` —— 见 SendProactive 的「先规整、再落库」），
//     系统元数据（决策标记、渠道选择）绝不进正文，也绝不新增任何隐藏字段 ——
//     注入面因此与「气泡里看到的那句话」逐字相同。
//   - **turn_id 留空**：主动推送不属于任何一路回合（她单方面开口，没有对应的
//     入站回合），空值诚实地表示这一点（与 channelbridge 的同一取舍）。
//
// 未接线历史存储时它是空操作并返回零值（`Persisted=false`）—— 与编排器 /
// IM 镜像路径同一取舍：没存储不是错误，但**绝不能谎称已落库**。写库失败返回
// 包装后的错误，由调用方让它可见（WARN + 返回给推送服务）。
func (h *hub) persistProactiveToMain(ctx context.Context, msg adapter.UnifiedMessage) (history.Message, error) {
	if h.history == nil {
		return history.Message{}, nil
	}
	full, err := h.history.AppendFull(ctx, history.Message{
		SessionID: history.MainSessionID,
		Role:      history.RoleAssistant,
		Content:   msg.Content,
		Platform:  msg.Platform,
		Mode:      modeChat,
	})
	if err != nil {
		return history.Message{}, fmt.Errorf("gateway: persist proactive to main session: %w", err)
	}
	return full, nil
}