| 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 |