mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-14 21:01:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

[autofix.ci] apply automated fixes

Browse Source
This commit is contained in:
autofix-ci[bot]
2025-08-05 19:08:43 +00:00
committed by GitHub
parent 7822083657
commit 39df200ac9
2 changed files with 23 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
test/js/node/http/node-http.test.ts
View File

@@ -3081,7 +3081,7 @@ test("should handle invalid method", async () => {
test("multiple request writes should not hang (issue #21620)", async () => {
const { promise, resolve, reject } = Promise.withResolvers();
let responseReceived = false;
await using server = http.createServer((req, res) => {
let body = "";
req.on("data", chunk => {
@@ -3098,7 +3098,7 @@ test("multiple request writes should not hang (issue #21620)", async () => {
const address = server.address() as AddressInfo;
const jsonStr = JSON.stringify({ key: "val", key2: 200 });
const req = http.request(
{
hostname: "localhost",
@@ -3108,7 +3108,7 @@ test("multiple request writes should not hang (issue #21620)", async () => {
"content-type": "application/json",
},
},
(res) => {
res => {
let data = "";
res.on("data", chunk => {
data += chunk.toString();
@@ -3123,7 +3123,7 @@ test("multiple request writes should not hang (issue #21620)", async () => {
reject(err);
}
});
}
},
);
req.on("error", reject);
@@ -3155,7 +3155,7 @@ test("multiple request writes should not hang (issue #21620)", async () => {
test("multiple https request writes should not hang", async () => {
const { promise, resolve, reject } = Promise.withResolvers();
let responseReceived = false;
await using server = https.createServer(COMMON_TLS_CERT, (req, res) => {
let body = "";
req.on("data", chunk => {
@@ -3172,7 +3172,7 @@ test("multiple https request writes should not hang", async () => {
const address = server.address() as AddressInfo;
const jsonStr = JSON.stringify({ key: "val", key2: 200 });
const req = https.request(
{
hostname: "localhost",
@@ -3183,7 +3183,7 @@ test("multiple https request writes should not hang", async () => {
},
rejectUnauthorized: false, // For test cert
},
(res) => {
res => {
let data = "";
res.on("data", chunk => {
data += chunk.toString();
@@ -3198,12 +3198,12 @@ test("multiple https request writes should not hang", async () => {
reject(err);
}
});
}
},
);
req.on("error", reject);
// Add timeout to prevent hanging
// Add timeout to prevent hanging
const timeout = setTimeout(() => {
if (!responseReceived) {
req.destroy();

28
test/regression/issue/21620.test.ts
View File

@@ -2,7 +2,7 @@
* Regression test for issue #21620 - Multiple data writes on outgoing http/https request cause the connection to hang
* @see https://github.com/oven-sh/bun/issues/21620
*/
import { test, expect } from "bun:test";
import { expect, test } from "bun:test";
import { once } from "node:events";
import http from "node:http";
import https from "node:https";
@@ -25,13 +25,13 @@ lCECIQDcOTGFE7gU6zW8bV2b1JzG1Hv5jJiO2xON9U3qxnKNZwIhAOKGOLQcHrOO
hGdJWp5YTJD5K3vxrW6HzfN/Lr8yTpGVAiEA4mD8YjQxuCJ3yDY1zR5U2n7rE5ON
LYZa5GGl9g5w6YMCIQDH4U+7K3mw7yV3U6gHfLaV0+6nOW9l1lCY2vXzjUr5HQIg
YMU+J1Y5SBo9PHLLqJQ9E3mH2LZU7q9Z9lkJdA+6TnE=
-----END RSA PRIVATE KEY-----`
-----END RSA PRIVATE KEY-----`,
};
test("multiple http request writes should not hang (issue #21620)", async () => {
const { promise, resolve, reject } = Promise.withResolvers<void>();
let responseReceived = false;
await using server = http.createServer((req, res) => {
let body = "";
req.on("data", chunk => {
@@ -48,7 +48,7 @@ test("multiple http request writes should not hang (issue #21620)", async () =>
const address = server.address() as AddressInfo;
const jsonStr = JSON.stringify({ key: "val", key2: 200 });
const req = http.request(
{
hostname: "localhost",
@@ -58,7 +58,7 @@ test("multiple http request writes should not hang (issue #21620)", async () =>
"content-type": "application/json",
},
},
(res) => {
res => {
let data = "";
res.on("data", chunk => {
data += chunk.toString();
@@ -73,7 +73,7 @@ test("multiple http request writes should not hang (issue #21620)", async () =>
reject(err);
}
});
}
},
);
req.on("error", reject);
@@ -88,7 +88,7 @@ test("multiple http request writes should not hang (issue #21620)", async () =>
// Multiple writes should not cause hanging
req.write(jsonStr.slice(0, 10));
// Add small delay between writes to trigger the race condition
setTimeout(() => {
req.write(jsonStr.slice(10));
@@ -107,7 +107,7 @@ test("multiple http request writes should not hang (issue #21620)", async () =>
test("multiple https request writes should not hang (issue #21620)", async () => {
const { promise, resolve, reject } = Promise.withResolvers<void>();
let responseReceived = false;
await using server = https.createServer(COMMON_TLS_CERT, (req, res) => {
let body = "";
req.on("data", chunk => {
@@ -124,7 +124,7 @@ test("multiple https request writes should not hang (issue #21620)", async () =>
const address = server.address() as AddressInfo;
const jsonStr = JSON.stringify({ key: "val", key2: 200 });
const req = https.request(
{
hostname: "localhost",
@@ -135,7 +135,7 @@ test("multiple https request writes should not hang (issue #21620)", async () =>
},
rejectUnauthorized: false, // For test cert
},
(res) => {
res => {
let data = "";
res.on("data", chunk => {
data += chunk.toString();
@@ -150,12 +150,12 @@ test("multiple https request writes should not hang (issue #21620)", async () =>
reject(err);
}
});
}
},
);
req.on("error", reject);
// Add timeout to prevent hanging
// Add timeout to prevent hanging
const timeout = setTimeout(() => {
if (!responseReceived) {
req.destroy();
@@ -165,7 +165,7 @@ test("multiple https request writes should not hang (issue #21620)", async () =>
// Multiple writes should not cause hanging
req.write(jsonStr.slice(0, 10));
// Add small delay between writes to trigger the race condition
setTimeout(() => {
req.write(jsonStr.slice(10));
@@ -179,4 +179,4 @@ test("multiple https request writes should not hang (issue #21620)", async () =>
clearTimeout(timeout);
throw err;
}
});
});