Method executePrompt

x/acpio/acp_conversation.go:222–288

executePrompt runs the actual agent request and returns any error.

(messageParts []st.MessagePart)

// executePrompt runs the actual agent request and returns any error.
func (c *ACPConversation) executePrompt(messageParts []st.MessagePart) error {
	// Drain any stale signal before sending the prompt.
	select {
	case <-c.chunkReceived:
	default:
	}

	var err error
	for _, part := range messageParts {
		if c.ctx.Err() != nil {
			err = c.ctx.Err()
			break
		}
		if partErr := part.Do(c.agentIO); partErr != nil {
			err = partErr
			break
		}
	}

	// The ACP SDK dispatches SessionUpdate notifications as goroutines, so
	// the chunk may arrive after conn.Prompt() returns. Wait up to 100ms.
	timer := c.clock.NewTimer(100 * time.Millisecond)
	select {
	case <-c.chunkReceived:
	case <-timer.C:
	}
	timer.Stop()

	c.mu.Lock()
	c.prompting = false

	if err != nil {
		c.logger.Error("ACPConversation message failed", "error", err)
		// Remove the agent's streaming message on error (may be empty or partial)
		if len(c.messages) > 0 && c.messages[len(c.messages)-1].Role == st.ConversationRoleAgent {
			c.messages = c.messages[:len(c.messages)-1]
		}
		messages := slices.Clone(c.messages)
		status := c.statusLocked()
		screen := c.streamingResponse.String()
		c.mu.Unlock()

		c.emitter.EmitMessages(messages)
		c.emitter.EmitStatus(status)
		c.emitter.EmitScreen(screen)
		return err
	}

	// Final response should already be in the last message via streaming
	// but ensure it's finalized
	response := c.streamingResponse.String()
	if len(c.messages) > 0 && c.messages[len(c.messages)-1].Role == st.ConversationRoleAgent {
		// Intentionally not trimming space here.
		c.messages[len(c.messages)-1].Message = response
	}
	messages := slices.Clone(c.messages)
	status := c.statusLocked()
	screen := c.streamingResponse.String()