package codec

import (
	"io"
	"runtime"
	"sync"
	"testing"
	"time"
)

func TestMeasureBitRateStatic(t *testing.T) {
	// https://github.com/pion/mediadevices/issues/198
	if runtime.GOOS == "darwin" {
		t.Skip("Skipping because Darwin CI is not reliable for timing related tests.")
	}

	r, w := io.Pipe()
	const (
		dataSize       = 1000
		dur            = 5 * time.Second
		packetInterval = time.Second
		precision      = 8.0 // 1 byte
	)
	var wg sync.WaitGroup
	wg.Add(1)
	done := make(chan struct{})

	go func() {
		data := make([]byte, dataSize)
		ticker := time.NewTicker(packetInterval)

		// Wait half interval
		time.Sleep(packetInterval / 2)

		// Make sure that this goroutine is synchronized with main goroutine
		wg.Done()

		for {
			select {
			case <-ticker.C:
				w.Write(data)
			case <-done:
				w.Close()
				return
			}
		}
	}()

	wg.Wait()
	bitrate, err := MeasureBitRate(r, dur)
	if err != nil {
		t.Error(err)
	}
	done <- struct{}{}

	expected := float64(dataSize * 8)
	if bitrate < expected-precision || bitrate > expected+precision {
		t.Fatalf("expected: %f (with %f precision), but got %f", expected, precision, bitrate)
	}
}

func TestMeasureBitRateDynamic(t *testing.T) {
	// https://github.com/pion/mediadevices/issues/198
	if runtime.GOOS == "darwin" {
		t.Skip("Skipping because Darwin CI is not reliable for timing related tests.")
	}

	r, w := io.Pipe()
	const (
		dataSize       = 1000
		dur            = 5 * time.Second
		packetInterval = time.Millisecond * 250
		precision      = 8.0 // 1 byte
	)
	var wg sync.WaitGroup
	wg.Add(1)
	done := make(chan struct{})

	go func() {
		data := make([]byte, dataSize)
		ticker := time.NewTicker(packetInterval)

		// Wait half interval
		time.Sleep(packetInterval / 2)

		wg.Done()

		var count int
		for {
			select {
			case <-ticker.C:
				// 4 x 500ms ticks and 250ms ticks
				if count%2 == 1 || count >= 8 {
					w.Write(data)
				}
				count++
			case <-done:
				w.Close()
				return
			}
		}
	}()

	wg.Wait()
	bitrate, err := MeasureBitRate(r, dur)
	if err != nil {
		t.Error(err)
	}
	done <- struct{}{}

	// Measure the expected bitrate using the number of ticks or write * data size / duration in seconds
	// For the first 2 seconds: #ticks = 2000ms / 500ms = 4
	// For the last 3 seconds: #ticks = 3000ms / 250ms = 12
	// So, in 5 seconds, there will be 16 ticks
	expected := float64(16*(dataSize*8)) / 5
	if bitrate < expected-precision || bitrate > expected+precision {
		t.Fatalf("expected: %f (with %f precision), but got %f", expected, precision, bitrate)
	}
}