Function NewACPConversation

x/acpio/acp_conversation.go:56–78

NewACPConversation creates a new ACPConversation. If emitter is provided, it will receive events when messages/status/screen change. If clock is nil, a real clock will be used.

(ctx context.Context, agentIO ChunkableAgentIO, logger *slog.Logger, initialPrompt []st.MessagePart, emitter st.Emitter, clock quartz.Clock)

// If emitter is provided, it will receive events when messages/status/screen change.
// If clock is nil, a real clock will be used.
func NewACPConversation(ctx context.Context, agentIO ChunkableAgentIO, logger *slog.Logger, initialPrompt []st.MessagePart, emitter st.Emitter, clock quartz.Clock) *ACPConversation {
	if logger == nil {
		logger = slog.Default()
	}
	if clock == nil {
		clock = quartz.NewReal()
	}
	if emitter == nil {
		emitter = noopEmitter{}
	}
	ctx, cancel := context.WithCancel(ctx)
	c := &ACPConversation{
		ctx:           ctx,
		cancel:        cancel,
		agentIO:       agentIO,
		logger:        logger,
		initialPrompt: initialPrompt,
		emitter:       emitter,
		clock:         clock,
		chunkReceived: make(chan struct{}, 1),
	}
	return c
}

// Messages returns the conversation history.
func (c *ACPConversation) Messages() []st.ConversationMessage {