Function Test_Send_RejectsDuplicateSend

x/acpio/acp_conversation_test.go:278–304

(t *testing.T)

}

func Test_Send_RejectsDuplicateSend(t *testing.T) {
	mClock := quartz.NewMock(t)
	mock := newMockAgentIO()
	// Block the write so it doesn't complete immediately
	started, done := mock.BlockWrite()

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

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

	// Wait for the write to start (ensuring we're in "prompting" state)
	<-started

	// Second send while first is processing should fail
	err := conv.Send(screentracker.MessagePartText{Content: "second"})
	assert.ErrorIs(t, err, screentracker.ErrMessageValidationChanging)

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

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

func Test_Status_ChangesWhileProcessing(t *testing.T) {
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)