X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.maintenance%2Fsrc%2Forg%2Fargeo%2Fmaintenance%2Fbackup%2FSshSync.java;fp=org.argeo.maintenance%2Fsrc%2Forg%2Fargeo%2Fmaintenance%2Fbackup%2FSshSync.java;h=72eb1d817fa13cebe7887f4e0cb90e816d824a24;hb=17dd64ee0a7c7873e87689e0371f425cbca924d1;hp=0000000000000000000000000000000000000000;hpb=e536b7a675138ca2d0257ac6b3b4d84ecb41efb5;p=lgpl%2Fargeo-commons.git

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
index 000000000..72eb1d817
--- /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();
+		}
+	}
+}