Function MergeSplitMessages

agent/normalize.go:151–182

(messages []map[string]any)

}

func MergeSplitMessages(messages []map[string]any) []map[string]any {
	if len(messages) == 0 {
		return messages
	}
	out := make([]map[string]any, 0, len(messages))
	i := 0
	for i < len(messages) {
		msg := messages[i]
		role := stringFromAny(msg["role"])
		msgID := stringFromAny(msg["id"])
		if role != "assistant" || msgID == "" {
			out = append(out, msg)
			i++
			continue
		}
		merged := append([]map[string]any{}, contentBlocks(msg["content"])...)
		j := i + 1
		for j < len(messages) {
			next := messages[j]
			if stringFromAny(next["role"]) != "assistant" || stringFromAny(next["id"]) != msgID {
				break
			}
			merged = append(merged, contentBlocks(next["content"])...)
			j++
		}
		cp := copyMap(msg)
		cp["content"] = merged
		out = append(out, cp)
		i = j
	}
	return out
}

func FixToolPairings(messages []map[string]any) []map[string]any {
	uses := map[string]struct{}{}