Function TestHandleProxyForwardsOrigin400Verbatim

cmd/cache-proxy/proxy_test.go:650–674

TestHandleProxyForwardsOrigin400Verbatim is the case the user actually hit: S3 returns 400 with an XML envelope ( ExpiredToken ) and DuckDB needs to see *that* body and *that* status, not a generic 502 with a Go-formatted error string. Without verbatim passthrough the error class (4xx ter

(t *testing.T)

			url := fmt.Sprintf("%s/bucket/concurrent-%d.parquet", originURL, i)
			headers := http.Header{"Range": []string{fmt.Sprintf("bytes=%d-%d", i, i+1)}}
			results <- doForwardProxyRequest(proxy, "GET", url, headers)
		}()
	}

	deadline := time.Now().Add(2 * time.Second)
	for atomic.LoadInt32(&originCalls) < requests && time.Now().Before(deadline) {
		time.Sleep(10 * time.Millisecond)
	}
	if got := atomic.LoadInt32(&originCalls); got != requests {
		release()
		t.Fatalf("origin calls before release = %d, want %d; metrics-only PR must not limit origin concurrency", got, requests)
	}
	if got := atomic.LoadInt32(&maxActiveOriginCalls); got != requests {
		release()
		t.Fatalf("simultaneous origin calls before release = %d, want %d; metrics-only PR must not queue origin concurrency", got, requests)
	}
	release()

	var failed []string
	for i := 0; i < requests; i++ {
		rec := waitForRecorder(t, results, "timed out waiting for concurrent proxy response")
		if rec.Code != http.StatusPartialContent {
			failed = append(failed, fmt.Sprintf("response %d status = %d", i+1, rec.Code))
		}
	}
	if len(failed) > 0 {
		t.Fatalf("metrics-only PR must not add local rejection behavior: %s", strings.Join(failed, ", "))
	}