Function HandleThinkingBlocks

agent/normalize.go:123–149

(messages []map[string]any, modelFamily string, recentErrors []string)

}

func HandleThinkingBlocks(messages []map[string]any, modelFamily string, recentErrors []string) []map[string]any {
	supports := modelSupportsThinking(modelFamily)
	out := make([]map[string]any, 0, len(messages))
	for _, msg := range messages {
		blocks := contentBlocks(msg["content"])
		if blocks == nil {
			out = append(out, msg)
			continue
		}
		role := stringFromAny(msg["role"])
		stripThinking := role == "user" || !supports
		filtered := make([]map[string]any, 0, len(blocks))
		for _, block := range blocks {
			if _, ok := thinkingBlockTypes[stringFromAny(block["type"])]; ok && stripThinking {
				continue
			}
			filtered = append(filtered, block)
		}
		if len(filtered) == 0 {
			continue
		}
		cp := copyMap(msg)
		cp["content"] = filtered
		out = append(out, cp)
	}
	return out
}

func MergeSplitMessages(messages []map[string]any) []map[string]any {
	if len(messages) == 0 {