Left: | ||
Right: |
LEFT | RIGHT |
---|---|
1 package org.adblockplus.brazil; | 1 package org.adblockplus.brazil; |
2 | 2 |
3 import java.io.IOException; | 3 import java.io.IOException; |
4 import java.io.InputStream; | 4 import java.io.InputStream; |
5 import java.io.OutputStream; | 5 import java.io.OutputStream; |
6 import java.net.InetAddress; | 6 import java.net.InetAddress; |
7 import java.net.Socket; | 7 import java.net.Socket; |
8 import java.util.Properties; | |
9 | 8 |
10 import sunlabs.brazil.server.Handler; | |
11 import sunlabs.brazil.server.Request; | 9 import sunlabs.brazil.server.Request; |
12 import sunlabs.brazil.server.Server; | 10 import sunlabs.brazil.server.Server; |
13 import sunlabs.brazil.util.MatchString; | 11 import sunlabs.brazil.util.MatchString; |
14 import android.util.Log; | |
15 | 12 |
16 /** | 13 /** |
17 * <code>RequestHandler</code> implements a SSL tunnel. | 14 * <code>RequestHandler</code> implements a SSL tunnel. |
18 * | 15 * |
19 * The following configuration parameters are used to initialize this | 16 * The following configuration parameters are used to initialize this |
20 * <code>Handler</code>: | 17 * <code>Handler</code>: |
21 * <dl class=props> | 18 * <dl class=props> |
22 * | 19 * |
23 * <dt>prefix, suffix, glob, match | 20 * <dt>prefix, suffix, glob, match |
24 * <dd>Specify the URL that triggers this handler. (See {@link MatchString}). | 21 * <dd>Specify the URL that triggers this handler. (See {@link MatchString}). |
(...skipping 14 matching lines...) Expand all Loading... | |
39 * handler=https | 36 * handler=https |
40 * https.class=org.adblockplus.brazil.SSLConnectionHandler | 37 * https.class=org.adblockplus.brazil.SSLConnectionHandler |
41 * </pre> | 38 * </pre> |
42 * | 39 * |
43 * See the description under {@link sunlabs.brazil.server.Handler#respond | 40 * See the description under {@link sunlabs.brazil.server.Handler#respond |
44 * respond} for a more detailed explanation. | 41 * respond} for a more detailed explanation. |
45 * | 42 * |
46 * Original source by Jochen Luell, PAW (http://paw-project.sourceforge.net/) | 43 * Original source by Jochen Luell, PAW (http://paw-project.sourceforge.net/) |
47 */ | 44 */ |
48 | 45 |
49 public class SSLConnectionHandler implements Handler | 46 public class SSLConnectionHandler extends BaseRequestHandler |
50 { | 47 { |
51 public static final String PROXY_HOST = "proxyHost"; | |
Felix Dahlke
2012/11/09 06:04:32
The indentation level in this file seems to be off
Andrey Novikov
2012/11/09 09:23:47
I will fix it after review.
Felix Dahlke
2012/11/09 14:40:46
Thanks, it would ruin the diffs :D
| |
52 public static final String PROXY_PORT = "proxyPort"; | |
53 public static final String AUTH = "auth"; | |
54 | |
55 private String prefix; | |
56 | |
57 private String proxyHost; | |
58 private int proxyPort = 80; | |
59 private String auth; | |
60 | |
61 @Override | |
62 public boolean init(Server server, String prefix) | |
63 { | |
64 this.prefix = prefix; | |
65 | |
66 Properties props = server.props; | |
67 | |
68 proxyHost = props.getProperty(prefix + PROXY_HOST); | |
69 | |
70 String s = props.getProperty(prefix + PROXY_PORT); | |
71 try | |
72 { | |
73 proxyPort = Integer.decode(s).intValue(); | |
74 } | |
75 catch (Exception e) | |
76 { | |
Felix Dahlke
2012/11/09 06:04:32
As in RequestHandler.init(), a comment would be ni
Andrey Novikov
2012/11/12 08:53:12
Done.
| |
77 } | |
78 | |
79 auth = props.getProperty(prefix + AUTH); | |
80 | |
81 return true; | |
82 } | |
83 | |
84 @Override | 48 @Override |
85 public boolean respond(Request request) throws IOException | 49 public boolean respond(Request request) throws IOException |
86 { | 50 { |
87 if (!request.method.equals("CONNECT")) | 51 if (!request.method.equals("CONNECT")) |
88 return false; | 52 return false; |
89 | 53 |
90 request.log(Server.LOG_LOG, prefix, "SSL connection to " + reque st.url); | 54 request.log(Server.LOG_LOG, prefix, "SSL connection to " + reque st.url); |
91 | 55 |
92 String host = null; | 56 String host = null; |
93 int port = 0; | 57 int port = 0; |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
145 ConnectionHandler server = new ConnectionHandler(serverS ocket, request.sock); | 109 ConnectionHandler server = new ConnectionHandler(serverS ocket, request.sock); |
146 client.start(); | 110 client.start(); |
147 server.start(); | 111 server.start(); |
148 | 112 |
149 // Wait for connections to close | 113 // Wait for connections to close |
150 client.join(); | 114 client.join(); |
151 server.join(); | 115 server.join(); |
152 } | 116 } |
153 catch (InterruptedException e) | 117 catch (InterruptedException e) |
154 { | 118 { |
155 » » » Log.e(prefix, "Data exchange error", e); | 119 » » request.log(Server.LOG_ERROR, prefix, "Data exchange error: " + e.getMessage()); |
156 } | 120 } |
157 | 121 |
158 // Close connection | 122 // Close connection |
159 serverSocket.close(); | 123 serverSocket.close(); |
160 request.log(Server.LOG_LOG, prefix, "SSL connection closed"); | 124 request.log(Server.LOG_LOG, prefix, "SSL connection closed"); |
161 | 125 |
162 return true; | 126 return true; |
163 } | 127 } |
164 | 128 |
165 private class ConnectionHandler extends Thread | 129 private class ConnectionHandler extends Thread |
(...skipping 16 matching lines...) Expand all Loading... | |
182 try | 146 try |
183 { | 147 { |
184 while ((count = in.read(buf, 0, buf.length)) != -1) | 148 while ((count = in.read(buf, 0, buf.length)) != -1) |
185 { | 149 { |
186 out.write(buf, 0, count); | 150 out.write(buf, 0, count); |
187 } | 151 } |
188 out.flush(); | 152 out.flush(); |
189 } | 153 } |
190 catch (IOException e) | 154 catch (IOException e) |
191 { | 155 { |
192 e.printStackTrace(); | 156 e.printStackTrace(); |
Felix Dahlke
2012/11/09 06:04:32
Log.e()?
Andrey Novikov
2012/11/09 09:23:47
No, should remove Log.e above. This is not Android
Felix Dahlke
2012/11/09 14:40:46
I see.
| |
193 } | 157 } |
194 } | 158 } |
195 } | 159 } |
196 } | 160 } |
LEFT | RIGHT |