package jobs

import (
	"context"
	"io"
	"sync"
	"testing"

	"reasonix/internal/event"
)

// TestManagerConcurrentAccess hammers every public Manager method from many
// goroutines. Any map access that escapes m.mu trips the runtime's built-in
// "concurrent map writes/read" fatal even without the race detector.
func TestManagerConcurrentAccess(t *testing.T) {
	m := NewManager(event.Discard)
	defer m.Close()

	const workers = 24
	var wg sync.WaitGroup
	wg.Add(workers)
	for w := range workers {
		go func(w int) {
			defer wg.Done()
			for i := range 200 {
				switch (w + i) % 6 {
				case 0:
					j := m.Start("bash", "x", func(ctx context.Context, out io.Writer) (string, error) {
						_, _ = out.Write([]byte("tick"))
						return "done", nil
					})
					_, _, _ = m.Output(j.ID)
				case 1:
					_ = m.Running()
				case 2:
					_ = m.DrainCompletedNote()
				case 3:
					_ = m.Wait(context.Background(), nil, 0) // non-blocking-ish: returns running snapshot
				case 4:
					m.Kill("bash-1")
				case 5:
					_, _, _ = m.Output("bash-2")
				}
			}
		}(w)
	}
	wg.Wait()
}