Function queueToolLogDelta

api/controller/relay/relay_agent.go:1102–1130

(c *gin.Context, requestId string, content string, toolCallId string, functionName string, streamType string)

}

func queueToolLogDelta(c *gin.Context, requestId string, content string, toolCallId string, functionName string, streamType string) {
	if content == "" {
		return
	}
	if !config.IsSSECompactMode() {
		step := ProcessStep{
			StepCode:  "tool_log_delta",
			Name:      "工具输出",
			Status:    "streaming",
			Message:   "",
			Data:      map[string]interface{}{"content": content, "type": streamType, "tool_call_id": toolCallId, "function_name": functionName},
			Timestamp: time.Now().Unix(),
		}
		if err := sendProcessStep(c, requestId, step); err != nil {
			logger.Warnf(c, "Failed to send tool_log_delta step: %v", err)
		}
		return
	}

	key := fmt.Sprintf("%s|%s", toolCallId, streamType)
	buffers := getToolLogDeltaBuffers(c)
	buf, ok := buffers[key]
	if !ok || buf == nil {
		buf = &toolLogDeltaBuffer{LastFlush: time.Now()}
		buffers[key] = buf
	}
	buf.Content.WriteString(content)
	flushToolLogDeltaBuffer(c, requestId, key, toolCallId, functionName, streamType, false)
}

func compactToolResultPreview(result string) (string, bool) {
	result = extractHTTPBodyFromToolOutput(result)