Function TestLoop_LastOutputTimeUpdated

internal/loop/loop_test.go:607–643

TestLoop_LastOutputTimeUpdated tests that lastOutputTime is updated on each scanner output.

(t *testing.T)

// TestLoop_LastOutputTimeUpdated tests that lastOutputTime is updated on each scanner output.
func TestLoop_LastOutputTimeUpdated(t *testing.T) {
	l := NewLoop("/test/prd.json", "test", 5, testProvider)
	l.iteration = 1

	// Drain events to avoid blocking
	go func() {
		for range l.Events() {
		}
	}()

	// Record initial time
	l.mu.Lock()
	l.lastOutputTime = time.Now().Add(-1 * time.Hour) // Set to an old time
	initialTime := l.lastOutputTime
	l.mu.Unlock()

	// Send output through processOutput
	r, w, _ := os.Pipe()
	go func() {
		w.WriteString(`{"type":"assistant","message":{"content":[{"type":"text","text":"hello"}]}}` + "\n")
		time.Sleep(50 * time.Millisecond)
		w.WriteString(`{"type":"assistant","message":{"content":[{"type":"text","text":"world"}]}}` + "\n")
		w.Close()
	}()

	l.processOutput(r)
	close(l.events)

	// Verify lastOutputTime was updated
	l.mu.Lock()
	finalTime := l.lastOutputTime
	l.mu.Unlock()

	if !finalTime.After(initialTime) {
		t.Errorf("Expected lastOutputTime to be updated after output, initial=%v, final=%v", initialTime, finalTime)
	}
}

// TestLoop_WatchdogReturnsError tests that watchdog kill causes runIteration to return an error
// that feeds into retry logic.