decadent
commented
6 years ago Here's a log of events on the sockets involved. Legend:
→pr: incoming socket on the proxypr→: outgoing socket from the proxy to the server→ser: incoming socket on the server from the proxy
[ pr→] lookup
[ pr→] connect
[→pr] pipe
[ pr→] pipe
[ pr→] ready
[ pr→] resume
[→pr] resume
[→pr] data
[ pr→] data
[→pr] data
[ pr→] data
[→pr] data
[ pr→] data
[ pr→] data
[→pr] data
[→ser] close
[ pr→] error
[ pr→] unpipe
proxy→server connection socket error: { Error: read ECONNRESET
at TCP.onStreamRead (internal/stream_base_commons.js:111:27) errno: 'ECONNRESET', code: 'ECONNRESET', syscall: 'read' }
[→pr] error
[→pr] unpipe
proxy←client socket error: { Error: read ECONNRESET
at TCP.onStreamRead (internal/stream_base_commons.js:111:27) errno: 'ECONNRESET', code: 'ECONNRESET', syscall: 'read' }
[→pr] close
[ pr→] closeExtracted with the following code:
const http = require('http');
const https = require('https');
const pem = require('pem');
const net = require('net');
const bedeckAnEventEmitterWithDebuggingOutpour = (emitter, name) => {
const oldEmit = emitter.emit;
emitter.emit = (...args) => {
console.log('[%s] %s', name, args[0]);
oldEmit.apply(emitter, args);
};
};
const createHttpsServer = (callback) => {
pem.createCertificate({
days: 365,
selfSigned: true
}, (error, {serviceKey, certificate, csr}) => {
const server = https.createServer({
ca: csr,
cert: certificate,
key: serviceKey
}, (req, res) => {
setImmediate(() => {
res.writeHead(200, {
connection: 'close'
});
res.end('OK');
});
});
server.on('connection', (socket) => {
bedeckAnEventEmitterWithDebuggingOutpour(socket, '→ser');
socket.on('error', (error) => {
console.log('server←proxy socket error:', error);
});
});
server.listen((error) => {
if (error) {
console.error(error);
} else {
callback(null, server.address().port);
}
});
});
};
const createProxy = (httpsServerPort) => {
const proxy = http.createServer();
proxy.on('connect', (request, requestSocket, head) => {
console.log('---------------------------------------------------------------------');
const serverSocket = net.connect({
port: httpsServerPort
}, 'localhost', () => {
requestSocket.write(
'HTTP/1.1 200 Connection established\r\n\r\n'
);
serverSocket.write(head);
serverSocket.pipe(requestSocket);
requestSocket.pipe(serverSocket);
});
bedeckAnEventEmitterWithDebuggingOutpour(serverSocket, ' pr→');
serverSocket.on('error', (error) => {
console.log('proxy→server connection socket error:', error);
});
bedeckAnEventEmitterWithDebuggingOutpour(requestSocket, '→pr');
requestSocket.on('error', (error) => {
console.log('proxy←client socket error:', error);
throw error;
});
});
proxy.listen(9000);
};
createHttpsServer((error, httpsServerPort) => {
if (error) {
console.error(error);
} else {
createProxy(httpsServerPort);
}
});
crazywako
n-clark
ajimix
ibc
grega913
Johnz86
krisselden
imcotton
addaleax
lpinca
onewayticket255
vinbarnes
gajus
mack1290
diegoug
manjufy
mmomtchev
HardikOO79
Aashir1
cloudnotify
i-m-alok
temp3l
ghost
Vishal8523
In the following code,
pemis a module from NPM, and the rest is an HTTP proxy which serves CONNECT requests and pipes them to an HTTPS server defined in the same script:If you run
curl --proxy http://localhost:9000 https://qweasd/ -k, you'll see Curl receive the reply, and meanwhile the script will almost certainly fail with:This issue is dependent on several parameters:
curl --proxytunnelwork alright.connection: 'close'header.setImmediateorsetTimeoutaround the reply (with, I guess, any timeout value).process.nextTickdoesn't do it. And if the handler instead serves the reply immediately, the server continues to answer perfectly alright until you hit a seemingly different ECONNRESET.If you adorn the sockets with
errorevent handlers, you'll see that the errors actually don't happen on each request, and when they do, it's primarily on the outgoing socket from the proxy to the HTTPS server; and often, but not necessarily, a second ECONNRESET occurs on the incoming socket to the proxy.