Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
fe7c4c2f5e | |||
ab1ec84832 | |||
156abbf5b4 | |||
1a90566622 |
13
changelog.md
13
changelog.md
@ -1,5 +1,18 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2025-03-12 - 3.41.4 - fix(tls/sni)
|
||||||
|
Improve logging for TLS session resumption by extracting and logging SNI values from ClientHello messages.
|
||||||
|
|
||||||
|
- Added logging to output the extracted SNI value during renegotiation, initial ClientHello and in the SNI handler.
|
||||||
|
- Enhanced error handling during SNI extraction to aid troubleshooting of TLS session resumption issues.
|
||||||
|
|
||||||
|
## 2025-03-12 - 3.41.3 - fix(TLS/SNI)
|
||||||
|
Improve TLS session resumption handling and logging. Now, session resumption attempts are always logged with details, and connections without a proper SNI are rejected when allowSessionTicket is disabled. In addition, empty SNI extensions are explicitly treated as missing, ensuring stricter and more consistent TLS handshake validation.
|
||||||
|
|
||||||
|
- Always log session resumption in both renegotiation and initial ClientHello processing.
|
||||||
|
- Terminate connections that attempt session resumption without SNI when allowSessionTicket is false.
|
||||||
|
- Treat empty SNI extensions as absence of SNI to improve consistency in TLS handshake processing.
|
||||||
|
|
||||||
## 2025-03-11 - 3.41.2 - fix(SniHandler)
|
## 2025-03-11 - 3.41.2 - fix(SniHandler)
|
||||||
Refactor hasSessionResumption to return detailed session resumption info
|
Refactor hasSessionResumption to return detailed session resumption info
|
||||||
|
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@push.rocks/smartproxy",
|
"name": "@push.rocks/smartproxy",
|
||||||
"version": "3.41.2",
|
"version": "3.41.4",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "A powerful proxy package that effectively handles high traffic, with features such as SSL/TLS support, port proxying, WebSocket handling, dynamic routing with authentication options, and automatic ACME certificate management.",
|
"description": "A powerful proxy package that effectively handles high traffic, with features such as SSL/TLS support, port proxying, WebSocket handling, dynamic routing with authentication options, and automatic ACME certificate management.",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartproxy',
|
name: '@push.rocks/smartproxy',
|
||||||
version: '3.41.2',
|
version: '3.41.4',
|
||||||
description: 'A powerful proxy package that effectively handles high traffic, with features such as SSL/TLS support, port proxying, WebSocket handling, dynamic routing with authentication options, and automatic ACME certificate management.'
|
description: 'A powerful proxy package that effectively handles high traffic, with features such as SSL/TLS support, port proxying, WebSocket handling, dynamic routing with authentication options, and automatic ACME certificate management.'
|
||||||
}
|
}
|
||||||
|
@ -943,20 +943,32 @@ export class PortProxy {
|
|||||||
// Analyze for session resumption attempt (session ticket or PSK)
|
// Analyze for session resumption attempt (session ticket or PSK)
|
||||||
const resumptionInfo = SniHandler.hasSessionResumption(renegChunk, this.settings.enableTlsDebugLogging);
|
const resumptionInfo = SniHandler.hasSessionResumption(renegChunk, this.settings.enableTlsDebugLogging);
|
||||||
|
|
||||||
// Only block if there's a session ticket without SNI
|
if (resumptionInfo.isResumption) {
|
||||||
if (resumptionInfo.isResumption && !resumptionInfo.hasSNI) {
|
// Always log resumption attempt for easier debugging
|
||||||
|
// Try to extract SNI for logging
|
||||||
|
const extractedSNI = SniHandler.extractSNI(renegChunk, this.settings.enableTlsDebugLogging);
|
||||||
console.log(
|
console.log(
|
||||||
`[${connectionId}] Session ticket detected in renegotiation without SNI and allowSessionTicket=false. ` +
|
`[${connectionId}] Session resumption detected in renegotiation. ` +
|
||||||
`Terminating connection to force new TLS handshake.`
|
`Has SNI: ${resumptionInfo.hasSNI ? 'Yes' : 'No'}, ` +
|
||||||
|
`SNI value: ${extractedSNI || 'None'}, ` +
|
||||||
|
`allowSessionTicket: ${this.settings.allowSessionTicket}`
|
||||||
);
|
);
|
||||||
this.initiateCleanupOnce(record, 'session_ticket_blocked');
|
|
||||||
return;
|
// Block if there's session resumption without SNI
|
||||||
} else if (resumptionInfo.isResumption && resumptionInfo.hasSNI) {
|
if (!resumptionInfo.hasSNI) {
|
||||||
if (this.settings.enableTlsDebugLogging) {
|
|
||||||
console.log(
|
console.log(
|
||||||
`[${connectionId}] Session ticket with SNI detected in renegotiation. ` +
|
`[${connectionId}] Session resumption detected in renegotiation without SNI and allowSessionTicket=false. ` +
|
||||||
`Allowing connection since SNI is present.`
|
`Terminating connection to force new TLS handshake.`
|
||||||
);
|
);
|
||||||
|
this.initiateCleanupOnce(record, 'session_ticket_blocked');
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
if (this.settings.enableDetailedLogging) {
|
||||||
|
console.log(
|
||||||
|
`[${connectionId}] Session resumption with SNI detected in renegotiation. ` +
|
||||||
|
`Allowing connection since SNI is present.`
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -1575,25 +1587,37 @@ export class PortProxy {
|
|||||||
// Analyze for session resumption attempt
|
// Analyze for session resumption attempt
|
||||||
const resumptionInfo = SniHandler.hasSessionResumption(chunk, this.settings.enableTlsDebugLogging);
|
const resumptionInfo = SniHandler.hasSessionResumption(chunk, this.settings.enableTlsDebugLogging);
|
||||||
|
|
||||||
// Only block if there's a session ticket without SNI
|
if (resumptionInfo.isResumption) {
|
||||||
if (resumptionInfo.isResumption && !resumptionInfo.hasSNI) {
|
// Always log resumption attempt for easier debugging
|
||||||
|
// Try to extract SNI for logging
|
||||||
|
const extractedSNI = SniHandler.extractSNI(chunk, this.settings.enableTlsDebugLogging);
|
||||||
console.log(
|
console.log(
|
||||||
`[${connectionId}] Session ticket detected in initial ClientHello without SNI and allowSessionTicket=false. ` +
|
`[${connectionId}] Session resumption detected in initial ClientHello. ` +
|
||||||
`Terminating connection to force new TLS handshake.`
|
`Has SNI: ${resumptionInfo.hasSNI ? 'Yes' : 'No'}, ` +
|
||||||
|
`SNI value: ${extractedSNI || 'None'}, ` +
|
||||||
|
`allowSessionTicket: ${this.settings.allowSessionTicket}`
|
||||||
);
|
);
|
||||||
if (connectionRecord.incomingTerminationReason === null) {
|
|
||||||
connectionRecord.incomingTerminationReason = 'session_ticket_blocked';
|
// Block if there's session resumption without SNI
|
||||||
this.incrementTerminationStat('incoming', 'session_ticket_blocked');
|
if (!resumptionInfo.hasSNI) {
|
||||||
}
|
|
||||||
socket.end();
|
|
||||||
this.cleanupConnection(connectionRecord, 'session_ticket_blocked');
|
|
||||||
return;
|
|
||||||
} else if (resumptionInfo.isResumption && resumptionInfo.hasSNI) {
|
|
||||||
if (this.settings.enableTlsDebugLogging) {
|
|
||||||
console.log(
|
console.log(
|
||||||
`[${connectionId}] Session ticket with SNI detected in initial ClientHello. ` +
|
`[${connectionId}] Session resumption detected in initial ClientHello without SNI and allowSessionTicket=false. ` +
|
||||||
`Allowing connection since SNI is present.`
|
`Terminating connection to force new TLS handshake.`
|
||||||
);
|
);
|
||||||
|
if (connectionRecord.incomingTerminationReason === null) {
|
||||||
|
connectionRecord.incomingTerminationReason = 'session_ticket_blocked';
|
||||||
|
this.incrementTerminationStat('incoming', 'session_ticket_blocked');
|
||||||
|
}
|
||||||
|
socket.end();
|
||||||
|
this.cleanupConnection(connectionRecord, 'session_ticket_blocked');
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
if (this.settings.enableDetailedLogging) {
|
||||||
|
console.log(
|
||||||
|
`[${connectionId}] Session resumption with SNI detected in initial ClientHello. ` +
|
||||||
|
`Allowing connection since SNI is present.`
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -1949,25 +1973,37 @@ export class PortProxy {
|
|||||||
// Analyze for session resumption attempt
|
// Analyze for session resumption attempt
|
||||||
const resumptionInfo = SniHandler.hasSessionResumption(chunk, this.settings.enableTlsDebugLogging);
|
const resumptionInfo = SniHandler.hasSessionResumption(chunk, this.settings.enableTlsDebugLogging);
|
||||||
|
|
||||||
// Only block if there's a session ticket without SNI
|
if (resumptionInfo.isResumption) {
|
||||||
if (resumptionInfo.isResumption && !resumptionInfo.hasSNI) {
|
// Always log resumption attempt for easier debugging
|
||||||
|
// Try to extract SNI for logging
|
||||||
|
const extractedSNI = SniHandler.extractSNI(chunk, this.settings.enableTlsDebugLogging);
|
||||||
console.log(
|
console.log(
|
||||||
`[${connectionId}] Session ticket detected in initial ClientHello without SNI and allowSessionTicket=false. ` +
|
`[${connectionId}] Session resumption detected in SNI handler. ` +
|
||||||
`Terminating connection to force new TLS handshake.`
|
`Has SNI: ${resumptionInfo.hasSNI ? 'Yes' : 'No'}, ` +
|
||||||
|
`SNI value: ${extractedSNI || 'None'}, ` +
|
||||||
|
`allowSessionTicket: ${this.settings.allowSessionTicket}`
|
||||||
);
|
);
|
||||||
if (connectionRecord.incomingTerminationReason === null) {
|
|
||||||
connectionRecord.incomingTerminationReason = 'session_ticket_blocked';
|
// Block if there's session resumption without SNI
|
||||||
this.incrementTerminationStat('incoming', 'session_ticket_blocked');
|
if (!resumptionInfo.hasSNI) {
|
||||||
}
|
|
||||||
socket.end();
|
|
||||||
this.cleanupConnection(connectionRecord, 'session_ticket_blocked');
|
|
||||||
return;
|
|
||||||
} else if (resumptionInfo.isResumption && resumptionInfo.hasSNI) {
|
|
||||||
if (this.settings.enableTlsDebugLogging) {
|
|
||||||
console.log(
|
console.log(
|
||||||
`[${connectionId}] Session ticket with SNI detected in initial ClientHello. ` +
|
`[${connectionId}] Session resumption detected in SNI handler without SNI and allowSessionTicket=false. ` +
|
||||||
`Allowing connection since SNI is present.`
|
`Terminating connection to force new TLS handshake.`
|
||||||
);
|
);
|
||||||
|
if (connectionRecord.incomingTerminationReason === null) {
|
||||||
|
connectionRecord.incomingTerminationReason = 'session_ticket_blocked';
|
||||||
|
this.incrementTerminationStat('incoming', 'session_ticket_blocked');
|
||||||
|
}
|
||||||
|
socket.end();
|
||||||
|
this.cleanupConnection(connectionRecord, 'session_ticket_blocked');
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
if (this.settings.enableDetailedLogging) {
|
||||||
|
console.log(
|
||||||
|
`[${connectionId}] Session resumption with SNI detected in SNI handler. ` +
|
||||||
|
`Allowing connection since SNI is present.`
|
||||||
|
);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -410,8 +410,42 @@ export class SniHandler {
|
|||||||
pos += 2;
|
pos += 2;
|
||||||
|
|
||||||
if (extensionType === this.TLS_SNI_EXTENSION_TYPE) {
|
if (extensionType === this.TLS_SNI_EXTENSION_TYPE) {
|
||||||
hasSNI = true;
|
// Check that the SNI extension actually has content
|
||||||
log('Found SNI extension');
|
if (extensionLength > 0) {
|
||||||
|
hasSNI = true;
|
||||||
|
|
||||||
|
// Try to extract the actual SNI value for logging
|
||||||
|
try {
|
||||||
|
// Skip to server_name_list_length (2 bytes)
|
||||||
|
const tempPos = pos;
|
||||||
|
if (tempPos + 2 <= extensionsEnd) {
|
||||||
|
const nameListLength = (buffer[tempPos] << 8) + buffer[tempPos + 1];
|
||||||
|
|
||||||
|
// Skip server_name_list_length (2 bytes)
|
||||||
|
if (tempPos + 2 + 1 <= extensionsEnd) {
|
||||||
|
// Check name_type (should be 0 for hostname)
|
||||||
|
if (buffer[tempPos + 2] === 0) {
|
||||||
|
// Skip name_type (1 byte)
|
||||||
|
if (tempPos + 3 + 2 <= extensionsEnd) {
|
||||||
|
// Get name_length (2 bytes)
|
||||||
|
const nameLength = (buffer[tempPos + 3] << 8) + buffer[tempPos + 4];
|
||||||
|
|
||||||
|
// Extract the hostname
|
||||||
|
if (tempPos + 5 + nameLength <= extensionsEnd) {
|
||||||
|
const hostname = buffer.slice(tempPos + 5, tempPos + 5 + nameLength).toString('utf8');
|
||||||
|
log(`Found SNI extension with server_name: ${hostname}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
log(`Error extracting SNI value: ${e}`);
|
||||||
|
log('Found SNI extension with length: ' + extensionLength);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
log('Found empty SNI extension, treating as no SNI');
|
||||||
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -438,6 +472,15 @@ export class SniHandler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Return an object with both flags
|
// Return an object with both flags
|
||||||
|
// For clarity: connections should be blocked if they have session resumption without SNI
|
||||||
|
if (isResumption) {
|
||||||
|
log(`Resumption summary - hasSNI: ${hasSNI ? 'yes' : 'no'}, resumption type: ${
|
||||||
|
hasSessionTicket ? 'session ticket, ' : ''
|
||||||
|
}${hasPSK ? 'PSK, ' : ''}${hasEarlyData ? 'early data, ' : ''}${
|
||||||
|
hasNonEmptySessionId ? 'session ID' : ''
|
||||||
|
}`);
|
||||||
|
}
|
||||||
|
|
||||||
return {
|
return {
|
||||||
isResumption,
|
isResumption,
|
||||||
hasSNI
|
hasSNI
|
||||||
|
Reference in New Issue
Block a user