Method Send

x/acpio/acp_conversation.go:91–138

Send sends a message to the agent synchronously. It blocks until the agent has finished processing and returns any error from the underlying write. Returns a validation error immediately if the message is invalid or another message is already being processed.

(messageParts ...st.MessagePart)

// from the underlying write. Returns a validation error immediately if
// the message is invalid or another message is already being processed.
func (c *ACPConversation) Send(messageParts ...st.MessagePart) error {
	message := ""
	for _, part := range messageParts {
		message += part.String()
	}

	// Validate whitespace BEFORE trimming (match PTY behavior)
	if message != strings.TrimSpace(message) {
		return st.ErrMessageValidationWhitespace
	}

	if message == "" {
		return st.ErrMessageValidationEmpty
	}

	// Check if already prompting and set state atomically
	c.mu.Lock()
	if c.prompting {
		c.mu.Unlock()
		return st.ErrMessageValidationChanging
	}
	c.messages = append(c.messages, st.ConversationMessage{
		Id:      c.nextID,
		Role:    st.ConversationRoleUser,
		Message: message,
		Time:    c.clock.Now(),
	})
	c.nextID++
	// Add placeholder for streaming agent response
	c.messages = append(c.messages, st.ConversationMessage{
		Id:      c.nextID,
		Role:    st.ConversationRoleAgent,
		Message: "",
		Time:    c.clock.Now(),
	})
	c.nextID++
	c.streamingResponse.Reset()
	c.prompting = true
	status := c.statusLocked()
	c.mu.Unlock()

	// Emit status change to "running" before starting the prompt
	c.emitter.EmitStatus(status)

	c.logger.Debug("ACPConversation sending message", "message", message)

	return c.executePrompt(messageParts)
}

// Start sets up chunk handling and sends the initial prompt if provided.
func (c *ACPConversation) Start(ctx context.Context) {