// Copyright 2026 Alibaba Group
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.

package chatmsg

import "strings"

// StreamingCardContractVersion identifies the additive card receipt emitted by
// high-level card shortcuts.
const StreamingCardContractVersion = "im.streaming-card.v1"

// ProjectStreamingCardReceipt publishes every server-returned identifier in a
// single cardRef. referencePairAvailable means this response contained both
// the update identifier and the visible message identifiers; it does not claim
// that older messages can be resolved without server-side mapping support.
func ProjectStreamingCardReceipt(created map[string]any, bizID string) map[string]any {
	bizID = strings.TrimSpace(bizID)
	messageID := firstSendStatusString(created, "openMessageId", "messageId", "msgId")
	conversationID := firstSendStatusString(created, "openConversationId", "conversationId", "openCid")
	cardRef := map[string]any{}
	if bizID != "" {
		cardRef["bizId"] = bizID
	}
	if messageID != "" {
		cardRef["openMessageId"] = messageID
	}
	if conversationID != "" {
		cardRef["openConversationId"] = conversationID
	}
	pairAvailable := bizID != "" && messageID != "" && conversationID != ""
	payload := map[string]any{
		"contractVersion":        StreamingCardContractVersion,
		"ok":                     true,
		"cardRef":                cardRef,
		"referencePairAvailable": pairAvailable,
		"created":                created,
		"nextActions":            []map[string]any{},
	}
	if bizID != "" {
		payload["nextActions"] = []map[string]any{{
			"cliPath": "chat +messages-update-card",
			"arguments": map[string]any{
				"biz-id": bizID,
			},
			"requiredArguments": []string{"content", "flow-status"},
			"ready":             false,
		}}
	}
	if !pairAvailable {
		payload["capabilityGap"] = "服务端尚未同时返回 bizId、openMessageId 和 openConversationId；CLI 只能保留本次响应，不能据此承诺从历史消息反向恢复 bizId"
	}
	return payload
}

// ProjectStreamingCardUpdate preserves the lower response while making the
// verified target explicit for downstream consumers.
func ProjectStreamingCardUpdate(updated map[string]any, bizID string, verification CardUpdateVerification) map[string]any {
	payload := cloneSendStatusMap(updated)
	payload["contractVersion"] = StreamingCardContractVersion
	payload["cardRef"] = map[string]any{"bizId": strings.TrimSpace(bizID)}
	payload["accepted"] = verification.Accepted
	payload["verified"] = verification.Verified
	payload["verificationEvidence"] = verification.Evidence
	if verification.Accepted && !verification.Verified {
		payload["warning"] = "服务端已接受卡片更新请求，但未返回可独立证明可见内容已更新的字段；不要重复执行相同更新"
	}
	return payload
}