milliways-infosec/AikidoSec-safe-chain
7
0
Fork 0
mirror of https://github.com/AikidoSec/safe-chain.git synced 2026-05-26 12:10:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Further cleanup

Browse source
This commit is contained in:
Sander Declerck 2025-10-15 09:25:24 +02:00
parent fce7550609
commit 37ef3e187b
No known key found for this signature in database
1 changed files with 10 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

12
packages/safe-chain/src/registryProxy/plainHttpProxy.js
View file

@ -23,9 +23,17 @@ export function handleHttpProxyRequest(req, res) {
res.writeHead(proxyRes.statusCode, proxyRes.headers); res.writeHead(proxyRes.statusCode, proxyRes.headers);
proxyRes.pipe(res); proxyRes.pipe(res);
proxyRes.on("error", () => {
// Proxy response stream error
// Clean up client response stream
if (res.writable) {
res.end();
}
});
proxyRes.on("close", () => { proxyRes.on("close", () => {
// Clean up if the proxy response stream closes // Clean up if the proxy response stream closes
if (!res.writableEnded) { if (res.writable) {
res.end(); res.end();
} }
}); });
@ -51,9 +59,7 @@ export function handleHttpProxyRequest(req, res) {
res.on("close", () => { res.on("close", () => {
// Client disconnected // Client disconnected
// Abort the proxy request to avoid unnecessary work // Abort the proxy request to avoid unnecessary work
if (!res.writableEnded) {
proxyRequest.destroy(); proxyRequest.destroy();
}
}); });
req.pipe(proxyRequest); req.pipe(proxyRequest);