Add a Physical Web JNI bridge to support native Physical Web clients

chrome/android/java/src/org/chromium/chrome/browser/physicalweb/UrlManager.java

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package org.chromium.chrome.browser.physicalweb;
 
 import android.app.AlarmManager;
 import android.app.Notification;
 import android.app.NotificationManager;
 import android.app.PendingIntent;
 import android.content.Context;
 import android.content.Intent;
 import android.content.SharedPreferences;
 import android.content.res.Resources;
 import android.graphics.Bitmap;
 import android.graphics.BitmapFactory;
 import android.os.AsyncTask;
 import android.os.Handler;
 import android.os.Looper;
 import android.os.SystemClock;
 import android.support.v4.app.NotificationCompat;
 
+import org.json.JSONException;
+import org.json.JSONObject;
+
 import org.chromium.base.ContextUtils;
 import org.chromium.base.Log;
 import org.chromium.base.ObserverList;
+import org.chromium.base.ThreadUtils;
 import org.chromium.base.VisibleForTesting;
+import org.chromium.base.annotations.CalledByNative;
+import org.chromium.base.library_loader.LibraryProcessType;
 import org.chromium.chrome.R;
 import org.chromium.chrome.browser.ChromeApplication;
 import org.chromium.chrome.browser.notifications.NotificationConstants;
 import org.chromium.chrome.browser.notifications.NotificationManagerProxy;
 import org.chromium.chrome.browser.notifications.NotificationManagerProxyImpl;
-import org.json.JSONException;
-import org.json.JSONObject;
+import org.chromium.content.browser.BrowserStartupController;
+import org.chromium.content.browser.BrowserStartupController.StartupCallback;
 
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
@@ skipping 26 matching lines @@
     private static final int MAX_CACHE_SIZE = 100;
     private static UrlManager sInstance = null;
     private final Context mContext;
     private final ObserverList<Listener> mObservers;
     private final Set<String> mNearbyUrls;
     private final Map<String, UrlInfo> mUrlInfoMap;
     private final Map<String, PwsResult> mPwsResultMap;
     private final PriorityQueue<String> mUrlsSortedByTimestamp;
     private NotificationManagerProxy mNotificationManager;
     private PwsClient mPwsClient;
+    private long mNativePhysicalWebDataSourceAndroid;
 
     /**
      * Interface for observers that should be notified when the nearby URL list changes.
      */
     public interface Listener {
         /**
          * Callback called when one or more URLs are added to the URL list.
          * @param urls A set of UrlInfos containing nearby URLs resolvable with our resolution
          * service.
          */
@@ skipping 16 matching lines @@
         mPwsResultMap = new HashMap<>();
         mUrlsSortedByTimestamp = new PriorityQueue<String>(1, new Comparator<String>() {
             @Override
             public int compare(String url1, String url2) {
                 Long scanTimestamp1 = Long.valueOf(mUrlInfoMap.get(url1).getScanTimestamp());
                 Long scanTimestamp2 = Long.valueOf(mUrlInfoMap.get(url2).getScanTimestamp());
                 return scanTimestamp1.compareTo(scanTimestamp2);
             }
         });
         initSharedPreferences();
+        registerNativeInitStartupCallback();
     }
 
     /**
      * Get a singleton instance of this class.
      * @return A singleton instance of this class.
      */
+    @CalledByNative
     public static UrlManager getInstance() {
         if (sInstance == null) {
             sInstance = new UrlManager(ContextUtils.getApplicationContext());
         }
         return sInstance;
     }
 
     /**
      * Get a singleton instance of this class.
      * @param context unused
@@ skipping 47 matching lines @@
             return;
         }
         registerNewDisplayableUrl(urlInfo);
     }
 
     /**
      * Remove a URL to the store of URLs.
      * This method additionally updates the Physical Web notification.
      * @param urlInfo The URL to remove.
      */
-    @VisibleForTesting
     public void removeUrl(UrlInfo urlInfo) {
         Log.d(TAG, "URL lost: %s", urlInfo);
         recordUpdate();
         mNearbyUrls.remove(urlInfo.getUrl());
         putCachedNearbyUrls();
 
         // If there are no URLs nearby to display, clear the notification.
         if (getUrls(PhysicalWeb.isOnboarding()).isEmpty()) {
             clearNotification();
         }
@@ skipping 45 matching lines @@
 
     public Set<String> getNearbyUrls() {
         return mNearbyUrls;
     }
 
     public Set<String> getResolvedUrls() {
         return mPwsResultMap.keySet();
     }
 
     /**
-     * Gets all UrlInfos and PwsResults for resolved URLs.
+     * Gets all UrlInfos and PwsResults for nearby URLs.
+     * The UrlInfos and PwsResults are returned as parallel arrays. Unresolved URLs in the UrlInfo
+     * array will have a null element in the corresponding entry of the PwsResult array.
+     * @return A PwCollection object containg parallel arrays of UrlInfos and PwsResults.
      */
     public PwCollection getPwCollection() {
         List<PwsResult> nearbyPwsResults = new ArrayList<>();
         for (String url : mNearbyUrls) {
             nearbyPwsResults.add(mPwsResultMap.get(url));
         }
         return new PwCollection(getUrlInfoList(mNearbyUrls), nearbyPwsResults);
     }
 
     /**
@@ skipping 354 matching lines @@
             }
             Log.d(TAG, "Garbage collecting: ", urlInfo);
             // The min value cannot have changed at this point, so it's OK to just remove via
             // poll().
             mUrlsSortedByTimestamp.poll();
             mUrlInfoMap.remove(url);
             mPwsResultMap.remove(url);
         }
     }
 
+    /**
+     * Register a StartupCallback to initialize the native portion of the JNI bridge.
+     */
+    private void registerNativeInitStartupCallback() {
+        ThreadUtils.postOnUiThread(new Runnable() {
+            @Override
+            public void run() {
+                BrowserStartupController.get(mContext, LibraryProcessType.PROCESS_BROWSER)
+                        .addStartupCompletedObserver(new StartupCallback() {
+                            @Override
+                            public void onSuccess(boolean alreadyStarted) {
+                                mNativePhysicalWebDataSourceAndroid = nativeInit();
+                            }
+
+                            @Override
+                            public void onFailure() {
+                                // Startup failed.
+                            }
+                        });
+            }
+        });
+    }
+
+    /**
+     * Checks if we have initialized the native library and received a handle to the data source.
+     * @return true if the data source handle is non-null.
+     */
+    private boolean isNativeInitialized() {
+        return mNativePhysicalWebDataSourceAndroid != 0;
+    }
+
     @VisibleForTesting
     void overridePwsClientForTesting(PwsClient pwsClient) {
         mPwsClient = pwsClient;
     }
 
     @VisibleForTesting
     void overrideNotificationManagerForTesting(
             NotificationManagerProxy notificationManager) {
         mNotificationManager = notificationManager;
     }
@@ skipping 23 matching lines @@
         return mNearbyUrls.contains(url)
                 || mPwsResultMap.containsKey(url)
                 || mUrlInfoMap.containsKey(url)
                 || mUrlsSortedByTimestamp.contains(url);
     }
 
     @VisibleForTesting
     int getMaxCacheSize() {
         return MAX_CACHE_SIZE;
     }
+
+    private native long nativeInit();
 }