| Index: src/org/adblockplus/android/ProxyService.java |
| diff --git a/src/org/adblockplus/android/ProxyService.java b/src/org/adblockplus/android/ProxyService.java |
| index 96b5d13456de1014f16afb33593d90e4c27c37d9..093ea1f894d70a63465354fa7c14dedf8821e367 100755 |
| --- a/src/org/adblockplus/android/ProxyService.java |
| +++ b/src/org/adblockplus/android/ProxyService.java |
| @@ -1,934 +1,933 @@ |
| -/* |
| - * This file is part of Adblock Plus <http://adblockplus.org/>, |
| - * Copyright (C) 2006-2014 Eyeo GmbH |
| - * |
| - * Adblock Plus is free software: you can redistribute it and/or modify |
| - * it under the terms of the GNU General Public License version 3 as |
| - * published by the Free Software Foundation. |
| - * |
| - * Adblock Plus is distributed in the hope that it will be useful, |
| - * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| - * GNU General Public License for more details. |
| - * |
| - * You should have received a copy of the GNU General Public License |
| - * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
| - */ |
| - |
| -package org.adblockplus.android; |
| - |
| -import java.io.File; |
| -import java.io.FileNotFoundException; |
| -import java.io.IOException; |
| -import java.lang.reflect.Method; |
| -import java.net.Inet4Address; |
| -import java.net.InetAddress; |
| -import java.net.ServerSocket; |
| -import java.util.List; |
| -import java.util.Properties; |
| -import java.util.concurrent.TimeoutException; |
| - |
| -import sunlabs.brazil.server.Server; |
| -import sunlabs.brazil.util.Base64; |
| -import android.annotation.SuppressLint; |
| -import android.app.Notification; |
| -import android.app.NotificationManager; |
| -import android.app.PendingIntent; |
| -import android.app.Service; |
| -import android.content.BroadcastReceiver; |
| -import android.content.Context; |
| -import android.content.Intent; |
| -import android.content.IntentFilter; |
| -import android.content.SharedPreferences; |
| -import android.content.SharedPreferences.OnSharedPreferenceChangeListener; |
| -import android.content.pm.PackageManager.NameNotFoundException; |
| -import android.content.res.Resources; |
| -import android.net.ConnectivityManager; |
| -import android.net.NetworkInfo; |
| -import android.net.Proxy; |
| -import android.os.Binder; |
| -import android.os.Build; |
| -import android.os.Handler; |
| -import android.os.IBinder; |
| -import android.os.StrictMode; |
| -import android.preference.PreferenceManager; |
| -import android.support.v4.app.NotificationCompat; |
| -import android.util.Log; |
| - |
| -import com.stericson.RootTools.RootTools; |
| -import com.stericson.RootTools.RootToolsException; |
| - |
| -public class ProxyService extends Service implements OnSharedPreferenceChangeListener |
| -{ |
| - private static final String LOCALHOST = "127.0.0.1"; |
| - /** |
| - * Indicates that system supports native proxy configuration. |
| - */ |
| - public static final boolean NATIVE_PROXY_SUPPORTED = Build.VERSION.SDK_INT >= 12; // Honeycomb 3.1 |
| - |
| - static |
| - { |
| - RootTools.debugMode = false; |
| - } |
| - |
| - private static final String TAG = "ProxyService"; |
| - private static final boolean logRequests = false; |
| - |
| - // Do not use 8080 because it is a "dirty" port, Android uses it if something goes wrong |
| - // First element is reserved for previously used port |
| - private static final int[] portVariants = new int[] {-1, 2020, 3030, 4040, 5050, 6060, 7070, 9090, 1234, 12345, 4321, 0}; |
| - |
| - private final static int DEFAULT_TIMEOUT = 3000; |
| - private final static int NO_TRAFFIC_TIMEOUT = 5 * 60 * 1000; // 5 minutes |
| - |
| - final static int ONGOING_NOTIFICATION_ID = R.string.app_name; |
| - private static final long POSITION_RIGHT = Build.VERSION.SDK_INT >= Build.VERSION_CODES.GINGERBREAD ? Long.MIN_VALUE : Long.MAX_VALUE; |
| - private final static int NOTRAFFIC_NOTIFICATION_ID = R.string.app_name + 3; |
| - |
| - /** |
| - * Broadcasted when service starts or stops. |
| - */ |
| - public final static String BROADCAST_STATE_CHANGED = "org.adblockplus.android.service.state"; |
| - /** |
| - * Broadcasted if proxy fails to start. |
| - */ |
| - public final static String BROADCAST_PROXY_FAILED = "org.adblockplus.android.proxy.failure"; |
| - |
| - private final static String IPTABLES_RETURN = " -t nat -m owner --uid-owner {{UID}} -A OUTPUT -p tcp -j RETURN\n"; |
| - private final static String IPTABLES_ADD_HTTP = " -t nat -A OUTPUT -p tcp --dport 80 -j REDIRECT --to {{PORT}}\n"; |
| - |
| - boolean hideIcon; |
| - private Handler notrafficHandler; |
| - |
| - protected ProxyServer proxy = null; |
| - protected int port; |
| - private Properties proxyConfiguration = new Properties(); |
| - |
| - /** |
| - * Indicates that service is working with root privileges. |
| - */ |
| - private boolean transparent = false; |
| - /** |
| - * Indicates that service has autoconfigured Android proxy settings (version 3.1+). |
| - */ |
| - private boolean nativeProxyAutoConfigured = false; |
| - /** |
| - * Indicates that Android proxy settings are correctly configured (version 4.1.2+ 4.2.2+). |
| - */ |
| - private boolean proxyManualyConfigured = false; |
| - |
| - private String iptables = null; |
| - |
| - @SuppressLint("NewApi") |
| - @Override |
| - public void onCreate() |
| - { |
| - super.onCreate(); |
| - |
| - if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.GINGERBREAD) |
| - { |
| - // Proxy is running in separate thread, it's just some resolution request during initialization. |
| - // Not worth spawning a separate thread for this. |
| - StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder().permitNetwork().build(); |
| - StrictMode.setThreadPolicy(policy); |
| - } |
| - |
| - // Get port for local proxy |
| - SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(this); |
| - Resources resources = getResources(); |
| - |
| - // Try to read user proxy settings |
| - String proxyHost = null; |
| - String proxyPort = null; |
| - String proxyExcl = null; |
| - String proxyUser = null; |
| - String proxyPass = null; |
| - |
| - if (NATIVE_PROXY_SUPPORTED) |
| - { |
| - // Read system settings |
| - proxyHost = System.getProperty("http.proxyHost"); |
| - proxyPort = System.getProperty("http.proxyPort"); |
| - proxyExcl = System.getProperty("http.nonProxyHosts"); |
| - |
| - Log.d(TAG, "PRX: " + proxyHost + ":" + proxyPort + "(" + proxyExcl + ")"); |
| - // not used but left for future reference |
| - String[] px = ProxySettings.getUserProxy(getApplicationContext()); |
| - if (px != null) |
| - Log.d(TAG, "PRX: " + px[0] + ":" + px[1] + "(" + px[2] + ")"); |
| - } |
| - else |
| - { |
| - // Read application settings |
| - proxyHost = prefs.getString(getString(R.string.pref_proxyhost), null); |
| - proxyPort = prefs.getString(getString(R.string.pref_proxyport), null); |
| - proxyUser = prefs.getString(getString(R.string.pref_proxyuser), null); |
| - proxyPass = prefs.getString(getString(R.string.pref_proxypass), null); |
| - } |
| - |
| - // Check for root privileges and try to install transparent proxy |
| - if (RootTools.isAccessGiven()) |
| - { |
| - try |
| - { |
| - initIptables(); |
| - |
| - StringBuffer cmd = new StringBuffer(); |
| - int uid = getPackageManager().getPackageInfo(getPackageName(), 0).applicationInfo.uid; |
| - cmd.append(iptables); |
| - cmd.append(IPTABLES_RETURN.replace("{{UID}}", String.valueOf(uid))); |
| - String rules = cmd.toString(); |
| - RootTools.sendShell(rules, DEFAULT_TIMEOUT); |
| - transparent = true; |
| - } |
| - catch (FileNotFoundException e) |
| - { |
| - // ignore - this is "normal" case |
| - } |
| - catch (NameNotFoundException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - catch (IOException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - catch (RootToolsException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - catch (TimeoutException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - } |
| - |
| - if (!transparent) |
| - { |
| - // Try to set native proxy |
| - nativeProxyAutoConfigured = ProxySettings.setConnectionProxy(getApplicationContext(), LOCALHOST, port, ""); |
| - |
| - if (NATIVE_PROXY_SUPPORTED) |
| - { |
| - registerReceiver(connectionReceiver, new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION)); |
| - registerReceiver(connectionReceiver, new IntentFilter(Proxy.PROXY_CHANGE_ACTION)); |
| - } |
| - } |
| - |
| - // Save current native proxy situation. The service is always started on the first run so |
| - // we will always have a correct value from the box |
| - SharedPreferences.Editor editor = prefs.edit(); |
| - editor.putBoolean(getString(R.string.pref_proxyautoconfigured), transparent || nativeProxyAutoConfigured); |
| - editor.commit(); |
| - |
| - registerReceiver(proxyReceiver, new IntentFilter(ProxyService.BROADCAST_PROXY_FAILED)); |
| - registerReceiver(filterReceiver, new IntentFilter(AdblockPlus.BROADCAST_FILTERING_CHANGE)); |
| - registerReceiver(filterReceiver, new IntentFilter(AdblockPlus.BROADCAST_FILTER_MATCHES)); |
| - |
| - // Start proxy |
| - if (proxy == null) |
| - { |
| - // Select available port and bind to it, use previously selected port by default |
| - portVariants[0] = prefs.getInt(getString(R.string.pref_lastport), -1); |
| - ServerSocket listen = null; |
| - String msg = null; |
| - for (int p : portVariants) |
| - { |
| - if (p < 0) |
| - continue; |
| - try |
| - { |
| - // Fix for #232, bind proxy socket to loopback only |
| - listen = new ServerSocket(p, 1024, InetAddress.getByName(LOCALHOST)); |
| - port = p; |
| - break; |
| - } |
| - catch (IOException e) |
| - { |
| - Log.e(TAG, null, e); |
| - msg = e.getMessage(); |
| - } |
| - } |
| - if (listen == null) |
| - { |
| - sendBroadcast(new Intent(BROADCAST_PROXY_FAILED).putExtra("msg", msg)); |
| - return; |
| - } |
| - |
| - // Save selected port |
| - editor.putInt(getString(R.string.pref_lastport), port); |
| - editor.commit(); |
| - |
| - // Initialize proxy |
| - proxyConfiguration.put("handler", "main"); |
| - proxyConfiguration.put("main.prefix", ""); |
| - proxyConfiguration.put("main.class", "sunlabs.brazil.server.ChainHandler"); |
| - if (transparent) |
| - { |
| - proxyConfiguration.put("main.handlers", "urlmodifier adblock"); |
| - proxyConfiguration.put("urlmodifier.class", "org.adblockplus.brazil.TransparentProxyHandler"); |
| - } |
| - else |
| - { |
| - proxyConfiguration.put("main.handlers", "https adblock"); |
| - proxyConfiguration.put("https.class", "org.adblockplus.brazil.SSLConnectionHandler"); |
| - } |
| - proxyConfiguration.put("adblock.class", "org.adblockplus.brazil.RequestHandler"); |
| - if (logRequests) |
| - proxyConfiguration.put("adblock.proxylog", "yes"); |
| - |
| - configureUserProxy(proxyConfiguration, proxyHost, proxyPort, proxyExcl, proxyUser, proxyPass); |
| - |
| - proxy = new ProxyServer(); |
| - proxy.logLevel = Server.LOG_DIAGNOSTIC; |
| - proxy.setup(listen, proxyConfiguration.getProperty("handler"), proxyConfiguration); |
| - proxy.start(); |
| - } |
| - |
| - if (transparent) |
| - { |
| - // Redirect traffic via iptables |
| - try |
| - { |
| - StringBuffer cmd = new StringBuffer(); |
| - cmd.append(iptables); |
| - cmd.append(IPTABLES_ADD_HTTP.replace("{{PORT}}", String.valueOf(port))); |
| - String rules = cmd.toString(); |
| - RootTools.sendShell(rules, DEFAULT_TIMEOUT); |
| - } |
| - catch (FileNotFoundException e) |
| - { |
| - // ignore - this is "normal" case |
| - } |
| - catch (IOException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - catch (RootToolsException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - catch (TimeoutException e) |
| - { |
| - Log.e(TAG, "Failed to initialize iptables", e); |
| - } |
| - } |
| - |
| - prefs.registerOnSharedPreferenceChangeListener(this); |
| - |
| - // Lock service |
| - hideIcon = prefs.getBoolean(getString(R.string.pref_hideicon), resources.getBoolean(R.bool.def_hideicon)); |
| - startForeground(ONGOING_NOTIFICATION_ID, getNotification()); |
| - |
| - // If automatic setting of proxy was blocked, check if user has set it manually |
| - boolean manual = isManual(); |
| - if (manual && NATIVE_PROXY_SUPPORTED) |
| - { |
| - ConnectivityManager connectivityManager = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE); |
| - updateNoTrafficCheck(connectivityManager); |
| - } |
| - |
| - sendStateChangedBroadcast(); |
| - Log.i(TAG, "Service started"); |
| - } |
| - |
| - @Override |
| - public int onStartCommand(Intent intent, int flags, int startId) |
| - { |
| - return START_STICKY; |
| - } |
| - |
| - @Override |
| - public void onDestroy() |
| - { |
| - super.onDestroy(); |
| - |
| - stopNoTrafficCheck(); |
| - |
| - unregisterReceiver(filterReceiver); |
| - unregisterReceiver(proxyReceiver); |
| - |
| - // Stop IP redirecting |
| - if (transparent) |
| - { |
| - new Thread() |
| - { |
| - @Override |
| - public void run() |
| - { |
| - try |
| - { |
| - RootTools.sendShell(iptables + " -t nat -F OUTPUT", DEFAULT_TIMEOUT); |
| - } |
| - catch (Exception e) |
| - { |
| - Log.e(TAG, "Failed to clear iptables", e); |
| - } |
| - } |
| - }.start(); |
| - } |
| - |
| - if (!transparent && NATIVE_PROXY_SUPPORTED) |
| - unregisterReceiver(connectionReceiver); |
| - |
| - // Clear native proxy |
| - if (nativeProxyAutoConfigured) |
| - { |
| - clearConnectionProxy(); |
| - } |
| - |
| - sendBroadcast(new Intent(BROADCAST_STATE_CHANGED).putExtra("enabled", false)); |
| - |
| - // Stop proxy server |
| - if (proxy != null) |
| - proxy.close(); |
| - |
| - // Release service lock |
| - stopForeground(true); |
| - |
| - Log.i(TAG, "Service stopped"); |
| - } |
| - |
| - /** |
| - * Restores system proxy settings via native call on Android 3.1+ devices |
| - * using Java reflection. |
| - */ |
| - private void clearConnectionProxy() |
| - { |
| - String proxyHost = (String) proxyConfiguration.getProperty("adblock.proxyHost"); |
| - String proxyPort = (String) proxyConfiguration.getProperty("adblock.proxyPort"); |
| - String proxyExcl = (String) proxyConfiguration.getProperty("adblock.proxyExcl"); |
| - int port = 0; |
| - try |
| - { |
| - if (proxyHost != null) |
| - port = Integer.valueOf(proxyPort); |
| - } |
| - catch (NumberFormatException e) |
| - { |
| - Log.e(TAG, "Bad port setting", e); |
| - } |
| - ProxySettings.setConnectionProxy(getApplicationContext(), proxyHost, port, proxyExcl); |
| - } |
| - |
| - /** |
| - * Sets user proxy settings in proxy service properties. |
| - */ |
| - private void configureUserProxy(Properties config, String proxyHost, String proxyPort, String proxyExcl, String proxyUser, String proxyPass) |
| - { |
| - // Clean previous settings |
| - config.remove("adblock.proxyHost"); |
| - config.remove("adblock.proxyPort"); |
| - config.remove("adblock.auth"); |
| - config.remove("adblock.proxyExcl"); |
| - if (!transparent) |
| - { |
| - config.remove("https.proxyHost"); |
| - config.remove("https.proxyPort"); |
| - config.remove("https.auth"); |
| - } |
| - |
| - if (nativeProxyAutoConfigured) |
| - passProxySettings(proxyHost, proxyPort, proxyExcl); |
| - |
| - // Check if there are any settings |
| - if (proxyHost == null || "".equals(proxyHost)) |
| - return; |
| - |
| - // Check for dirty proxy settings - this indicated previous crash: |
| - // proxy points to ourselves |
| - // proxy port is null, 0 or not a number |
| - // proxy is 127.0.0.1:8080 |
| - if (proxyPort == null) |
| - return; |
| - int p = 0; |
| - try |
| - { |
| - p = Integer.valueOf(proxyPort); |
| - } |
| - catch (NumberFormatException e) |
| - { |
| - return; |
| - } |
| - if (p == 0 || isLocalHost(proxyHost) && (p == port || p == 8080)) |
| - { |
| - if (nativeProxyAutoConfigured) |
| - passProxySettings(null, null, null); |
| - return; |
| - } |
| - |
| - config.put("adblock.proxyHost", proxyHost); |
| - config.put("adblock.proxyPort", proxyPort); |
| - if (!transparent) |
| - { |
| - config.put("https.proxyHost", proxyHost); |
| - config.put("https.proxyPort", proxyPort); |
| - } |
| - |
| - // TODO Not implemented in our proxy but needed to restore settings |
| - if (proxyExcl != null) |
| - config.put("adblock.proxyExcl", proxyExcl); |
| - |
| - if (proxyUser != null && !"".equals(proxyUser) && proxyPass != null && !"".equals(proxyPass)) |
| - { |
| - // Base64 encode user:password |
| - String proxyAuth = "Basic " + new String(Base64.encode(proxyUser + ":" + proxyPass)); |
| - config.put("adblock.auth", proxyAuth); |
| - if (!transparent) |
| - config.put("https.auth", proxyAuth); |
| - } |
| - } |
| - |
| - private void passProxySettings(String proxyHost, String proxyPort, String proxyExcl) |
| - { |
| - try |
| - { |
| - CrashHandler handler = (CrashHandler) Thread.getDefaultUncaughtExceptionHandler(); |
| - handler.saveProxySettings(proxyHost, proxyPort, proxyExcl); |
| - } |
| - catch (ClassCastException e) |
| - { |
| - // ignore - default handler in use |
| - } |
| - } |
| - |
| - @Override |
| - public void onSharedPreferenceChanged(SharedPreferences sharedPreferences, String key) |
| - { |
| - if (!NATIVE_PROXY_SUPPORTED) |
| - { |
| - String ketHost = getString(R.string.pref_proxyhost); |
| - String keyPort = getString(R.string.pref_proxyport); |
| - String keyUser = getString(R.string.pref_proxyuser); |
| - String keyPass = getString(R.string.pref_proxypass); |
| - if (key.equals(ketHost) || key.equals(keyPort) || key.equals(keyUser) || key.equals(keyPass)) |
| - { |
| - String proxyHost = sharedPreferences.getString(ketHost, null); |
| - String proxyPort = sharedPreferences.getString(keyPort, null); |
| - String proxyUser = sharedPreferences.getString(keyUser, null); |
| - String proxyPass = sharedPreferences.getString(keyPass, null); |
| - if (proxy != null) |
| - { |
| - configureUserProxy(proxyConfiguration, proxyHost, proxyPort, null, proxyUser, proxyPass); |
| - proxy.restart(proxyConfiguration.getProperty("handler")); |
| - } |
| - } |
| - } |
| - } |
| - |
| - public boolean isTransparent() |
| - { |
| - return transparent; |
| - } |
| - |
| - public boolean isNativeProxyAutoConfigured() |
| - { |
| - return nativeProxyAutoConfigured; |
| - } |
| - |
| - /** |
| - * Checks if user has to set proxy settings manually |
| - */ |
| - public boolean isManual() |
| - { |
| - return !transparent && !nativeProxyAutoConfigured; |
| - } |
| - |
| - /** |
| - * Checks whether traffic check is pending |
| - */ |
| - public boolean noTraffic() |
| - { |
| - return notrafficHandler != null; |
| - } |
| - |
| - /** |
| - * Checks if specified host is local. |
| - */ |
| - private static final boolean isLocalHost(String host) |
| - { |
| - if (host == null) |
| - return false; |
| - |
| - try |
| - { |
| - if (host.equalsIgnoreCase("localhost")) |
| - return true; |
| - |
| - String className = "android.net.NetworkUtils"; |
| - Class<?> c = Class.forName(className); |
| - /* |
| - * InetAddress address = NetworkUtils.numericToInetAddress(host); |
| - */ |
| - Method method = c.getMethod("numericToInetAddress", String.class); |
| - InetAddress address = (InetAddress) method.invoke(null, host); |
| - |
| - if (address.isLoopbackAddress()) |
| - return true; |
| - } |
| - catch (Exception e) |
| - { |
| - Log.w(TAG, null, e); |
| - } |
| - return false; |
| - } |
| - |
| - /** |
| - * Initializes iptables executable. |
| - * |
| - * @throws FileNotFoundException |
| - * If iptables initialization failed due to provided reasons. |
| - */ |
| - private void initIptables() throws IOException, RootToolsException, TimeoutException, FileNotFoundException |
| - { |
| - if (!RootTools.isAccessGiven()) |
| - throw new FileNotFoundException("No root access"); |
| - |
| - File ipt = getFileStreamPath("iptables"); |
| - |
| - if (!ipt.exists()) |
| - { |
| - Log.e(TAG, "No iptables excutable found"); |
| - throw new FileNotFoundException("No iptables executable"); |
| - } |
| - |
| - String path = ipt.getAbsolutePath(); |
| - |
| - RootTools.sendShell("chmod 700 " + path, DEFAULT_TIMEOUT); |
| - |
| - boolean compatible = false; |
| - boolean version = false; |
| - |
| - String command = path + " --version\n" + path + " -L -t nat -n\n"; |
| - |
| - List<String> result = RootTools.sendShell(command, DEFAULT_TIMEOUT); |
| - for (String line : result) |
| - { |
| - if (line.contains("OUTPUT")) |
| - compatible = true; |
| - if (line.contains("v1.4.")) |
| - version = true; |
| - } |
| - |
| - if (!compatible || !version) |
| - { |
| - Log.e(TAG, "Incompatible iptables excutable"); |
| - throw new FileNotFoundException("Incompatible iptables excutable"); |
| - } |
| - |
| - iptables = path; |
| - } |
| - |
| - public List<String> getIptablesOutput() |
| - { |
| - if (iptables == null) |
| - return null; |
| - |
| - String command = iptables + " -L -t nat -n\n"; |
| - try |
| - { |
| - return RootTools.sendShell(command, DEFAULT_TIMEOUT); |
| - } |
| - catch (Exception e) |
| - { |
| - Log.e(TAG, "Failed to get iptables configuration", e); |
| - return null; |
| - } |
| - } |
| - |
| - /** |
| - * Raises or removes no traffic notification based on current link proxy |
| - * settings |
| - */ |
| - private void updateNoTrafficCheck(ConnectivityManager connectivityManager) |
| - { |
| - try |
| - { |
| - Object pp = ProxySettings.getActiveLinkProxy(connectivityManager); |
| - String[] userProxy = ProxySettings.getUserProxy(pp); |
| - if (userProxy != null) |
| - Log.i(TAG, "Proxy settings: " + userProxy[0] + ":" + userProxy[1] + "(" + userProxy[2] + ")"); |
| - updateNoTrafficCheck(userProxy); |
| - } |
| - catch (Exception e) |
| - { |
| - // This should not happen |
| - Log.e(TAG, null, e); |
| - } |
| - } |
| - |
| - /** |
| - * Raises or removes no traffic notification based on the user proxy settings |
| - */ |
| - private void updateNoTrafficCheck(String[] userProxy) |
| - { |
| - boolean ourProxy = userProxy != null && isLocalHost(userProxy[0]) && Integer.valueOf(userProxy[1]) == port; |
| - if (ourProxy != proxyManualyConfigured) |
| - { |
| - proxyManualyConfigured = ourProxy; |
| - sendStateChangedBroadcast(); |
| - } |
| - if (ourProxy) |
| - { |
| - stopNoTrafficCheck(); |
| - } |
| - else |
| - { |
| - // Initiate no traffic check |
| - notrafficHandler = new Handler(); |
| - notrafficHandler.postDelayed(noTraffic, NO_TRAFFIC_TIMEOUT); |
| - } |
| - NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| - notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| - } |
| - |
| - /** |
| - * Stops no traffic check and resets notification message. |
| - */ |
| - private void stopNoTrafficCheck() |
| - { |
| - if (notrafficHandler != null) |
| - { |
| - notrafficHandler.removeCallbacks(noTraffic); |
| - sendStateChangedBroadcast(); |
| - NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| - notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| - notificationManager.cancel(NOTRAFFIC_NOTIFICATION_ID); |
| - } |
| - notrafficHandler = null; |
| - } |
| - |
| - @SuppressLint("NewApi") |
| - private Notification getNotification() |
| - { |
| - boolean filtering = AdblockPlus.getApplication().isFilteringEnabled(); |
| - |
| - int msgId = R.string.notif_waiting; |
| - if (nativeProxyAutoConfigured || proxyManualyConfigured) |
| - msgId = filtering ? R.string.notif_wifi : R.string.notif_wifi_nofiltering; |
| - if (transparent) |
| - msgId = R.string.notif_all; |
| - |
| - NotificationCompat.Builder builder = new NotificationCompat.Builder(this); |
| - if (hideIcon && msgId != R.string.notif_waiting) |
| - { |
| - builder.setWhen(POSITION_RIGHT); |
| - builder.setSmallIcon(R.drawable.transparent); |
| - //builder.setContent(new RemoteViews(getPackageName(), R.layout.notif_hidden)); |
| - } |
| - else |
| - { |
| - builder.setWhen(0); |
| - builder.setSmallIcon(R.drawable.ic_stat_blocking); |
| - } |
| - PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, Preferences.class).addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP | Intent.FLAG_ACTIVITY_NEW_TASK), 0); |
| - builder.setContentIntent(contentIntent); |
| - builder.setContentTitle(getText(R.string.app_name)); |
| - builder.setContentText(getString(msgId, port)); |
| - builder.setOngoing(true); |
| - |
| - Notification notification = builder.getNotification(); |
| - return notification; |
| - } |
| - |
| - public void setEmptyIcon(boolean hide) |
| - { |
| - hideIcon = hide; |
| - NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| - notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| - } |
| - |
| - public void sendStateChangedBroadcast() |
| - { |
| - Log.i(TAG, "Broadcasting " + BROADCAST_STATE_CHANGED); |
| - boolean manual = isManual(); |
| - Intent stateIntent = new Intent(BROADCAST_STATE_CHANGED).putExtra("enabled", true).putExtra("port", port).putExtra("manual", manual); |
| - if (manual) |
| - stateIntent.putExtra("configured", proxyManualyConfigured); |
| - sendBroadcast(stateIntent); |
| - } |
| - |
| - private final IBinder binder = new LocalBinder(); |
| - |
| - public final class LocalBinder extends Binder |
| - { |
| - public ProxyService getService() |
| - { |
| - return ProxyService.this; |
| - } |
| - } |
| - |
| - @Override |
| - public IBinder onBind(Intent intent) |
| - { |
| - return binder; |
| - } |
| - |
| - /** |
| - * Executed if no traffic is detected after a period of time. Notifies user |
| - * about possible configuration problems. |
| - */ |
| - private Runnable noTraffic = new Runnable() |
| - { |
| - public void run() |
| - { |
| - // It's weird but notrafficHandler.removeCallbacks(noTraffic) does not remove this callback |
| - if (notrafficHandler == null) |
| - return; |
| - // Show warning notification |
| - NotificationCompat.Builder builder = new NotificationCompat.Builder(ProxyService.this); |
| - builder.setSmallIcon(R.drawable.ic_stat_warning); |
| - builder.setWhen(System.currentTimeMillis()); |
| - builder.setAutoCancel(true); |
| - Intent intent = new Intent(ProxyService.this, ConfigurationActivity.class).addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); |
| - intent.putExtra("port", port); |
| - PendingIntent contentIntent = PendingIntent.getActivity(ProxyService.this, 0, intent, PendingIntent.FLAG_UPDATE_CURRENT); |
| - builder.setContentIntent(contentIntent); |
| - builder.setContentTitle(getText(R.string.app_name)); |
| - builder.setContentText(getText(R.string.notif_notraffic)); |
| - NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| - notificationManager.notify(NOTRAFFIC_NOTIFICATION_ID, builder.getNotification()); |
| - } |
| - }; |
| - |
| - /** |
| - * Stops no traffic check if traffic is detected by proxy service. |
| - */ |
| - private BroadcastReceiver filterReceiver = new BroadcastReceiver() |
| - { |
| - @Override |
| - public void onReceive(final Context context, Intent intent) |
| - { |
| - if (intent.getAction().equals(AdblockPlus.BROADCAST_FILTERING_CHANGE)) |
| - { |
| - // It's rather a hack but things are happening simultaneously and we |
| - // receive this broadcast despite the fact we have unsubscribed from |
| - // it and notification is not removed because it is changed to new one |
| - // during removal. |
| - if (!ProxyService.this.isNativeProxyAutoConfigured()) |
| - { |
| - NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| - notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| - } |
| - } |
| - if (intent.getAction().equals(AdblockPlus.BROADCAST_FILTER_MATCHES)) |
| - { |
| - proxyManualyConfigured = true; |
| - stopNoTrafficCheck(); |
| - } |
| - } |
| - }; |
| - |
| - /** |
| - * Stops service if proxy fails. |
| - */ |
| - private BroadcastReceiver proxyReceiver = new BroadcastReceiver() |
| - { |
| - @Override |
| - public void onReceive(final Context context, Intent intent) |
| - { |
| - if (intent.getAction().equals(ProxyService.BROADCAST_PROXY_FAILED)) |
| - { |
| - stopSelf(); |
| - } |
| - } |
| - }; |
| - |
| - /** |
| - * Monitors system network connection settings changes and updates proxy |
| - * settings accordingly. |
| - */ |
| - private BroadcastReceiver connectionReceiver = new BroadcastReceiver() |
| - { |
| - @Override |
| - public void onReceive(Context ctx, Intent intent) |
| - { |
| - String action = intent.getAction(); |
| - Log.i(TAG, "Action: " + action); |
| - // Connectivity change |
| - if (ConnectivityManager.CONNECTIVITY_ACTION.equals(action)) |
| - { |
| - ConnectivityManager connectivityManager = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE); |
| - // TODO Should we use ConnectivityManagerCompat.getNetworkInfoFromBroadcast() instead? |
| - NetworkInfo info = connectivityManager.getActiveNetworkInfo(); |
| - if (info == null) |
| - return; |
| - String typeName = info.getTypeName(); |
| - String subtypeName = info.getSubtypeName(); |
| - boolean available = info.isAvailable(); |
| - |
| - Log.i(TAG, "Network Type: " + typeName + ", subtype: " + subtypeName + ", available: " + available); |
| - if (info.getType() == ConnectivityManager.TYPE_WIFI) |
| - { |
| - if (nativeProxyAutoConfigured) |
| - { |
| - ProxySettings.setConnectionProxy(getApplicationContext(), LOCALHOST, port, ""); |
| - } |
| - else |
| - { |
| - updateNoTrafficCheck(connectivityManager); |
| - } |
| - } |
| - } |
| - // Proxy change |
| - else if (Proxy.PROXY_CHANGE_ACTION.equals(action)) |
| - { |
| - Object pp = intent.getParcelableExtra("proxy"); |
| - try |
| - { |
| - String[] userProxy = ProxySettings.getUserProxy(pp); |
| - if (nativeProxyAutoConfigured) |
| - { |
| - if (userProxy != null && Integer.valueOf(userProxy[1]) != port) |
| - { |
| - Log.i(TAG, "User has set new proxy: " + userProxy[0] + ":" + userProxy[1] + "(" + userProxy[2] + ")"); |
| - if (proxy != null) |
| - { |
| - configureUserProxy(proxyConfiguration, userProxy[0], userProxy[1], userProxy[2], null, null); |
| - proxy.restart(proxyConfiguration.getProperty("handler")); |
| - } |
| - } |
| - } |
| - else |
| - { |
| - Log.i(TAG, "User has set proxy: " + userProxy[0] + ":" + userProxy[1] + "(" + userProxy[2] + ")"); |
| - updateNoTrafficCheck(userProxy); |
| - } |
| - } |
| - catch (Exception e) |
| - { |
| - // This should not happen |
| - Log.e(TAG, null, e); |
| - } |
| - } |
| - } |
| - }; |
| - |
| - final class ProxyServer extends Server |
| - { |
| - @Override |
| - public void close() |
| - { |
| - try |
| - { |
| - listen.close(); |
| - this.interrupt(); |
| - this.join(); |
| - } |
| - catch (Exception e) |
| - { |
| - // ignore - it always happens |
| - } |
| - log(LOG_WARNING, null, "server stopped"); |
| - } |
| - |
| - @Override |
| - public void log(int level, Object obj, String message) |
| - { |
| - if (level <= logLevel) |
| - { |
| - Log.println(7 - level, obj != null ? obj.toString() : TAG, message); |
| - } |
| - } |
| - } |
| -} |
| +/* |
| + * This file is part of Adblock Plus <http://adblockplus.org/>, |
| + * Copyright (C) 2006-2014 Eyeo GmbH |
| + * |
| + * Adblock Plus is free software: you can redistribute it and/or modify |
| + * it under the terms of the GNU General Public License version 3 as |
| + * published by the Free Software Foundation. |
| + * |
| + * Adblock Plus is distributed in the hope that it will be useful, |
| + * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| + * GNU General Public License for more details. |
| + * |
| + * You should have received a copy of the GNU General Public License |
| + * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
| + */ |
| + |
| +package org.adblockplus.android; |
| + |
| +import java.io.File; |
| +import java.io.FileNotFoundException; |
| +import java.io.IOException; |
| +import java.lang.reflect.Method; |
| +import java.net.InetAddress; |
| +import java.net.ServerSocket; |
| +import java.util.List; |
| +import java.util.Properties; |
| +import java.util.concurrent.TimeoutException; |
| + |
| +import sunlabs.brazil.server.Server; |
| +import sunlabs.brazil.util.Base64; |
| +import android.annotation.SuppressLint; |
| +import android.app.Notification; |
| +import android.app.NotificationManager; |
| +import android.app.PendingIntent; |
| +import android.app.Service; |
| +import android.content.BroadcastReceiver; |
| +import android.content.Context; |
| +import android.content.Intent; |
| +import android.content.IntentFilter; |
| +import android.content.SharedPreferences; |
| +import android.content.SharedPreferences.OnSharedPreferenceChangeListener; |
| +import android.content.pm.PackageManager.NameNotFoundException; |
| +import android.content.res.Resources; |
| +import android.net.ConnectivityManager; |
| +import android.net.NetworkInfo; |
| +import android.net.Proxy; |
| +import android.os.Binder; |
| +import android.os.Build; |
| +import android.os.Handler; |
| +import android.os.IBinder; |
| +import android.os.StrictMode; |
| +import android.preference.PreferenceManager; |
| +import android.support.v4.app.NotificationCompat; |
| +import android.util.Log; |
| + |
| +import com.stericson.RootTools.RootTools; |
| +import com.stericson.RootTools.RootToolsException; |
| + |
| +public class ProxyService extends Service implements OnSharedPreferenceChangeListener |
| +{ |
| + private static final String LOCALHOST = "127.0.0.1"; |
| + /** |
| + * Indicates that system supports native proxy configuration. |
| + */ |
| + public static final boolean NATIVE_PROXY_SUPPORTED = Build.VERSION.SDK_INT >= 12; // Honeycomb 3.1 |
| + |
| + static |
| + { |
| + RootTools.debugMode = false; |
| + } |
| + |
| + private static final String TAG = "ProxyService"; |
| + private static final boolean logRequests = false; |
| + |
| + // Do not use 8080 because it is a "dirty" port, Android uses it if something goes wrong |
| + // First element is reserved for previously used port |
| + private static final int[] portVariants = new int[] {-1, 2020, 3030, 4040, 5050, 6060, 7070, 9090, 1234, 12345, 4321, 0}; |
| + |
| + private final static int DEFAULT_TIMEOUT = 3000; |
| + private final static int NO_TRAFFIC_TIMEOUT = 5 * 60 * 1000; // 5 minutes |
| + |
| + final static int ONGOING_NOTIFICATION_ID = R.string.app_name; |
| + private static final long POSITION_RIGHT = Build.VERSION.SDK_INT >= Build.VERSION_CODES.GINGERBREAD ? Long.MIN_VALUE : Long.MAX_VALUE; |
| + private final static int NOTRAFFIC_NOTIFICATION_ID = R.string.app_name + 3; |
| + |
| + /** |
| + * Broadcasted when service starts or stops. |
| + */ |
| + public final static String BROADCAST_STATE_CHANGED = "org.adblockplus.android.service.state"; |
| + /** |
| + * Broadcasted if proxy fails to start. |
| + */ |
| + public final static String BROADCAST_PROXY_FAILED = "org.adblockplus.android.proxy.failure"; |
| + |
| + private final static String IPTABLES_RETURN = " -t nat -m owner --uid-owner {{UID}} -A OUTPUT -p tcp -j RETURN\n"; |
| + private final static String IPTABLES_ADD_HTTP = " -t nat -A OUTPUT -p tcp --dport 80 -j REDIRECT --to {{PORT}}\n"; |
| + |
| + boolean hideIcon; |
| + private Handler notrafficHandler; |
| + |
| + protected ProxyServer proxy = null; |
| + protected int port; |
| + private Properties proxyConfiguration = new Properties(); |
| + |
| + /** |
| + * Indicates that service is working with root privileges. |
| + */ |
| + private boolean transparent = false; |
| + /** |
| + * Indicates that service has autoconfigured Android proxy settings (version 3.1+). |
| + */ |
| + private boolean nativeProxyAutoConfigured = false; |
| + /** |
| + * Indicates that Android proxy settings are correctly configured (version 4.1.2+ 4.2.2+). |
| + */ |
| + private boolean proxyManualyConfigured = false; |
| + |
| + private String iptables = null; |
| + |
| + @SuppressLint("NewApi") |
| + @Override |
| + public void onCreate() |
| + { |
| + super.onCreate(); |
| + |
| + if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.GINGERBREAD) |
| + { |
| + // Proxy is running in separate thread, it's just some resolution request during initialization. |
| + // Not worth spawning a separate thread for this. |
| + StrictMode.ThreadPolicy policy = new StrictMode.ThreadPolicy.Builder().permitNetwork().build(); |
| + StrictMode.setThreadPolicy(policy); |
| + } |
| + |
| + // Get port for local proxy |
| + SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(this); |
| + Resources resources = getResources(); |
| + |
| + // Try to read user proxy settings |
| + String proxyHost = null; |
| + String proxyPort = null; |
| + String proxyExcl = null; |
| + String proxyUser = null; |
| + String proxyPass = null; |
| + |
| + if (NATIVE_PROXY_SUPPORTED) |
| + { |
| + // Read system settings |
| + proxyHost = System.getProperty("http.proxyHost"); |
| + proxyPort = System.getProperty("http.proxyPort"); |
| + proxyExcl = System.getProperty("http.nonProxyHosts"); |
| + |
| + Log.d(TAG, "PRX: " + proxyHost + ":" + proxyPort + "(" + proxyExcl + ")"); |
| + // not used but left for future reference |
| + String[] px = ProxySettings.getUserProxy(getApplicationContext()); |
| + if (px != null) |
| + Log.d(TAG, "PRX: " + px[0] + ":" + px[1] + "(" + px[2] + ")"); |
| + } |
| + else |
| + { |
| + // Read application settings |
| + proxyHost = prefs.getString(getString(R.string.pref_proxyhost), null); |
| + proxyPort = prefs.getString(getString(R.string.pref_proxyport), null); |
| + proxyUser = prefs.getString(getString(R.string.pref_proxyuser), null); |
| + proxyPass = prefs.getString(getString(R.string.pref_proxypass), null); |
| + } |
| + |
| + // Check for root privileges and try to install transparent proxy |
| + if (RootTools.isAccessGiven()) |
| + { |
| + try |
| + { |
| + initIptables(); |
| + |
| + StringBuffer cmd = new StringBuffer(); |
| + int uid = getPackageManager().getPackageInfo(getPackageName(), 0).applicationInfo.uid; |
| + cmd.append(iptables); |
| + cmd.append(IPTABLES_RETURN.replace("{{UID}}", String.valueOf(uid))); |
| + String rules = cmd.toString(); |
| + RootTools.sendShell(rules, DEFAULT_TIMEOUT); |
| + transparent = true; |
| + } |
| + catch (FileNotFoundException e) |
| + { |
| + // ignore - this is "normal" case |
| + } |
| + catch (NameNotFoundException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + catch (IOException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + catch (RootToolsException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + catch (TimeoutException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + } |
| + |
| + if (!transparent) |
| + { |
| + // Try to set native proxy |
| + nativeProxyAutoConfigured = ProxySettings.setConnectionProxy(getApplicationContext(), LOCALHOST, port, ""); |
| + |
| + if (NATIVE_PROXY_SUPPORTED) |
| + { |
| + registerReceiver(connectionReceiver, new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION)); |
| + registerReceiver(connectionReceiver, new IntentFilter(Proxy.PROXY_CHANGE_ACTION)); |
| + } |
| + } |
| + |
| + // Save current native proxy situation. The service is always started on the first run so |
| + // we will always have a correct value from the box |
| + SharedPreferences.Editor editor = prefs.edit(); |
| + editor.putBoolean(getString(R.string.pref_proxyautoconfigured), transparent || nativeProxyAutoConfigured); |
| + editor.commit(); |
| + |
| + registerReceiver(proxyReceiver, new IntentFilter(ProxyService.BROADCAST_PROXY_FAILED)); |
| + registerReceiver(filterReceiver, new IntentFilter(AdblockPlus.BROADCAST_FILTERING_CHANGE)); |
| + registerReceiver(filterReceiver, new IntentFilter(AdblockPlus.BROADCAST_FILTER_MATCHES)); |
| + |
| + // Start proxy |
| + if (proxy == null) |
| + { |
| + // Select available port and bind to it, use previously selected port by default |
| + portVariants[0] = prefs.getInt(getString(R.string.pref_lastport), -1); |
| + ServerSocket listen = null; |
| + String msg = null; |
| + for (int p : portVariants) |
| + { |
| + if (p < 0) |
| + continue; |
| + try |
| + { |
| + // Fix for #232, bind proxy socket to loopback only |
| + listen = new ServerSocket(p, 1024, InetAddress.getByName(LOCALHOST)); |
| + port = p; |
| + break; |
| + } |
| + catch (IOException e) |
| + { |
| + Log.e(TAG, null, e); |
| + msg = e.getMessage(); |
| + } |
| + } |
| + if (listen == null) |
| + { |
| + sendBroadcast(new Intent(BROADCAST_PROXY_FAILED).putExtra("msg", msg)); |
| + return; |
| + } |
| + |
| + // Save selected port |
| + editor.putInt(getString(R.string.pref_lastport), port); |
| + editor.commit(); |
| + |
| + // Initialize proxy |
| + proxyConfiguration.put("handler", "main"); |
| + proxyConfiguration.put("main.prefix", ""); |
| + proxyConfiguration.put("main.class", "sunlabs.brazil.server.ChainHandler"); |
| + if (transparent) |
| + { |
| + proxyConfiguration.put("main.handlers", "urlmodifier adblock"); |
| + proxyConfiguration.put("urlmodifier.class", "org.adblockplus.brazil.TransparentProxyHandler"); |
| + } |
| + else |
| + { |
| + proxyConfiguration.put("main.handlers", "https adblock"); |
| + proxyConfiguration.put("https.class", "org.adblockplus.brazil.SSLConnectionHandler"); |
| + } |
| + proxyConfiguration.put("adblock.class", "org.adblockplus.brazil.RequestHandler"); |
| + if (logRequests) |
| + proxyConfiguration.put("adblock.proxylog", "yes"); |
| + |
| + configureUserProxy(proxyConfiguration, proxyHost, proxyPort, proxyExcl, proxyUser, proxyPass); |
| + |
| + proxy = new ProxyServer(); |
| + proxy.logLevel = Server.LOG_DIAGNOSTIC; |
| + proxy.setup(listen, proxyConfiguration.getProperty("handler"), proxyConfiguration); |
| + proxy.start(); |
| + } |
| + |
| + if (transparent) |
| + { |
| + // Redirect traffic via iptables |
| + try |
| + { |
| + StringBuffer cmd = new StringBuffer(); |
| + cmd.append(iptables); |
| + cmd.append(IPTABLES_ADD_HTTP.replace("{{PORT}}", String.valueOf(port))); |
| + String rules = cmd.toString(); |
| + RootTools.sendShell(rules, DEFAULT_TIMEOUT); |
| + } |
| + catch (FileNotFoundException e) |
| + { |
| + // ignore - this is "normal" case |
| + } |
| + catch (IOException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + catch (RootToolsException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + catch (TimeoutException e) |
| + { |
| + Log.e(TAG, "Failed to initialize iptables", e); |
| + } |
| + } |
| + |
| + prefs.registerOnSharedPreferenceChangeListener(this); |
| + |
| + // Lock service |
| + hideIcon = prefs.getBoolean(getString(R.string.pref_hideicon), resources.getBoolean(R.bool.def_hideicon)); |
| + startForeground(ONGOING_NOTIFICATION_ID, getNotification()); |
| + |
| + // If automatic setting of proxy was blocked, check if user has set it manually |
| + boolean manual = isManual(); |
| + if (manual && NATIVE_PROXY_SUPPORTED) |
| + { |
| + ConnectivityManager connectivityManager = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE); |
| + updateNoTrafficCheck(connectivityManager); |
| + } |
| + |
| + sendStateChangedBroadcast(); |
| + Log.i(TAG, "Service started"); |
| + } |
| + |
| + @Override |
| + public int onStartCommand(Intent intent, int flags, int startId) |
| + { |
| + return START_STICKY; |
| + } |
| + |
| + @Override |
| + public void onDestroy() |
| + { |
| + super.onDestroy(); |
| + |
| + stopNoTrafficCheck(); |
| + |
| + unregisterReceiver(filterReceiver); |
| + unregisterReceiver(proxyReceiver); |
| + |
| + // Stop IP redirecting |
| + if (transparent) |
| + { |
| + new Thread() |
| + { |
| + @Override |
| + public void run() |
| + { |
| + try |
| + { |
| + RootTools.sendShell(iptables + " -t nat -F OUTPUT", DEFAULT_TIMEOUT); |
| + } |
| + catch (Exception e) |
| + { |
| + Log.e(TAG, "Failed to clear iptables", e); |
| + } |
| + } |
| + }.start(); |
| + } |
| + |
| + if (!transparent && NATIVE_PROXY_SUPPORTED) |
| + unregisterReceiver(connectionReceiver); |
| + |
| + // Clear native proxy |
| + if (nativeProxyAutoConfigured) |
| + { |
| + clearConnectionProxy(); |
| + } |
| + |
| + sendBroadcast(new Intent(BROADCAST_STATE_CHANGED).putExtra("enabled", false)); |
| + |
| + // Stop proxy server |
| + if (proxy != null) |
| + proxy.close(); |
| + |
| + // Release service lock |
| + stopForeground(true); |
| + |
| + Log.i(TAG, "Service stopped"); |
| + } |
| + |
| + /** |
| + * Restores system proxy settings via native call on Android 3.1+ devices |
| + * using Java reflection. |
| + */ |
| + private void clearConnectionProxy() |
| + { |
| + String proxyHost = proxyConfiguration.getProperty("adblock.proxyHost"); |
| + String proxyPort = proxyConfiguration.getProperty("adblock.proxyPort"); |
| + String proxyExcl = proxyConfiguration.getProperty("adblock.proxyExcl"); |
| + int port = 0; |
| + try |
| + { |
| + if (proxyHost != null) |
| + port = Integer.valueOf(proxyPort); |
| + } |
| + catch (NumberFormatException e) |
| + { |
| + Log.e(TAG, "Bad port setting", e); |
| + } |
| + ProxySettings.setConnectionProxy(getApplicationContext(), proxyHost, port, proxyExcl); |
| + } |
| + |
| + /** |
| + * Sets user proxy settings in proxy service properties. |
| + */ |
| + private void configureUserProxy(Properties config, String proxyHost, String proxyPort, String proxyExcl, String proxyUser, String proxyPass) |
| + { |
| + // Clean previous settings |
| + config.remove("adblock.proxyHost"); |
| + config.remove("adblock.proxyPort"); |
| + config.remove("adblock.auth"); |
| + config.remove("adblock.proxyExcl"); |
| + if (!transparent) |
| + { |
| + config.remove("https.proxyHost"); |
| + config.remove("https.proxyPort"); |
| + config.remove("https.auth"); |
| + } |
| + |
| + if (nativeProxyAutoConfigured) |
| + passProxySettings(proxyHost, proxyPort, proxyExcl); |
| + |
| + // Check if there are any settings |
| + if (proxyHost == null || "".equals(proxyHost)) |
| + return; |
| + |
| + // Check for dirty proxy settings - this indicated previous crash: |
| + // proxy points to ourselves |
| + // proxy port is null, 0 or not a number |
| + // proxy is 127.0.0.1:8080 |
| + if (proxyPort == null) |
| + return; |
| + int p = 0; |
| + try |
| + { |
| + p = Integer.valueOf(proxyPort); |
| + } |
| + catch (NumberFormatException e) |
| + { |
| + return; |
| + } |
| + if (p == 0 || isLocalHost(proxyHost) && (p == port || p == 8080)) |
| + { |
| + if (nativeProxyAutoConfigured) |
| + passProxySettings(null, null, null); |
| + return; |
| + } |
| + |
| + config.put("adblock.proxyHost", proxyHost); |
| + config.put("adblock.proxyPort", proxyPort); |
| + if (!transparent) |
| + { |
| + config.put("https.proxyHost", proxyHost); |
| + config.put("https.proxyPort", proxyPort); |
| + } |
| + |
| + // TODO Not implemented in our proxy but needed to restore settings |
| + if (proxyExcl != null) |
| + config.put("adblock.proxyExcl", proxyExcl); |
| + |
| + if (proxyUser != null && !"".equals(proxyUser) && proxyPass != null && !"".equals(proxyPass)) |
| + { |
| + // Base64 encode user:password |
| + String proxyAuth = "Basic " + new String(Base64.encode(proxyUser + ":" + proxyPass)); |
| + config.put("adblock.auth", proxyAuth); |
| + if (!transparent) |
| + config.put("https.auth", proxyAuth); |
| + } |
| + } |
| + |
| + private void passProxySettings(String proxyHost, String proxyPort, String proxyExcl) |
| + { |
| + try |
| + { |
| + CrashHandler handler = (CrashHandler) Thread.getDefaultUncaughtExceptionHandler(); |
| + handler.saveProxySettings(proxyHost, proxyPort, proxyExcl); |
| + } |
| + catch (ClassCastException e) |
| + { |
| + // ignore - default handler in use |
| + } |
| + } |
| + |
| + @Override |
| + public void onSharedPreferenceChanged(SharedPreferences sharedPreferences, String key) |
| + { |
| + if (!NATIVE_PROXY_SUPPORTED) |
| + { |
| + String ketHost = getString(R.string.pref_proxyhost); |
| + String keyPort = getString(R.string.pref_proxyport); |
| + String keyUser = getString(R.string.pref_proxyuser); |
| + String keyPass = getString(R.string.pref_proxypass); |
| + if (key.equals(ketHost) || key.equals(keyPort) || key.equals(keyUser) || key.equals(keyPass)) |
| + { |
| + String proxyHost = sharedPreferences.getString(ketHost, null); |
| + String proxyPort = sharedPreferences.getString(keyPort, null); |
| + String proxyUser = sharedPreferences.getString(keyUser, null); |
| + String proxyPass = sharedPreferences.getString(keyPass, null); |
| + if (proxy != null) |
| + { |
| + configureUserProxy(proxyConfiguration, proxyHost, proxyPort, null, proxyUser, proxyPass); |
| + proxy.restart(proxyConfiguration.getProperty("handler")); |
| + } |
| + } |
| + } |
| + } |
| + |
| + public boolean isTransparent() |
| + { |
| + return transparent; |
| + } |
| + |
| + public boolean isNativeProxyAutoConfigured() |
| + { |
| + return nativeProxyAutoConfigured; |
| + } |
| + |
| + /** |
| + * Checks if user has to set proxy settings manually |
| + */ |
| + public boolean isManual() |
| + { |
| + return !transparent && !nativeProxyAutoConfigured; |
| + } |
| + |
| + /** |
| + * Checks whether traffic check is pending |
| + */ |
| + public boolean noTraffic() |
| + { |
| + return notrafficHandler != null; |
| + } |
| + |
| + /** |
| + * Checks if specified host is local. |
| + */ |
| + private static final boolean isLocalHost(String host) |
| + { |
| + if (host == null) |
| + return false; |
| + |
| + try |
| + { |
| + if (host.equalsIgnoreCase("localhost")) |
| + return true; |
| + |
| + String className = "android.net.NetworkUtils"; |
| + Class<?> c = Class.forName(className); |
| + /* |
| + * InetAddress address = NetworkUtils.numericToInetAddress(host); |
| + */ |
| + Method method = c.getMethod("numericToInetAddress", String.class); |
| + InetAddress address = (InetAddress) method.invoke(null, host); |
| + |
| + if (address.isLoopbackAddress()) |
| + return true; |
| + } |
| + catch (Exception e) |
| + { |
| + Log.w(TAG, null, e); |
| + } |
| + return false; |
| + } |
| + |
| + /** |
| + * Initializes iptables executable. |
| + * |
| + * @throws FileNotFoundException |
| + * If iptables initialization failed due to provided reasons. |
| + */ |
| + private void initIptables() throws IOException, RootToolsException, TimeoutException, FileNotFoundException |
| + { |
| + if (!RootTools.isAccessGiven()) |
| + throw new FileNotFoundException("No root access"); |
| + |
| + File ipt = getFileStreamPath("iptables"); |
| + |
| + if (!ipt.exists()) |
| + { |
| + Log.e(TAG, "No iptables excutable found"); |
| + throw new FileNotFoundException("No iptables executable"); |
| + } |
| + |
| + String path = ipt.getAbsolutePath(); |
| + |
| + RootTools.sendShell("chmod 700 " + path, DEFAULT_TIMEOUT); |
| + |
| + boolean compatible = false; |
| + boolean version = false; |
| + |
| + String command = path + " --version\n" + path + " -L -t nat -n\n"; |
| + |
| + List<String> result = RootTools.sendShell(command, DEFAULT_TIMEOUT); |
| + for (String line : result) |
| + { |
| + if (line.contains("OUTPUT")) |
| + compatible = true; |
| + if (line.contains("v1.4.")) |
| + version = true; |
| + } |
| + |
| + if (!compatible || !version) |
| + { |
| + Log.e(TAG, "Incompatible iptables excutable"); |
| + throw new FileNotFoundException("Incompatible iptables excutable"); |
| + } |
| + |
| + iptables = path; |
| + } |
| + |
| + public List<String> getIptablesOutput() |
| + { |
| + if (iptables == null) |
| + return null; |
| + |
| + String command = iptables + " -L -t nat -n\n"; |
| + try |
| + { |
| + return RootTools.sendShell(command, DEFAULT_TIMEOUT); |
| + } |
| + catch (Exception e) |
| + { |
| + Log.e(TAG, "Failed to get iptables configuration", e); |
| + return null; |
| + } |
| + } |
| + |
| + /** |
| + * Raises or removes no traffic notification based on current link proxy |
| + * settings |
| + */ |
| + private void updateNoTrafficCheck(ConnectivityManager connectivityManager) |
| + { |
| + try |
| + { |
| + Object pp = ProxySettings.getActiveLinkProxy(connectivityManager); |
| + String[] userProxy = ProxySettings.getUserProxy(pp); |
| + if (userProxy != null) |
| + Log.i(TAG, "Proxy settings: " + userProxy[0] + ":" + userProxy[1] + "(" + userProxy[2] + ")"); |
| + updateNoTrafficCheck(userProxy); |
| + } |
| + catch (Exception e) |
| + { |
| + // This should not happen |
| + Log.e(TAG, null, e); |
| + } |
| + } |
| + |
| + /** |
| + * Raises or removes no traffic notification based on the user proxy settings |
| + */ |
| + private void updateNoTrafficCheck(String[] userProxy) |
| + { |
| + boolean ourProxy = userProxy != null && isLocalHost(userProxy[0]) && Integer.valueOf(userProxy[1]) == port; |
| + if (ourProxy != proxyManualyConfigured) |
| + { |
| + proxyManualyConfigured = ourProxy; |
| + sendStateChangedBroadcast(); |
| + } |
| + if (ourProxy) |
| + { |
| + stopNoTrafficCheck(); |
| + } |
| + else |
| + { |
| + // Initiate no traffic check |
| + notrafficHandler = new Handler(); |
| + notrafficHandler.postDelayed(noTraffic, NO_TRAFFIC_TIMEOUT); |
| + } |
| + NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| + notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| + } |
| + |
| + /** |
| + * Stops no traffic check and resets notification message. |
| + */ |
| + private void stopNoTrafficCheck() |
| + { |
| + if (notrafficHandler != null) |
| + { |
| + notrafficHandler.removeCallbacks(noTraffic); |
| + sendStateChangedBroadcast(); |
| + NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| + notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| + notificationManager.cancel(NOTRAFFIC_NOTIFICATION_ID); |
| + } |
| + notrafficHandler = null; |
| + } |
| + |
| + @SuppressLint("NewApi") |
| + private Notification getNotification() |
| + { |
| + boolean filtering = AdblockPlus.getApplication().isFilteringEnabled(); |
| + |
| + int msgId = R.string.notif_waiting; |
| + if (nativeProxyAutoConfigured || proxyManualyConfigured) |
| + msgId = filtering ? R.string.notif_wifi : R.string.notif_wifi_nofiltering; |
| + if (transparent) |
| + msgId = R.string.notif_all; |
| + |
| + NotificationCompat.Builder builder = new NotificationCompat.Builder(this); |
| + if (hideIcon && msgId != R.string.notif_waiting) |
| + { |
| + builder.setWhen(POSITION_RIGHT); |
| + builder.setSmallIcon(R.drawable.transparent); |
| + //builder.setContent(new RemoteViews(getPackageName(), R.layout.notif_hidden)); |
| + } |
| + else |
| + { |
| + builder.setWhen(0); |
| + builder.setSmallIcon(R.drawable.ic_stat_blocking); |
| + } |
| + PendingIntent contentIntent = PendingIntent.getActivity(this, 0, new Intent(this, Preferences.class).addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP | Intent.FLAG_ACTIVITY_NEW_TASK), 0); |
| + builder.setContentIntent(contentIntent); |
| + builder.setContentTitle(getText(R.string.app_name)); |
| + builder.setContentText(getString(msgId, port)); |
| + builder.setOngoing(true); |
| + |
| + Notification notification = builder.getNotification(); |
| + return notification; |
| + } |
| + |
| + public void setEmptyIcon(boolean hide) |
| + { |
| + hideIcon = hide; |
| + NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| + notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| + } |
| + |
| + public void sendStateChangedBroadcast() |
| + { |
| + Log.i(TAG, "Broadcasting " + BROADCAST_STATE_CHANGED); |
| + boolean manual = isManual(); |
| + Intent stateIntent = new Intent(BROADCAST_STATE_CHANGED).putExtra("enabled", true).putExtra("port", port).putExtra("manual", manual); |
| + if (manual) |
| + stateIntent.putExtra("configured", proxyManualyConfigured); |
| + sendBroadcast(stateIntent); |
| + } |
| + |
| + private final IBinder binder = new LocalBinder(); |
| + |
| + public final class LocalBinder extends Binder |
| + { |
| + public ProxyService getService() |
| + { |
| + return ProxyService.this; |
| + } |
| + } |
| + |
| + @Override |
| + public IBinder onBind(Intent intent) |
| + { |
| + return binder; |
| + } |
| + |
| + /** |
| + * Executed if no traffic is detected after a period of time. Notifies user |
| + * about possible configuration problems. |
| + */ |
| + private Runnable noTraffic = new Runnable() |
| + { |
| + public void run() |
| + { |
| + // It's weird but notrafficHandler.removeCallbacks(noTraffic) does not remove this callback |
| + if (notrafficHandler == null) |
| + return; |
| + // Show warning notification |
| + NotificationCompat.Builder builder = new NotificationCompat.Builder(ProxyService.this); |
| + builder.setSmallIcon(R.drawable.ic_stat_warning); |
| + builder.setWhen(System.currentTimeMillis()); |
| + builder.setAutoCancel(true); |
| + Intent intent = new Intent(ProxyService.this, ConfigurationActivity.class).addFlags(Intent.FLAG_ACTIVITY_NEW_TASK); |
| + intent.putExtra("port", port); |
| + PendingIntent contentIntent = PendingIntent.getActivity(ProxyService.this, 0, intent, PendingIntent.FLAG_UPDATE_CURRENT); |
| + builder.setContentIntent(contentIntent); |
| + builder.setContentTitle(getText(R.string.app_name)); |
| + builder.setContentText(getText(R.string.notif_notraffic)); |
| + NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| + notificationManager.notify(NOTRAFFIC_NOTIFICATION_ID, builder.getNotification()); |
| + } |
| + }; |
| + |
| + /** |
| + * Stops no traffic check if traffic is detected by proxy service. |
| + */ |
| + private BroadcastReceiver filterReceiver = new BroadcastReceiver() |
| + { |
| + @Override |
| + public void onReceive(final Context context, Intent intent) |
| + { |
| + if (intent.getAction().equals(AdblockPlus.BROADCAST_FILTERING_CHANGE)) |
| + { |
| + // It's rather a hack but things are happening simultaneously and we |
| + // receive this broadcast despite the fact we have unsubscribed from |
| + // it and notification is not removed because it is changed to new one |
| + // during removal. |
| + if (!ProxyService.this.isNativeProxyAutoConfigured()) |
| + { |
| + NotificationManager notificationManager = (NotificationManager) getSystemService(NOTIFICATION_SERVICE); |
| + notificationManager.notify(ONGOING_NOTIFICATION_ID, getNotification()); |
| + } |
| + } |
| + if (intent.getAction().equals(AdblockPlus.BROADCAST_FILTER_MATCHES)) |
| + { |
| + proxyManualyConfigured = true; |
| + stopNoTrafficCheck(); |
| + } |
| + } |
| + }; |
| + |
| + /** |
| + * Stops service if proxy fails. |
| + */ |
| + private BroadcastReceiver proxyReceiver = new BroadcastReceiver() |
| + { |
| + @Override |
| + public void onReceive(final Context context, Intent intent) |
| + { |
| + if (intent.getAction().equals(ProxyService.BROADCAST_PROXY_FAILED)) |
| + { |
| + stopSelf(); |
| + } |
| + } |
| + }; |
| + |
| + /** |
| + * Monitors system network connection settings changes and updates proxy |
| + * settings accordingly. |
| + */ |
| + private BroadcastReceiver connectionReceiver = new BroadcastReceiver() |
| + { |
| + @Override |
| + public void onReceive(Context ctx, Intent intent) |
| + { |
| + String action = intent.getAction(); |
| + Log.i(TAG, "Action: " + action); |
| + // Connectivity change |
| + if (ConnectivityManager.CONNECTIVITY_ACTION.equals(action)) |
| + { |
| + ConnectivityManager connectivityManager = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE); |
| + // TODO Should we use ConnectivityManagerCompat.getNetworkInfoFromBroadcast() instead? |
| + NetworkInfo info = connectivityManager.getActiveNetworkInfo(); |
| + if (info == null) |
| + return; |
| + String typeName = info.getTypeName(); |
| + String subtypeName = info.getSubtypeName(); |
| + boolean available = info.isAvailable(); |
| + |
| + Log.i(TAG, "Network Type: " + typeName + ", subtype: " + subtypeName + ", available: " + available); |
| + if (info.getType() == ConnectivityManager.TYPE_WIFI) |
| + { |
| + if (nativeProxyAutoConfigured) |
| + { |
| + ProxySettings.setConnectionProxy(getApplicationContext(), LOCALHOST, port, ""); |
| + } |
| + else |
| + { |
| + updateNoTrafficCheck(connectivityManager); |
| + } |
| + } |
| + } |
| + // Proxy change |
| + else if (Proxy.PROXY_CHANGE_ACTION.equals(action)) |
| + { |
| + Object pp = intent.getParcelableExtra("proxy"); |
| + try |
| + { |
| + String[] userProxy = ProxySettings.getUserProxy(pp); |
| + if (nativeProxyAutoConfigured) |
| + { |
| + if (userProxy != null && Integer.valueOf(userProxy[1]) != port) |
| + { |
| + Log.i(TAG, "User has set new proxy: " + userProxy[0] + ":" + userProxy[1] + "(" + userProxy[2] + ")"); |
| + if (proxy != null) |
| + { |
| + configureUserProxy(proxyConfiguration, userProxy[0], userProxy[1], userProxy[2], null, null); |
| + proxy.restart(proxyConfiguration.getProperty("handler")); |
| + } |
| + } |
| + } |
| + else |
| + { |
| + Log.i(TAG, "User has set proxy: " + userProxy[0] + ":" + userProxy[1] + "(" + userProxy[2] + ")"); |
| + updateNoTrafficCheck(userProxy); |
| + } |
| + } |
| + catch (Exception e) |
| + { |
| + // This should not happen |
| + Log.e(TAG, null, e); |
| + } |
| + } |
| + } |
| + }; |
| + |
| + final class ProxyServer extends Server |
| + { |
| + @Override |
| + public void close() |
| + { |
| + try |
| + { |
| + listen.close(); |
| + this.interrupt(); |
| + this.join(); |
| + } |
| + catch (Exception e) |
| + { |
| + // ignore - it always happens |
| + } |
| + log(LOG_WARNING, null, "server stopped"); |
| + } |
| + |
| + @Override |
| + public void log(int level, Object obj, String message) |
| + { |
| + if (level <= logLevel) |
| + { |
| + Log.println(7 - level, obj != null ? obj.toString() : TAG, message); |
| + } |
| + } |
| + } |
| +} |