Fix HTTP forwarding by making it fully synchronous

- Remove async context timeout that was causing premature completion
- Make HTTP request and response copying fully synchronous
- Add response flushing to ensure data reaches client
- Add detailed logging for bytes written and completion
- Should resolve the race condition causing empty replies

Co-authored-by: f0ssel <[email protected]>

Author: blink-so[bot]

proxy/proxy.go

@@ -224,11 +224,7 @@ func (p *Server) forwardHTTPRequest(w http.ResponseWriter, r *http.Request) {
 
 	p.logger.Debug("About to make HTTP request", "target", targetURL.String())
 
-	// Make the request with context
-	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
-	defer cancel()
-	req = req.WithContext(ctx)
-	
+	// Make the request synchronously - this is the key fix
 	resp, err := client.Do(req)
 	if err != nil {
 		p.logger.Error("Failed to make forward request", "error", err, "target", targetURL.String(), "error_type", fmt.Sprintf("%T", err))
@@ -252,13 +248,20 @@ func (p *Server) forwardHTTPRequest(w http.ResponseWriter, r *http.Request) {
 	// Copy status code
 	w.WriteHeader(resp.StatusCode)
 
-	// Copy response body
-	_, copyErr := io.Copy(w, resp.Body)
+	// Copy response body - ensure this completes
+	bytesWritten, copyErr := io.Copy(w, resp.Body)
 	if copyErr != nil {
-		p.logger.Debug("Error copying response body", "error", copyErr)
+		p.logger.Error("Error copying response body", "error", copyErr, "bytes_written", bytesWritten)
+		http.Error(w, "Failed to copy response", http.StatusBadGateway)
 	} else {
-		p.logger.Debug("Successfully forwarded HTTP response")
+		p.logger.Debug("Successfully forwarded HTTP response", "bytes_written", bytesWritten, "status", resp.StatusCode)
+	}
+
+	// Ensure response is flushed
+	if flusher, ok := w.(http.Flusher); ok {
+		flusher.Flush()
 	}
+	p.logger.Debug("forwardHTTPRequest completed")
 }
 
 // forwardHTTPSRequest forwards an HTTPS request