feat: add jump host ssh

feat: add jump host ssh

Author: rjourdan04

warpgate-admin/src/api/ssh_connection_test.rs

@@ -18,6 +18,10 @@ pub struct Api;
 struct CheckSshHostKeyRequest {
     host: String,
     port: u16,
+    username: Option<String>,
+    allow_insecure_algos: Option<bool>,
+    auth: Option<SSHTargetAuth>,
+    jump_host: Option<warpgate_common::SSHJumpHostOptions>,
 }
 
 #[derive(Object)]
@@ -55,11 +59,14 @@ impl Api {
             RCCommand::Connect(TargetSSHOptions {
                 host: body.host.clone(),
                 port: body.port,
-                username: String::new(),
-                allow_insecure_algos: None,
-                auth: SSHTargetAuth::Password(SshTargetPasswordAuth {
-                    password: String::new().into(),
+                username: body.username.clone().unwrap_or_default(),
+                allow_insecure_algos: body.allow_insecure_algos,
+                auth: body.auth.clone().unwrap_or_else(|| {
+                    SSHTargetAuth::Password(SshTargetPasswordAuth {
+                        password: String::new().into(),
+                    })
                 }),
+                jump_host: body.jump_host.clone(),
             }),
             None,
         ));
@@ -68,6 +75,10 @@ impl Api {
             let key = loop {
                 match handles.event_rx.recv().await {
                     Some(RCEvent::HostKeyReceived(key)) => break key,
+                    Some(RCEvent::HostKeyUnknown(key, reply)) => {
+                        let _ = reply.send(true);
+                        break key;
+                    },
                     Some(RCEvent::ConnectionError(err)) => return Err(anyhow::Error::from(err)),
                     Some(RCEvent::Error(err)) => return Err(err),
                     None => anyhow::bail!("Failed to connect to target"),

warpgate-common/src/config/target.rs

@@ -26,6 +26,17 @@ impl Default for KubernetesTargetCertificateAuth {
     }
 }
 
+#[derive(Debug, Deserialize, Serialize, Clone, Object, Default)]
+pub struct SSHJumpHostOptions {
+    pub host: String,
+    #[serde(default = "_default_ssh_port")]
+    pub port: u16,
+    #[serde(default = "_default_username")]
+    pub username: String,
+    #[serde(default)]
+    pub auth: SSHTargetAuth,
+}
+
 #[derive(Debug, Deserialize, Serialize, Clone, Object)]
 pub struct TargetSSHOptions {
     pub host: String,
@@ -37,6 +48,8 @@ pub struct TargetSSHOptions {
     pub allow_insecure_algos: Option<bool>,
     #[serde(default)]
     pub auth: SSHTargetAuth,
+    #[serde(default)]
+    pub jump_host: Option<SSHJumpHostOptions>,
 }
 
 #[derive(Debug, Deserialize, Serialize, Clone, PartialEq, Eq, Union)]