fix(PortProxy): Fix connection handling to include timeouts for SNI-enabled connections.
This commit is contained in:
parent
e47436608f
commit
f2f4e47893
@ -1,5 +1,11 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2025-02-23 - 3.10.2 - fix(PortProxy)
|
||||||
|
Fix connection handling to include timeouts for SNI-enabled connections.
|
||||||
|
|
||||||
|
- Added initial data timeout for SNI-enabled connections to improve connection handling.
|
||||||
|
- Cleared timeout once data is received to prevent premature socket closure.
|
||||||
|
|
||||||
## 2025-02-22 - 3.10.1 - fix(PortProxy)
|
## 2025-02-22 - 3.10.1 - fix(PortProxy)
|
||||||
Improve socket cleanup logic to prevent potential resource leaks
|
Improve socket cleanup logic to prevent potential resource leaks
|
||||||
|
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartproxy',
|
name: '@push.rocks/smartproxy',
|
||||||
version: '3.10.1',
|
version: '3.10.2',
|
||||||
description: 'a proxy for handling high workloads of proxying'
|
description: 'a proxy for handling high workloads of proxying'
|
||||||
}
|
}
|
||||||
|
@ -355,9 +355,18 @@ export class PortProxy {
|
|||||||
to!.on('end', handleClose('outgoing'));
|
to!.on('end', handleClose('outgoing'));
|
||||||
};
|
};
|
||||||
|
|
||||||
// For SNI-enabled connections, peek at the first chunk.
|
// For SNI-enabled connections, set an initial data timeout before waiting for data.
|
||||||
if (this.settings.sniEnabled) {
|
if (this.settings.sniEnabled) {
|
||||||
|
// Set an initial timeout for receiving data (e.g., 5 seconds)
|
||||||
|
socket.setTimeout(5000, () => {
|
||||||
|
console.log(`Initial data timeout for ${remoteIP}`);
|
||||||
|
socket.end();
|
||||||
|
cleanupOnce();
|
||||||
|
});
|
||||||
|
|
||||||
socket.once('data', (chunk: Buffer) => {
|
socket.once('data', (chunk: Buffer) => {
|
||||||
|
// Clear the initial timeout since data has been received
|
||||||
|
socket.setTimeout(0);
|
||||||
initialDataReceived = true;
|
initialDataReceived = true;
|
||||||
const serverName = extractSNI(chunk) || '';
|
const serverName = extractSNI(chunk) || '';
|
||||||
console.log(`Received connection from ${remoteIP} with SNI: ${serverName}`);
|
console.log(`Received connection from ${remoteIP} with SNI: ${serverName}`);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user