Method executeSync

pkg/middleware/subagent.go:298–327

executeSync 同步执行子代理

(ctx context.Context, subagentType, description string, parentContext map[string]any)

// executeSync 同步执行子代理
func (t *TaskTool) executeSync(ctx context.Context, subagentType, description string, parentContext map[string]any) (any, error) {
	// 获取子代理
	subagent, err := t.middleware.GetSubAgent(subagentType)
	if err != nil {
		return map[string]any{
			"ok":    false,
			"error": fmt.Sprintf("failed to get subagent: %v", err),
		}, nil
	}

	saLog.Info(ctx, "delegating task", map[string]any{"subagent": subagentType, "description": description})

	// 执行任务
	result, err := subagent.Execute(ctx, description, parentContext)
	if err != nil {
		return map[string]any{
			"ok":            false,
			"error":         fmt.Sprintf("subagent execution failed: %v", err),
			"subagent_type": subagentType,
		}, nil
	}

	saLog.Info(ctx, "subagent completed task", map[string]any{"subagent": subagentType})

	return map[string]any{
		"ok":            true,
		"subagent_type": subagentType,
		"result":        result,
	}, nil
}

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