Method Exec

internal/controller/controller.go:166–207

Exec executes a new agentic loop execution or resumes an existing one. If id is empty, a UUID will be generated. If the execution already exists, it will be resumed with optional new inputs.

(ctx context.Context, req *proto.ExecRequest, handler ExecHandler)

// If id is empty, a UUID will be generated.
// If the execution already exists, it will be resumed with optional new inputs.
func (d *Controller) Exec(ctx context.Context, req *proto.ExecRequest, handler ExecHandler) error {
	if req.ConversationId == "" {
		return fmt.Errorf("conversation_id is required")
	}

	planner, err := d.plannerBuilder(ctx, d.registry)
	if err != nil {
		return fmt.Errorf("failed to create planner: %w", err)
	}
	
	registry := maps.Clone(d.registry.Map())
	registry[plannerAgentID] = planner

	// TODO(lhuan): consider remove this.
	registry[geminiAgentID] = gemini.NewGeminiAgent()

	if req.AgentId == "" {
		req.AgentId = plannerAgentID
	}

	// Replay the execution history if any.
	history, done, err := d.tryResuming(ctx, req, d.eventLog, registry, handler)
	if err != nil {
		return err
	}
	if done {
		// Nothing else to do, new inputs are used in the replay.
		return nil
	}

	return d.execute(
		ctx,
		req.ConversationId,
		uuid.NewString(),
		req.AgentId,
		req.AgentConfig,
		history,
		req.Inputs,
		registry,
		handler,
	)
}

func (d *Controller) execute(ctx context.Context, conversationID string, execID string, agentID string, agentConfig []byte, history []*proto.Message, newInputs []*proto.Message, registry map[string]agent.Agent, handler ExecHandler) error {
	e := executor.DefaultExecutor(d.eventLog, registry)