1 package org.apache.maven.wagon.providers.ssh.knownhost;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.io.BufferedReader;
23 import java.io.IOException;
24 import java.io.InputStream;
25 import java.io.StringReader;
26 import java.util.HashSet;
27 import java.util.Set;
28
29 import org.codehaus.plexus.util.IOUtil;
30 import org.codehaus.plexus.util.StringOutputStream;
31 import org.codehaus.plexus.util.StringUtils;
32
33
34
35
36
37
38
39 public class StreamKnownHostsProvider
40 extends AbstractKnownHostsProvider
41 {
42
43 public StreamKnownHostsProvider( InputStream stream )
44 throws IOException
45 {
46 try
47 {
48 StringOutputStream stringOutputStream = new StringOutputStream();
49 IOUtil.copy( stream, stringOutputStream );
50 this.contents = stringOutputStream.toString();
51
52 this.knownHosts = this.loadKnownHosts( this.contents );
53 }
54 finally
55 {
56 IOUtil.close( stream );
57 }
58 }
59
60 protected Set<KnownHostEntry> loadKnownHosts( String contents )
61 throws IOException
62 {
63 Set<KnownHostEntry> hosts = new HashSet<KnownHostEntry>();
64
65 BufferedReader br = new BufferedReader( new StringReader( contents ) );
66
67 String line = null;
68
69 do
70 {
71 line = br.readLine();
72 if ( line != null )
73 {
74 String tokens[] = StringUtils.split( line );
75 if ( tokens.length == 3 )
76 {
77 hosts.add( new KnownHostEntry( tokens[0], tokens[1], tokens[2] ) );
78 }
79 }
80
81 }
82 while ( line != null );
83
84 return hosts;
85 }
86 }