LEFT | RIGHT |
1 /* | 1 /* |
2 * This file is part of Adblock Plus <http://adblockplus.org/>, | 2 * This file is part of Adblock Plus <http://adblockplus.org/>, |
3 * Copyright (C) 2006-2014 Eyeo GmbH | 3 * Copyright (C) 2006-2014 Eyeo GmbH |
4 * | 4 * |
5 * Adblock Plus is free software: you can redistribute it and/or modify | 5 * Adblock Plus is free software: you can redistribute it and/or modify |
6 * it under the terms of the GNU General Public License version 3 as | 6 * it under the terms of the GNU General Public License version 3 as |
7 * published by the Free Software Foundation. | 7 * published by the Free Software Foundation. |
8 * | 8 * |
9 * Adblock Plus is distributed in the hope that it will be useful, | 9 * Adblock Plus is distributed in the hope that it will be useful, |
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
12 * GNU General Public License for more details. | 12 * GNU General Public License for more details. |
13 * | 13 * |
14 * You should have received a copy of the GNU General Public License | 14 * You should have received a copy of the GNU General Public License |
15 * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. | 15 * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
16 */ | 16 */ |
17 | 17 |
18 package org.adblockplus.android; | 18 package org.adblockplus.android; |
19 | 19 |
20 import java.io.InputStream; | 20 import java.io.InputStream; |
21 import java.net.HttpURLConnection; | 21 import java.net.HttpURLConnection; |
22 import java.net.URL; | 22 import java.net.URL; |
23 import java.util.List; | 23 import java.util.List; |
24 | 24 |
25 import org.adblockplus.libadblockplus.AdblockPlusException; | 25 import org.adblockplus.libadblockplus.AdblockPlusException; |
| 26 import org.adblockplus.libadblockplus.HeaderEntry; |
26 import org.adblockplus.libadblockplus.ServerResponse; | 27 import org.adblockplus.libadblockplus.ServerResponse; |
27 import org.adblockplus.libadblockplus.WebRequest; | 28 import org.adblockplus.libadblockplus.WebRequest; |
28 import org.adblockplus.libadblockplus.ServerResponse.NsStatus; | 29 import org.adblockplus.libadblockplus.ServerResponse.NsStatus; |
29 | 30 |
30 import android.util.Log; | 31 import android.util.Log; |
31 | 32 |
32 import com.github.rjeschke.neetutils.Strings; | |
33 import com.github.rjeschke.neetutils.collections.Tuple; | |
34 | |
35 public class AndroidWebRequest extends WebRequest | 33 public class AndroidWebRequest extends WebRequest |
36 { | 34 { |
37 public final String TAG = Utils.getTag(WebRequest.class); | 35 public final String TAG = Utils.getTag(WebRequest.class); |
38 | 36 |
| 37 private static final int INITIAL_BUFFER_SIZE = 65536; |
| 38 private static final int BUFFER_GROWTH_DELTA = 65536; |
| 39 |
39 @Override | 40 @Override |
40 public ServerResponse httpGET(final String urlStr, final List<Tuple<String, St
ring>> headers) | 41 public ServerResponse httpGET(final String urlStr, final List<HeaderEntry> hea
ders) |
41 { | 42 { |
42 try | 43 try |
43 { | 44 { |
44 final URL url = new URL(urlStr); | 45 final URL url = new URL(urlStr); |
45 Log.d(this.TAG, "Downloading from: " + url); | 46 Log.d(this.TAG, "Downloading from: " + url); |
46 | 47 |
47 final HttpURLConnection connection = (HttpURLConnection)url.openConnection
(); | 48 final HttpURLConnection connection = (HttpURLConnection) url.openConnectio
n(); |
48 connection.setRequestMethod("GET"); | 49 connection.setRequestMethod("GET"); |
49 connection.connect(); | 50 connection.connect(); |
50 | 51 |
51 final ServerResponse response = new ServerResponse(); | 52 final ServerResponse response = new ServerResponse(); |
52 response.setResponseStatus(connection.getResponseCode()); | 53 response.setResponseStatus(connection.getResponseCode()); |
53 | 54 |
54 if (response.getResponseStatus() == 200) | 55 if (response.getResponseStatus() == 200) |
55 { | 56 { |
56 final InputStream in = connection.getInputStream(); | 57 final InputStream in = connection.getInputStream(); |
57 | 58 |
58 final byte[] buffer = new byte[4096]; | 59 final byte[] buffer = new byte[4096]; |
59 | 60 |
60 byte[] out = new byte[65536]; | 61 byte[] out = new byte[INITIAL_BUFFER_SIZE]; |
61 | 62 |
62 int pos = 0; | 63 int pos = 0; |
63 for (;;) | 64 for (;;) |
64 { | 65 { |
65 final int read = in.read(buffer); | 66 final int read = in.read(buffer); |
66 if (read < 0) | 67 if (read < 0) |
67 { | 68 { |
68 break; | 69 break; |
69 } | 70 } |
70 if (pos + read > out.length) | 71 if (pos + read > out.length) |
71 { | 72 { |
72 final byte[] old = out; | 73 final byte[] old = out; |
73 out = new byte[out.length + 65536]; | 74 out = new byte[out.length + BUFFER_GROWTH_DELTA]; |
74 System.arraycopy(old, 0, out, 0, pos); | 75 System.arraycopy(old, 0, out, 0, pos); |
75 } | 76 } |
76 System.arraycopy(buffer, 0, out, pos, read); | 77 System.arraycopy(buffer, 0, out, pos, read); |
77 pos += read; | 78 pos += read; |
78 } | 79 } |
79 | 80 |
80 connection.disconnect(); | 81 connection.disconnect(); |
81 | 82 |
82 response.setStatus(NsStatus.OK); | 83 response.setStatus(NsStatus.OK); |
83 response.setResponse(Strings.from(out, 0, pos)); | 84 response.setResponse(new String(out, 0, pos, "utf-8")); |
84 } | 85 } |
85 else | 86 else |
86 { | 87 { |
87 response.setStatus(NsStatus.ERROR_FAILURE); | 88 response.setStatus(NsStatus.ERROR_FAILURE); |
88 } | 89 } |
89 return response; | 90 return response; |
90 } | 91 } |
91 catch (final Throwable t) | 92 catch (final Throwable t) |
92 { | 93 { |
93 throw new AdblockPlusException("WebRequest failed", t); | 94 throw new AdblockPlusException("WebRequest failed", t); |
94 } | 95 } |
95 } | 96 } |
96 } | 97 } |
LEFT | RIGHT |