Function testTLSProxyProtocolMatrix

caddytest/integration/proxyprotocol_test.go:277–318

testTLSProxyProtocolMatrix is the shared implementation for TLS-based proxy protocol tests. It mirrors testProxyProtocolMatrix but uses a TLS backend.

(t *testing.T, ppVersion string, transportVersions []string, numRequests int)

// testTLSProxyProtocolMatrix is the shared implementation for TLS-based proxy
// protocol tests.  It mirrors testProxyProtocolMatrix but uses a TLS backend.
func testTLSProxyProtocolMatrix(t *testing.T, ppVersion string, transportVersions []string, numRequests int) {
	t.Helper()

	backend := newTLSProxyProtoBackend(t)
	listenPort := freePort(t)

	tester := caddytest.NewTester(t)
	tester.WithDefaultOverrides(caddytest.Config{
		AdminPort: 2999,
	})
	cfg := proxyProtoTLSConfig(listenPort, backend.addr(), ppVersion, transportVersions)
	tester.InitServer(cfg, "json")

	proxyURL := fmt.Sprintf("http://127.0.0.1:%d/", listenPort)

	for i := 0; i < numRequests; i++ {
		resp, err := tester.Client.Get(proxyURL)
		if err != nil {
			t.Fatalf("request %d/%d: GET %s: %v", i+1, numRequests, proxyURL, err)
		}
		resp.Body.Close()
		if resp.StatusCode != http.StatusOK {
			t.Errorf("request %d/%d: expected status 200, got %d", i+1, numRequests, resp.StatusCode)
		}
	}

	addrs := backend.recordedAddrs()
	if len(addrs) == 0 {
		t.Fatalf("backend recorded no PROXY protocol addresses (expected at least 1)")
	}

	for i, addr := range addrs {
		host, _, err := net.SplitHostPort(addr)
		if err != nil {
			t.Errorf("addr[%d] %q: SplitHostPort: %v", i, addr, err)
			continue
		}
		if host != "127.0.0.1" {
			t.Errorf("addr[%d]: expected source 127.0.0.1, got %q", i, host)
		}
	}
}

// proxyProtoConfig builds a Caddy JSON configuration that:
//   - listens on listenPort for inbound HTTP requests