socksinthemiddle
Advanced tools
Comparing version 1.0.3 to 1.0.4
18
index.js
@@ -14,2 +14,3 @@ const net = require('net'), | ||
/** | ||
@@ -39,2 +40,4 @@ * for getting a full buffer from a stream and modifying it | ||
this.push(result); | ||
this.buf.length=0; | ||
this.buf=null; | ||
setImmediate(cb,null); | ||
@@ -152,6 +155,11 @@ } | ||
cb(reqToServer,resFromServer); | ||
}).on('error',e=>this.httpLog&&console.error('(proxy error)',reqFromClient.potocol+'://'+reqFromClient.headers.host,options.headers.host,options.path,e)); | ||
});reqToServer.on('error',e=>{ | ||
this.httpLog&&console.error('(proxy error)',reqFromClient.potocol+'://'+reqFromClient.headers.host,options.headers.host,options.path,e); | ||
setImmediate(()=>{ | ||
reqToServer.removeAllListeners(); | ||
reqToServer.destroy(); | ||
}); | ||
}); | ||
streamChain.push(reqToServer); | ||
pump(...streamChain) | ||
return reqToServer; | ||
pump(streamChain) | ||
} | ||
@@ -175,3 +183,3 @@ async _responseModder(resToClient,resFromServer,reqFromClient,reqToServer){ | ||
resToClient.writeHead(resFromServer.statusCode,resFromServer.statusMessage,Object.assign({},headers)); | ||
pump(...streamChain); | ||
pump(streamChain); | ||
} | ||
@@ -210,3 +218,3 @@ /** | ||
let relay=new TCPRelay(socket, '127.0.0.1', port, CMD_REPLY); | ||
relay.on('connection',(socket,relaySocket)=>{ | ||
relay.once('connection',(socket,relaySocket)=>{ | ||
this.socksLog&&console.log('[TCP]',`${socket.remoteAddress}:${socket.remotePort} ==> ${net.isIP(rawAddress)?'':'('+rawAddress+')'} ${relaySocket.remoteAddress}:${relaySocket.remotePort}`); | ||
@@ -213,0 +221,0 @@ }).on('proxy_error',(err,socket,relaySocket)=>{ |
@@ -5,7 +5,7 @@ { | ||
"pump": "^3.0.0", | ||
"socks5server": "^4.3.2" | ||
"socks5server": "^4.4.1" | ||
}, | ||
"name": "socksinthemiddle", | ||
"description": "use a socks server for web request modification", | ||
"version": "1.0.3", | ||
"version": "1.0.4", | ||
"main": "index.js", | ||
@@ -12,0 +12,0 @@ "scripts": { |
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
17057
5
354
1
Updatedsocks5server@^4.4.1