Method Execute

pkg/middleware/subagent.go:259–295

(ctx context.Context, input map[string]any, tc *tools.ToolContext)

}

func (t *TaskTool) Execute(ctx context.Context, input map[string]any, tc *tools.ToolContext) (any, error) {
	description, ok := input["description"].(string)
	if !ok {
		return nil, errors.New("description must be a string")
	}

	subagentType, ok := input["subagent_type"].(string)
	if !ok {
		return nil, errors.New("subagent_type must be a string")
	}

	// 获取上下文(可选)
	parentContext := make(map[string]any)
	if contextData, ok := input["context"].(map[string]any); ok {
		parentContext = contextData
	}

	// 检查是否异步执行
	async := false
	if asyncVal, ok := input["async"].(bool); ok {
		async = asyncVal
	}

	// 获取超时设置
	timeout := t.middleware.defaultTimeout
	if timeoutVal, ok := input["timeout"].(float64); ok {
		timeout = time.Duration(timeoutVal) * time.Second
	}

	// 如果启用了管理器且请求异步执行
	if t.middleware.manager != nil && async {
		return t.executeAsync(ctx, subagentType, description, parentContext, timeout)
	}

	// 同步执行（原有逻辑）
	return t.executeSync(ctx, subagentType, description, parentContext)
}

// executeSync 同步执行子代理
func (t *TaskTool) executeSync(ctx context.Context, subagentType, description string, parentContext map[string]any) (any, error) {