diff --git a/examples/pom.xml b/examples/pom.xml index 5f48cb9f..4655f8bd 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -55,7 +55,7 @@ com.hierynomus sshj - 0.24.0 + 0.31.0 diff --git a/examples/src/main/java/net/schmizz/sshj/examples/InMemoryKnownHosts.java b/examples/src/main/java/net/schmizz/sshj/examples/InMemoryKnownHosts.java index f8e94325..27cca58b 100644 --- a/examples/src/main/java/net/schmizz/sshj/examples/InMemoryKnownHosts.java +++ b/examples/src/main/java/net/schmizz/sshj/examples/InMemoryKnownHosts.java @@ -18,7 +18,7 @@ public class InMemoryKnownHosts { public static void main(String[] args) throws IOException { InputStream entry = new ByteArrayInputStream("localhost ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIPmhSBtMctNa4hsZt8QGlsYSE5/gMkjeand69Vj4ir13".getBytes(Charset.defaultCharset())); SSHClient ssh = new SSHClient(); - ssh.addHostKeyVerifier(new InMemoryHostKeyVerifier(entry, Charset.defaultCharset())); + ssh.addHostKeyVerifier(new OpenSSHKnownHosts(new InputStreamReader(entry, Charset.defaultCharset()))); ssh.connect("localhost"); try { ssh.authPublickey(System.getProperty("user.name")); @@ -28,44 +28,4 @@ public class InMemoryKnownHosts { } } - public static class InMemoryHostKeyVerifier implements HostKeyVerifier { - - private final List entries = new ArrayList(); - - public InMemoryHostKeyVerifier(InputStream inputStream, Charset charset) throws IOException { - final OpenSSHKnownHosts.EntryFactory entryFactory = new OpenSSHKnownHosts.EntryFactory(); - BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, charset)); - while(reader.ready()) { - String line = reader.readLine(); - try { - OpenSSHKnownHosts.KnownHostEntry entry = entryFactory.parseEntry(line); - if (entry != null) { - entries.add(entry); - } - } catch (Exception e) { - //log error - } - } - } - - @Override - public boolean verify(String hostname, int port, PublicKey key) { - final KeyType type = KeyType.fromKey(key); - if (type == KeyType.UNKNOWN) { - return false; - } - - for (OpenSSHKnownHosts.KnownHostEntry e : entries) { - try { - if (e.appliesTo(type, hostname) && e.verify(key)) { - return true; - } - } catch (IOException ioe) { - //log error - } - } - return false; - } - } - } diff --git a/examples/src/main/java/net/schmizz/sshj/examples/LocalPF.java b/examples/src/main/java/net/schmizz/sshj/examples/LocalPF.java index b4a10fad..4732819d 100644 --- a/examples/src/main/java/net/schmizz/sshj/examples/LocalPF.java +++ b/examples/src/main/java/net/schmizz/sshj/examples/LocalPF.java @@ -2,6 +2,7 @@ package net.schmizz.sshj.examples; import net.schmizz.sshj.SSHClient; import net.schmizz.sshj.connection.channel.direct.LocalPortForwarder; +import net.schmizz.sshj.connection.channel.direct.Parameters; import java.io.IOException; import java.net.InetSocketAddress; @@ -28,8 +29,8 @@ public class LocalPF { * _We_ listen on localhost:8080 and forward all connections on to server, which then forwards it to * google.com:80 */ - final LocalPortForwarder.Parameters params - = new LocalPortForwarder.Parameters("0.0.0.0", 8080, "google.com", 80); + final Parameters params + = new Parameters("0.0.0.0", 8080, "google.com", 80); final ServerSocket ss = new ServerSocket(); ss.setReuseAddress(true); ss.bind(new InetSocketAddress(params.getLocalHost(), params.getLocalPort()));