Function Test_Send_AddsUserMessage

x/acpio/acp_conversation_test.go:209–238

(t *testing.T)

}

func Test_Send_AddsUserMessage(t *testing.T) {
	mClock := quartz.NewMock(t)
	mock := newMockAgentIO()
	// Set up blocking so we can inspect state mid-flight
	started, done := mock.BlockWrite()

	conv := acpio.NewACPConversation(context.Background(), mock, nil, nil, nil, mClock)
	conv.Start(context.Background())

	// Send blocks until completion, so run in a goroutine
	errCh := make(chan error, 1)
	go func() { errCh <- conv.Send(screentracker.MessagePartText{Content: "hello"}) }()

	// Wait for the write to start
	<-started

	messages := conv.Messages()
	require.Len(t, messages, 2) // user message + placeholder agent message

	assert.Equal(t, screentracker.ConversationRoleUser, messages[0].Role)
	assert.Equal(t, "hello", messages[0].Message)
	assert.Equal(t, screentracker.ConversationRoleAgent, messages[1].Role)

	// Signal a chunk so executePrompt's timer wait doesn't hang on the mock clock.
	mock.SimulateChunks("hello response")

	// Unblock the write to let Send complete
	close(done)
	require.NoError(t, <-errCh)
}

func Test_Send_RejectsEmptyMessage(t *testing.T) {
	mClock := quartz.NewMock(t)