Method runNonStreamingStep

pkg/agent/processor.go:1257–1358

runNonStreamingStep 非流式执行模型步骤（快速模式）

(ctx context.Context)

// runNonStreamingStep 非流式执行模型步骤（快速模式）
func (a *Agent) runNonStreamingStep(ctx context.Context) error {
	// 准备工具Schema（包含使用示例）
	toolSchemas := make([]provider.ToolSchema, 0, len(a.toolMap))
	for _, tool := range a.toolMap {
		schema := provider.ToolSchema{
			Name:        tool.Name(),
			Description: tool.Description(),
			InputSchema: tool.InputSchema(),
		}
		// 检查工具是否实现了 ExampleableTool 接口
		if exampleable, ok := tool.(tools.ExampleableTool); ok {
			examples := exampleable.Examples()
			if len(examples) > 0 {
				providerExamples := make([]provider.ToolExample, len(examples))
				for i, ex := range examples {
					providerExamples[i] = provider.ToolExample{
						Description: ex.Description,
						Input:       ex.Input,
						Output:      ex.Output,
					}
				}
				schema.InputExamples = providerExamples
			}
		}
		toolSchemas = append(toolSchemas, schema)
	}

	// 准备消息
	a.mu.RLock()
	messages := make([]types.Message, len(a.messages))
	copy(messages, a.messages)
	currentSystemPrompt := a.template.SystemPrompt
	a.mu.RUnlock()

	// 创建Provider选项
	streamOpts := &provider.StreamOptions{
		Tools:       toolSchemas,
		System:      currentSystemPrompt,
		Temperature: 0.7,
		MaxTokens:   32000, // Claude 4 Sonnet/Opus 最大支持 64000 output tokens
	}

	procLog.Debug(ctx, "calling Complete API", map[string]any{"messages": len(messages), "tools": len(toolSchemas)})

	// 调用Complete API（非流式）
	response, err := a.provider.Complete(ctx, messages, streamOpts)
	if err != nil {
		return fmt.Errorf("complete call failed: %w", err)
	}

	// 添加响应消息
	a.mu.Lock()
	a.messages = append(a.messages, response.Message)
	a.mu.Unlock()

	// 提取工具调用从ContentBlocks
	toolUses := make([]*types.ToolUseBlock, 0)
	for _, block := range response.Message.ContentBlocks {