Function Test_Status_ChangesWhileProcessing

x/acpio/acp_conversation_test.go:306–338

(t *testing.T)

}

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

	mClock := quartz.NewMock(t)
	mock := newMockAgentIO()
	emitter := newMockEmitter()
	// Block the write so we can observe status changes
	started, done := mock.BlockWrite()

	conv := acpio.NewACPConversation(ctx, mock, nil, nil, emitter, mClock)
	conv.Start(ctx)

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

	// Wait for write to start
	<-started

	// Status should be changing while processing
	assert.Equal(t, screentracker.ConversationStatusChanging, conv.Status())

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

	// Unblock the write
	close(done)

	// Wait for Send to complete - status should then be stable.
	require.NoError(t, <-errCh)
	emitter.WaitForStatus(ctx, t, screentracker.ConversationStatusStable)
}

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