get get_data.js working

denoland · Sep 24, 2024 · e98525c · e98525c
1 parent 3261473
commit e98525c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 5 deletions.
diff --git a/ext/node/polyfills/_http_outgoing.ts b/ext/node/polyfills/_http_outgoing.ts
@@ -514,7 +514,9 @@ Object.defineProperties(
     _flushHeaders() {
       console.log("flushHeaders");
       if (this.socket) {
-        if (!this._headerSent && this._header !== null) {
+        console.log("socket found: ", { headerSent: this._headerSent, header: this._header });
+        if (!this._headerSent) {
+          console.log("_writeHeader invoked");
           this._writeHeader();
           this._headerSent = true;
         }

diff --git a/ext/node/polyfills/http.ts b/ext/node/polyfills/http.ts
@@ -434,8 +434,9 @@ class ClientRequest extends OutgoingMessage {
       }
     }
 
-    const client = this._getClient() ?? createHttpClient({ http2: false });
-    this._client = client;
+    console.log({ headers });
+    // const client = this._getClient() ?? createHttpClient({ http2: false });
+    // this._client = client;
 
     if (
       this.method === "POST" || this.method === "PATCH" || this.method === "PUT"
@@ -476,15 +477,16 @@ class ClientRequest extends OutgoingMessage {
         await op_node_http_wait_for_connection(connRid);
         this.emit("requestReady");
         const res = await op_node_http_await_response(rid);
-        console.log({ res });
+        console.log({ status: res.status });
         // if (this._req.cancelHandleRid !== null) {
         //   core.tryClose(this._req.cancelHandleRid);
         // }
         // if (this._timeout) {
         //   this._timeout.removeEventListener("abort", this._timeoutCb);
         //   webClearTimeout(this._timeout[timerId]);
         // }
-        this._client.close();
+        // this._client.close();
+        console.log("IncomingMessageForClient constructed");
         const incoming = new IncomingMessageForClient(this.socket);
         incoming.req = this;
         this.res = incoming;
@@ -554,6 +556,7 @@ class ClientRequest extends OutgoingMessage {
           this._closed = true;
           this.emit("close");
         } else {
+          console.log("emitting response");
           {
             console.log("_bodyRid set", res.responseRid);
             incoming._bodyRid = res.responseRid;