Function TestPostHandshakeRequestFormat

ntrip/client_test.go:144–190

(t *testing.T)

}

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

	cfg := Config{
		Caster:     "caster.example.com:2101",
		Mountpoint: "/MOUNT01",
		Password:   "secret",
		Username:   "user1",
		UserAgent:  "NTRIP MyApp/1.0",
		Version:    2,
		Chunked:    true,
	}
	ntripClient := NewClient(cfg)

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

	reader := bufio.NewReader(server)
	var requestLine string
	headers := map[string]string{}
	for {
		line, err := reader.ReadString('\n')
		require.NoError(t, err)
		line = strings.TrimRight(line, "\r\n")
		if line == "" {
			break
		}
		if requestLine == "" {
			requestLine = line
			continue
		}
		k, v, _ := strings.Cut(line, ": ")
		headers[k] = v
	}

	require.Equal(t, "POST /MOUNT01 HTTP/1.1", requestLine)
	require.Equal(t, "caster.example.com:2101", headers["Host"])
	require.Equal(t, "Ntrip/2.0", headers["Ntrip-Version"])
	require.Equal(t, "NTRIP MyApp/1.0", headers["User-Agent"])
	require.Equal(t, "chunked", headers["Transfer-Encoding"])
	want := base64.StdEncoding.EncodeToString([]byte("user1:secret"))
	require.Equal(t, "Basic "+want, headers["Authorization"])
	require.NoError(t, <-errCh)
}

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