Merge pull request #123 from alexander-irion/master

Add parameter disableHostkeyVerification

Author: xtyxtyx

lib/src/ssh_channel.dart

@@ -297,7 +297,12 @@ class SSHChannelController {
     if (_done.isCompleted) return;
     if (_hasSentClose) return;
     _hasSentClose = true;
-    sendMessage(SSH_Message_Channel_Close(recipientChannel: remoteId));
+
+    try {
+      sendMessage(SSH_Message_Channel_Close(recipientChannel: remoteId));
+    } catch (e) {
+      printDebug?.call('SSHChannelController._sendCloseIfNeeded - error: $e');
+    }
   }
 
   void _sendRequestSuccess() {

lib/src/ssh_client.dart

@@ -130,6 +130,9 @@ class SSHClient {
   /// extension. May not be called if the server does not support the extension.
   // final SSHHostKeysHandler? onHostKeys;
 
+  /// Allow to disable hostkey verification, which can be slow in debug mode.
+  final bool disableHostkeyVerification;
+
   /// A [Future] that completes when the transport is closed, or when an error
   /// occurs. After this [Future] completes, [isClosed] will be true and no more
   /// data can be sent or received.
@@ -152,6 +155,7 @@ class SSHClient {
     this.onUserauthBanner,
     this.onAuthenticated,
     this.keepAliveInterval = const Duration(seconds: 10),
+    this.disableHostkeyVerification = false,
   }) {
     _transport = SSHTransport(
       socket,
@@ -162,6 +166,7 @@ class SSHClient {
       onVerifyHostKey: onVerifyHostKey,
       onReady: _handleTransportReady,
       onPacket: _handlePacket,
+      disableHostkeyVerification: disableHostkeyVerification,
     );
 
     _transport.done.then(
@@ -476,7 +481,12 @@ class SSHClient {
       );
     }
     _keepAlive?.stop();
-    _closeChannels();
+
+    try {
+      _closeChannels();
+    } catch (e) {
+      printDebug?.call("SSHClient::_handleTransportClosed - error: $e");
+    }
   }
 
   void _handlePacket(Uint8List payload) {

lib/src/ssh_transport.dart

@@ -72,6 +72,8 @@ class SSHTransport {
   /// Function called when a packet is received.
   final SSHPacketHandler? onPacket;
 
+  final bool disableHostkeyVerification;
+
   /// A [Future] that completes when the transport is closed, or when an error
   /// occurs. After this [Future] completes, [isClosed] will be true and no
   /// more data can be sent or received.
@@ -94,6 +96,7 @@ class SSHTransport {
     this.onVerifyHostKey,
     this.onReady,
     this.onPacket,
+    this.disableHostkeyVerification = false,
   }) {
     _initSocket();
     _startHandshake();
@@ -803,12 +806,14 @@ class SSHTransport {
       sharedSecret: sharedSecret,
     );
 
-    final verified = _verifyHostkey(
-      keyBytes: hostkey,
-      signatureBytes: hostSignature,
-      exchangeHash: exchangeHash,
-    );
-    if (!verified) throw SSHHostkeyError('Signature verification failed');
+    if (!disableHostkeyVerification) {
+      final verified = _verifyHostkey(
+        keyBytes: hostkey,
+        signatureBytes: hostSignature,
+        exchangeHash: exchangeHash,
+      );
+      if (!verified) throw SSHHostkeyError('Signature verification failed');
+    }
 
     _exchangeHash = exchangeHash;
     _sessionId ??= exchangeHash;