aljaz/flutter_server_box
1
1
Fork 0
mirror of https://github.com/lollipopkit/flutter_server_box.git synced 2026-02-14 04:05:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

opt.

Browse Source
This commit is contained in:
lollipopkit🏳️‍⚧️
2026-01-15 20:52:11 +08:00
parent 52c80795f4
commit 61f161d8a6
1 changed files with 23 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
lib/core/utils/server.dart
View File

@@ -177,8 +177,8 @@ Future<SSHClient> _genClientInternal(
String? alterUser;
final socket = await () async {
if (socketOverride != null) return socketOverride;
final (socket, hopClients) = await () async {
if (socketOverride != null) return (socketOverride, <SSHClient>[]);
if (followJumpConfig) {
final injectedSpiMap = <String, Spi>{};
@@ -269,7 +269,8 @@ Future<SSHClient> _genClientInternal(
createdClients.add(currentClient);
}
return await currentClient!.forwardLocal(spi.ip, spi.port);
final forwardedSocket = await currentClient!.forwardLocal(spi.ip, spi.port);
return (forwardedSocket, createdClients);
} catch (e) {
// Close all created clients on error to avoid leaks
for (final client in createdClients) {
@@ -288,14 +289,14 @@ Future<SSHClient> _genClientInternal(
// Direct
try {
return await SSHSocket.connect(spi.ip, spi.port, timeout: timeout);
return (await SSHSocket.connect(spi.ip, spi.port, timeout: timeout), <SSHClient>[]);
} catch (e) {
Loggers.app.warning('genClient', e);
if (spi.alterUrl == null) rethrow;
try {
final res = spi.parseAlterUrl();
alterUser = res.$2;
return await SSHSocket.connect(res.$1, res.$3, timeout: timeout);
return (await SSHSocket.connect(res.$1, res.$3, timeout: timeout), <SSHClient>[]);
} catch (e) {
Loggers.app.warning('genClient alterUrl', e);
rethrow;
@@ -339,7 +340,23 @@ Future<SSHClient> _genClientInternal(
);
}
return await buildClient(socket);
final client = await buildClient(socket);
// Tie hop clients' lifetime to the final client: close all hop clients
// when the target client disconnects to avoid leaking SSH connections.
if (hopClients.isNotEmpty) {
client.done.whenComplete(() {
for (final hopClient in hopClients) {
try {
hopClient.close();
} catch (_) {
// Ignore close errors during cleanup
}
}
});
}
return client;
}
typedef _HostKeyPersistCallback = void Function(String storageKey, String fingerprintHex);