Function waitForSOCKS5

test/e2e/basic_test.go:88–118

waitForSOCKS5 waits for the SOCKS5 proxy to be available

(ctx context.Context, port int, timeout time.Duration)

// waitForSOCKS5 waits for the SOCKS5 proxy to be available
func waitForSOCKS5(ctx context.Context, port int, timeout time.Duration) error {
	deadline := time.Now().Add(timeout)
	
	for time.Now().Before(deadline) {
		select {
		case <-ctx.Done():
			return ctx.Err()
		default:
		}
		
		// Try to connect to the SOCKS5 proxy
		proxyURL, _ := url.Parse("socks5://localhost:8080")
		client := &http.Client{
			Transport: &http.Transport{
				Proxy: http.ProxyURL(proxyURL),
			},
			Timeout: 5 * time.Second,
		}
		
		// Try a simple HTTP request through the proxy
		resp, err := client.Get("http://httpbin.org/ip")
		if err == nil {
			resp.Body.Close()
			return nil
		}
		
		time.Sleep(5 * time.Second)
	}
	
	return context.DeadlineExceeded
}

// testHTTPTraffic tests that HTTP requests work through the proxy
func testHTTPTraffic() error {