Function New

internal/controller/controller.go:61–88

New creates a new controller instance.

(ctx context.Context, cfg Config)

// New creates a new controller instance.
func New(ctx context.Context, cfg Config) (*Controller, error) {
	// Initialize agent registry
	registry := NewRegistry()

	// Determine plan function
	// If no planner builder is provided, use the default Gemini planner.
	if cfg.PlannerBuilder == nil {
		cfg.PlannerBuilder = func(ctx context.Context, r *Registry) (agent.Agent, error) {
			return gemini.NewGeminiPlannerAgent(ctx, r, gemini.GeminiPlannerConfig{})
		}
	}

	if cfg.EventLogBuilder == nil {
		return nil, fmt.Errorf("event log builder is required")
	}
	eventLog, err := cfg.EventLogBuilder()
	if err != nil {
		return nil, fmt.Errorf("failed to create event log: %w", err)
	}



	return &Controller{
		registry:       registry,
		eventLog:       eventLog,
		plannerBuilder: cfg.PlannerBuilder,
	}, nil
}

func (d *Controller) tryResuming(ctx context.Context, req *proto.ExecRequest, el executor.EventLog, registry map[string]agent.Agent, handler ExecHandler) (history []*proto.Message, done bool, err error) {
	events, err := el.Events(ctx, req.ConversationId)