Function TestSourceHandshakeRequestFormat

ntrip/client_test.go:70–103

(t *testing.T)

}

func TestSourceHandshakeRequestFormat(t *testing.T) {
	client, server := net.Pipe()
	defer server.Close()

	cfg := Config{
		Caster:     "caster.example.com:2101",
		Mountpoint: "/EXAMPLE_MOUNT",
		Password:   "my$ecr3t",
		Username:   "user1",
		UserAgent:  "NTRIP MyApp/1.0",
	}
	ntripClient := NewClient(cfg)

	errCh := make(chan error, 1)
	go func() {
		errCh <- ntripClient.sourceHandshake(client)
	}()

	// Read the complete request.
	reader := bufio.NewReader(server)
	var request strings.Builder
	for {
		line, err := reader.ReadString('\n')
		require.NoError(t, err)
		request.WriteString(line)
		if strings.TrimSpace(line) == "" {
			break
		}
	}

	expected := "SOURCE my$ecr3t EXAMPLE_MOUNT\r\nSource-Agent: NTRIP MyApp/1.0\r\nSTR: \r\n\r\n"
	require.Equal(t, expected, request.String())
	require.NoError(t, <-errCh)
}

func TestSourceHandshakeMountpointStripsSlash(t *testing.T) {
	client, server := net.Pipe()