Function startHeaderCatcher

ws_test.go:686–718

--- helpers ---

(t *testing.T)

// --- helpers ---

func startHeaderCatcher(t *testing.T) (addr string, got chan []string, closer func()) {
	t.Helper()
	ln, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		t.Fatalf("listen: %v", err)
	}
	got = make(chan []string, 1)

	go func() {
		conn, err := ln.Accept()
		if err != nil {
			// surface nothing; test will timeout
			return
		}
		defer conn.Close()
		r := bufio.NewReader(conn)
		var lines []string
		for {
			s, err := r.ReadString('\n')
			if err != nil {
				break
			}
			s = strings.TrimRight(s, "\r\n")
			if s == "" { // end of HTTP headers
				break
			}
			lines = append(lines, s)
		}
		got <- lines
	}()

	return ln.Addr().String(), got, func() { _ = ln.Close() }
}

func hasHeaderValue(headers []string, name, want string) bool {
	prefix := strings.ToLower(name) + ":"