X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms.lib.sshd%2Fsrc%2Forg%2Fargeo%2Fcms%2Fssh%2Fcli%2FSshShell.java;fp=org.argeo.cms.lib.sshd%2Fsrc%2Forg%2Fargeo%2Fcms%2Fssh%2Fcli%2FSshShell.java;h=78903a7791cf0da44b5ecf7672a17c2b7c4cf94f;hb=4e548693acc16f97b74eaaa95d6841054a172b85;hp=0000000000000000000000000000000000000000;hpb=7b242851c0094d13cbaca5b68261ad92c873a59f;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms.lib.sshd/src/org/argeo/cms/ssh/cli/SshShell.java b/org.argeo.cms.lib.sshd/src/org/argeo/cms/ssh/cli/SshShell.java
new file mode 100644
index 000000000..78903a779
--- /dev/null
+++ b/org.argeo.cms.lib.sshd/src/org/argeo/cms/ssh/cli/SshShell.java
@@ -0,0 +1,115 @@
+package org.argeo.cms.ssh.cli;
+
+import java.io.IOException;
+import java.lang.management.ManagementFactory;
+import java.net.URI;
+import java.security.GeneralSecurityException;
+import java.security.KeyPair;
+import java.util.List;
+
+import org.apache.commons.cli.CommandLine;
+import org.apache.commons.cli.Option;
+import org.apache.commons.cli.Options;
+import org.apache.sshd.agent.SshAgent;
+import org.apache.sshd.agent.SshAgentFactory;
+import org.apache.sshd.agent.local.LocalAgentFactory;
+import org.apache.sshd.agent.unix.UnixAgentFactory;
+import org.apache.sshd.client.config.keys.ClientIdentityLoader;
+import org.apache.sshd.common.NamedResource;
+import org.apache.sshd.common.config.keys.FilePasswordProvider;
+import org.argeo.api.cli.DescribedCommand;
+import org.argeo.cms.ssh.AbstractSsh;
+import org.argeo.cms.ssh.Ssh;
+
+public class SshShell implements DescribedCommand<String> {
+		private Option portOption;
+
+		@Override
+		public Options getOptions() {
+			Options options = new Options();
+			portOption = Option.builder().option("p").longOpt("port").hasArg().desc("port to connect to").build();
+			options.addOption(portOption);
+			return options;
+		}
+
+		@Override
+		public String apply(List<String> args) {
+			CommandLine cl = toCommandLine(args);
+			String portStr = cl.getOptionValue(portOption);
+			if (portStr == null)
+				portStr = "22";
+
+			String host = cl.getArgList().get(0);
+
+			String uriStr = "ssh://" + host + ":" + portStr + "/";
+			// System.out.println(uriStr);
+			URI uri = URI.create(uriStr);
+
+			Ssh ssh = null;
+			try {
+				ssh = new Ssh(uri);
+				boolean osAgent;
+				SshAgent sshAgent;
+				try {
+					String sshAuthSockentEnv = System.getenv(SshAgent.SSH_AUTHSOCKET_ENV_NAME);
+					if (sshAuthSockentEnv != null) {
+						ssh.getSshClient().getProperties().put(SshAgent.SSH_AUTHSOCKET_ENV_NAME, sshAuthSockentEnv);
+						SshAgentFactory agentFactory = new UnixAgentFactory();
+						ssh.getSshClient().setAgentFactory(agentFactory);
+						sshAgent = agentFactory.createClient(null, ssh.getSshClient());
+						osAgent = true;
+					} else {
+						osAgent = false;
+					}
+				} catch (Exception e) {
+					e.printStackTrace();
+					osAgent = false;
+				}
+
+				if (!osAgent) {
+					SshAgentFactory agentFactory = new LocalAgentFactory();
+					ssh.getSshClient().setAgentFactory(agentFactory);
+					sshAgent = agentFactory.createClient(null, ssh.getSshClient());
+					String keyPath = System.getProperty("user.home") + "/.ssh/id_rsa";
+
+					char[] keyPassword = AbstractSsh.readPassword();
+					NamedResource namedResource = new NamedResource() {
+
+						@Override
+						public String getName() {
+							return keyPath;
+						}
+					};
+					KeyPair keyPair = ClientIdentityLoader.DEFAULT
+							.loadClientIdentities(null, namedResource, FilePasswordProvider.of(new String(keyPassword)))
+							.iterator().next();
+					sshAgent.addIdentity(keyPair, "NO COMMENT");
+				}
+
+//				char[] keyPassword = AbstractSsh.readPassword();
+//				SshKeyPair keyPair = SshKeyPair.loadDefault(keyPassword);
+//				Arrays.fill(keyPassword, '*');
+//				ssh.setSshKeyPair(keyPair);
+//				ssh.authenticate();
+				ssh.verifyAuth();
+
+				long jvmUptime = ManagementFactory.getRuntimeMXBean().getUptime();
+				System.out.println("Ssh available in " + jvmUptime + " ms.");
+
+				AbstractSsh.openShell(ssh);
+			} catch (IOException | GeneralSecurityException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			} finally {
+				if (ssh != null)
+					ssh.closeSession();
+			}
+			return null;
+		}
+
+		@Override
+		public String getDescription() {
+			return "Launch a static CMS.";
+		}
+
+	}
\ No newline at end of file