Method execute

internal/controller/controller.go:209–260

(ctx context.Context, conversationID string, execID string, agentID string, agentConfig []byte, history []*proto.Message, newInputs []*proto.Message, registry map[string]agent.Agent, handler ExecHandler)

}

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)
	outputCapturer := func(outgoing *proto.AgentOutputs) error {
		// Filter out internal-only messages.
		var outputs []*proto.Message
		for _, m := range outgoing.Messages {
			if m.GetInternalOnly() {
				continue
			}
			outputs = append(outputs, m)
		}
		if len(outputs) == 0 {
			return nil
		}
		msg := &proto.ConversationEvent{
			ConversationId: conversationID,
			ExecId:         execID,
			Messages:       outputs,
			State:          proto.State_STATE_PENDING,
		}
		seq, err := d.eventLog.Append(ctx, msg)
		if err != nil {
			return err
		}
		return handler(&proto.ExecResponse{
			Outputs: msg.Messages,
			Seq:     seq,
		})
	}
	if _, err := d.eventLog.Append(ctx, &proto.ConversationEvent{
		ConversationId: conversationID,
		ExecId:         execID,
		Messages:       newInputs,
		State:          proto.State_STATE_PENDING,
	}); err != nil {
		return err
	}
	state, err := e.Exec(ctx, conversationID, execID, &proto.AgentStart{
		AgentId:     agentID,
		AgentConfig: agentConfig,
		Messages:    append(history, newInputs...),
	}, outputCapturer)
	if err != nil {
		return err
	}
	_, err = d.eventLog.Append(ctx, &proto.ConversationEvent{
		ConversationId: conversationID,
		ExecId:         execID,
		State:          state,
	})
	return err
}

// Delete deletes all events for a specific conversation ID.
func (d *Controller) Delete(ctx context.Context, conversationID string) error {