First tests with Apache SSHD client

[lgpl/argeo-commons.git] / org.argeo.maintenance / src / org / argeo / maintenance / backup / SshSync.java

diff --git a/org.argeo.maintenance/src/org/argeo/maintenance/backup/SshSync.java b/org.argeo.maintenance/src/org/argeo/maintenance/backup/SshSync.java
new file mode 100644 (file)
index 0000000..72eb1d8
--- /dev/null
+++ b/org.argeo.maintenance/src/org/argeo/maintenance/backup/SshSync.java
@@ -0,0 +1,60 @@
+package org.argeo.maintenance.backup;
+
+import java.io.Console;
+import java.io.IOException;
+import java.util.HashSet;
+import java.util.Set;
+
+import org.apache.sshd.client.SshClient;
+import org.apache.sshd.client.channel.ClientChannel;
+import org.apache.sshd.client.channel.ClientChannelEvent;
+import org.apache.sshd.client.future.ConnectFuture;
+import org.apache.sshd.client.session.ClientSession;
+import org.apache.sshd.common.util.io.NoCloseInputStream;
+import org.apache.sshd.common.util.io.NoCloseOutputStream;
+
+public class SshSync {
+       public static void main(String[] args) {
+               
+               String login = System.getProperty("user.name");
+               Console console = System.console();
+               char[] password = console.readPassword();
+               String host = "localhost";
+               int port = 22;
+
+               try (SshClient client = SshClient.setUpDefaultClient()) {
+                       client.start();
+
+//                     SimpleClient simpleClient= AbstractSimpleClientSessionCreator.wrap(client, null);
+//                     simpleClient.sessionLogin(host, login, password);
+
+                       ConnectFuture connectFuture = client.connect(login, host, port);
+                       connectFuture.await();
+                       ClientSession session = connectFuture.getSession();
+
+                       try {
+
+                               session.addPasswordIdentity(new String(password));
+                               session.auth().verify(1000l);
+
+                               try (ClientChannel channel = session.createChannel(ClientChannel.CHANNEL_SHELL)) {
+                                       channel.setIn(new NoCloseInputStream(System.in));
+                                       channel.setOut(new NoCloseOutputStream(System.out));
+                                       channel.setErr(new NoCloseOutputStream(System.err));
+                                       channel.open();
+
+                                       Set<ClientChannelEvent> events = new HashSet<>();
+                                       events.add(ClientChannelEvent.CLOSED);
+                                       channel.waitFor(events, 0);
+                               } finally {
+                                       session.close(false);
+                               }
+                       } finally {
+                               client.stop();
+                       }
+               } catch (IOException e) {
+                       // TODO Auto-generated catch block
+                       e.printStackTrace();
+               }
+       }
+}