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

More logs

Browse source
This commit is contained in:
Sander Declerck 2025-10-14 14:18:33 +02:00
parent 35beeb55b0
commit a2d05b0cf0
No known key found for this signature in database
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1,8 +1,10 @@
import * as http from "http"; import * as http from "http";
import * as https from "https"; import * as https from "https";
// oxlint-disable no-console - just for testing, remove afterwards
export function handleHttpProxyRequest(req, res) { export function handleHttpProxyRequest(req, res) {
const url = new URL(req.url); const url = new URL(req.url);
console.log(`Proxying request to: ${req.url}`);
let protocol; let protocol;
if (url.protocol === "http:") { if (url.protocol === "http:") {
@ -23,7 +25,8 @@ 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", () => { proxyRes.on("error", (err) => {
console.log("Error in proxy response stream:", err);
// Stream error while piping response // Stream error while piping response
// Response headers already sent, can't send error status // Response headers already sent, can't send error status
}); });
@ -35,18 +38,21 @@ export function handleHttpProxyRequest(req, res) {
}); });
req.on("error", () => { req.on("error", () => {
console.log("Error in client request stream");
// Client request stream error // Client request stream error
// Abort the proxy request // Abort the proxy request
proxyRequest.destroy(); proxyRequest.destroy();
}); });
res.on("error", () => { res.on("error", () => {
console.log("Error in client response stream");
// Client response stream error (client disconnected) // Client response stream error (client disconnected)
// Clean up proxy streams // Clean up proxy streams
proxyRequest.destroy(); proxyRequest.destroy();
}); });
res.on("close", () => { res.on("close", () => {
console.log("Client response stream closed");
// Client disconnected // Client disconnected
// Abort the proxy request to avoid unnecessary work // Abort the proxy request to avoid unnecessary work
if (!res.writableEnded) { if (!res.writableEnded) {