Function TestLoop_WatchdogKillsHungProcess

internal/loop/loop_test.go:465–525

TestLoop_WatchdogKillsHungProcess tests that a hung process is killed after timeout.

(t *testing.T)

// TestLoop_WatchdogKillsHungProcess tests that a hung process is killed after timeout.
func TestLoop_WatchdogKillsHungProcess(t *testing.T) {
	l := NewLoop("/test/prd.json", "test", 5, testProvider)
	l.iteration = 1

	// Use a very short timeout for testing
	timeout := 100 * time.Millisecond

	// Collect events
	var events []Event
	done := make(chan bool)
	go func() {
		for event := range l.Events() {
			events = append(events, event)
		}
		done <- true
	}()

	// Create a pipe that never sends data (simulates hung process)
	r, w, _ := os.Pipe()

	// Initialize lastOutputTime
	l.mu.Lock()
	l.lastOutputTime = time.Now()
	l.mu.Unlock()

	// Start watchdog with a short check interval
	watchdogDone := make(chan struct{})
	var fired atomic.Bool
	go l.runWatchdog(timeout, watchdogDone, &fired)

	// processOutput will block until pipe is closed (by watchdog killing would close it,
	// but in this test we close it manually after watchdog fires)
	go func() {
		// Wait for watchdog to fire
		time.Sleep(500 * time.Millisecond)
		w.Close()
	}()

	l.processOutput(r)
	close(watchdogDone)
	close(l.events)
	<-done

	if !fired.Load() {
		t.Error("Expected watchdog to fire for hung process")
	}

	// Check that we got a WatchdogTimeout event
	hasWatchdog := false
	for _, e := range events {
		if e.Type == EventWatchdogTimeout {
			hasWatchdog = true
			if e.Text == "" {
				t.Error("Expected watchdog event to have descriptive text")
			}
		}
	}
	if !hasWatchdog {