From fbc4c19c71a814a9336c971fa503bd9f2f13a6ca Mon Sep 17 00:00:00 2001
From: Ciro Spaciari <ciro.spaciari@gmail.com>
Date: Tue, 17 Dec 2024 11:08:09 -0800
Subject: [PATCH] pause/resume readable side

---
 src/http.zig | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/http.zig b/src/http.zig
index 3a6a27138d..f5a7d6c0c9 100644
--- a/src/http.zig
+++ b/src/http.zig
@@ -720,6 +720,7 @@ fn NewHTTPContext(comptime ssl: bool) type {
                     socket.flush();
                     socket.timeout(0);
                     socket.setTimeoutMinutes(5);
+                    _ = socket.pauseStream();
 
                     pending.http_socket = socket;
                     pending.did_have_handshaking_error_while_reject_unauthorized_is_false = did_have_handshaking_error_while_reject_unauthorized_is_false;
@@ -1005,6 +1006,7 @@ fn NewHTTPContext(comptime ssl: bool) type {
                         ctx.* = bun.cast(**anyopaque, ActiveSocket.init(client).ptr());
                     }
                     client.allow_retry = true;
+                    _ = sock.resumeStream();
                     client.onOpen(comptime ssl, sock);
                     if (comptime ssl) {
                         client.firstCall(comptime ssl, sock);
@@ -3615,8 +3617,6 @@ pub fn onData(
                 }
             }
         },
-
-        .fail => {},
         .proxy_headers, .proxy_handshake => {
             this.setTimeout(socket, 5);
             if (this.proxy_tunnel) |proxy| {
@@ -3624,7 +3624,11 @@ pub fn onData(
             }
             return;
         },
-        else => {
+        .fail => {}, // already fail just ignore
+        .done, .proxy_body => {
+            // .proxy_body is a invalid state should only be reachable on request side
+            bun.debugAssert(this.state.response_stage == .done);
+            // we are already done but we receive extra data, the socket may be in a invalid http state after this so we close
             this.state.pending_response = null;
             this.closeAndFail(error.UnexpectedData, is_ssl, socket);
             return;