Function TestJSONStats

ptp/sptp/client/json_stats_test.go:45–89

(t *testing.T)

}

func TestJSONStats(t *testing.T) {
	stats, err := NewJSONStats()
	require.NoError(t, err)
	port, err := getFreePort()
	require.Nil(t, err, "Failed to allocate port")
	url := fmt.Sprintf("http://localhost:%d", port)
	go stats.Start(port, time.Second)
	time.Sleep(time.Second)

	stats.SetTickDuration(time.Millisecond)

	gm0 := &gmstats.Stat{
		GMAddress: "192.168.0.10",
		Error:     "mymy",
	}
	stats.SetGMStats(gm0)

	gm1 := &gmstats.Stat{
		GMAddress:         "192.168.0.13",
		Error:             "",
		GMPresent:         1,
		IngressTime:       1676997604198536785,
		MeanPathDelay:     float64(299995 * time.Microsecond),
		Offset:            float64(-100001 * time.Microsecond),
		PortIdentity:      "000000.0086.09c621",
		Priority1:         1,
		Priority2:         2,
		Priority3:         3,
		Selected:          true,
		StepsRemoved:      1,
		CorrectionFieldRX: int64(6 * time.Microsecond),
		CorrectionFieldTX: int64(4 * time.Microsecond),
	}
	stats.SetGMStats(gm1)

	require.NoError(t, err)

	gms, err := gmstats.FetchStats(url)
	require.NoError(t, err)
	expectedStats := gmstats.Stats{
		gm0,
		gm1,
	}
	require.Equal(t, expectedStats, gms)
}

func TestHeaders(t *testing.T) {
	stats, err := NewJSONStats()