Issue 6066 - Implement 'force update' functionality for subscriptions

adblockplussbrowser/src/main/java/org/adblockplus/sbrowser/contentblocker/engine/Engine.java

 /*
  * This file is part of Adblock Plus <https://adblockplus.org/>,
  * Copyright (C) 2006-present 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
@@ skipping 25 matching lines @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.TreeSet;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.ReentrantLock;
 
 import org.adblockplus.adblockplussbrowser.R;
+import org.adblockplus.sbrowser.contentblocker.util.ConnectivityUtils;
 import org.adblockplus.sbrowser.contentblocker.util.SharedPrefsUtils;
 import org.adblockplus.sbrowser.contentblocker.util.SubscriptionUtils;
 
 import android.content.Context;
 import android.content.Intent;
 import android.content.pm.PackageInfo;
 import android.content.pm.PackageManager;
 import android.content.pm.ResolveInfo;
 import android.net.ConnectivityManager;
 import android.net.NetworkInfo;
 import android.net.Uri;
 import android.os.Handler;
 import android.os.Looper;
 import android.text.TextUtils;
 import android.text.format.DateUtils;
 import android.util.Log;
+import android.widget.Toast;
 
 public final class Engine
 {
   private static final String TAG = Engine.class.getSimpleName();
 
   public static final String USER_FILTERS_TITLE = "__filters";
   public static final String USER_EXCEPTIONS_TITLE = "__exceptions";
 
   public static final String SBROWSER_APP_ID = "com.sec.android.app.sbrowser";
   public static final String EASYLIST_URL = "https://easylist-downloads.adblockplus.org/easylist.txt";
@@ skipping 117 matching lines @@
       public void run()
       {
         final Intent intent = new Intent();
         intent.setAction(ACTION_UPDATE);
         intent.setData(Uri.parse("package:" + Engine.this.serviceContext.getPackageName()));
         Engine.this.serviceContext.sendBroadcast(intent);
       }
     });
   }
 
-  boolean canUseInternet()
+  boolean canUseInternet(final boolean allowMetered)
   {
-    final ConnectivityManager connManager = (ConnectivityManager) this.serviceContext
-        .getSystemService(Context.CONNECTIVITY_SERVICE);
-    final NetworkInfo current = connManager.getActiveNetworkInfo();
-    if (current == null)
+    // allow a metered connection to update default subscriptions at the first run.
+    // See https://issues.adblockplus.org/ticket/5237
+    return ConnectivityUtils.canUseInternet(serviceContext, allowMetered || wasFirstRun());
+  }
+
+  public void forceUpdateSubscriptions(final boolean allowMetered)
+  {
+    try
     {
-      return false;
+      subscriptions.checkForUpdates(true, allowMetered);
+      Toast.makeText(serviceContext, serviceContext.getText(R.string.updating_subscriptions), Toast.LENGTH_LONG).show();
     }
-
-    if (wasFirstRun())
+    catch (IOException e)
     {
-      return true;
+      Log.e(TAG, "Failed checking for updates", e);
     }
-
-    final boolean wifiOnly = "1".equals(SharedPrefsUtils.getString(
-        this.serviceContext, R.string.key_automatic_updates , "1"));
-
-    if (wifiOnly)
-    {
-      if (current.isConnected() && !current.isRoaming())
-      {
-        switch (current.getType())
-        {
-          case ConnectivityManager.TYPE_BLUETOOTH:
-          case ConnectivityManager.TYPE_ETHERNET:
-          case ConnectivityManager.TYPE_WIFI:
-          case ConnectivityManager.TYPE_WIMAX:
-            return true;
-          default:
-            return false;
-        }
-      }
-      return false;
-    }
-    return current.isConnected();
   }
 
   public List<SubscriptionInfo> getListedSubscriptions()
   {
     return this.subscriptions.getSubscriptions(this);
   }
 
   public void changeSubscriptionState(final String id, final boolean enabled)
   {
     if (this.subscriptionUpdateCallback != null)
@@ skipping 437 matching lines @@
                   Log.d(TAG, "Unhandled type: " + event.getType());
                   break;
               }
             }
 
             final long currentTime = System.currentTimeMillis();
             if (currentTime > nextUpdateCheck)
             {
               nextUpdateCheck = currentTime + UPDATE_CHECK_INTERVAL;
 
-              this.engine.subscriptions.checkForUpdates();
+              this.engine.subscriptions.checkForUpdates(false, false);
             }
 
             if (currentTime > this.engine.nextUpdateBroadcast)
             {
               this.engine.nextUpdateBroadcast = Long.MAX_VALUE;
               Log.d(TAG, "Sending update broadcast");
               this.engine.writeFileAndSendUpdateBroadcast();
             }
           }
           finally
@@ skipping 66 matching lines @@
       this.id = id;
       this.responseCode = responseCode;
       this.response = response;
       if (headers != null)
       {
         this.headers.putAll(headers);
       }
     }
   }
 
-  public void enqueueDownload(final Subscription sub, final boolean forced) throws IOException
+  public void enqueueDownload(final Subscription sub, final boolean forced,
+      final boolean allowMetered) throws IOException
   {
     if (sub.getURL() != null && sub.shouldUpdate(forced))
     {
       final HashMap<String, String> headers = new HashMap<>();
       if (sub.isMetaDataValid() && sub.isFiltersValid())
       {
         final String lastModified = sub.getMeta(Subscription.KEY_HTTP_LAST_MODIFIED);
         if (!TextUtils.isEmpty(lastModified))
         {
           headers.put("If-Modified-Since", lastModified);
         }
         final String etag = sub.getMeta(Subscription.KEY_HTTP_ETAG);
         if (!TextUtils.isEmpty(etag))
         {
           headers.put("If-None-Match", etag);
         }
       }
       Log.d(TAG, headers.toString());
-      this.downloader.enqueueDownload(this.createDownloadURL(sub), sub.getId(), headers);
+      this.downloader.enqueueDownload(this.createDownloadURL(sub), sub.getId(), headers, allowMetered);
     }
   }
 
   public void connectivityChanged()
   {
     this.downloader.connectivityChanged();
   }
 
   public interface SubscriptionUpdateCallback
   {
     void subscriptionUpdateRequested(boolean enabled);
     void subscriptionUpdatedApplied();
   }
 
   public interface SubscriptionAddedCallback
   {
     void subscriptionAdded();
   }
 }