GAIA ID migration for Android

chrome/android/java/src/org/chromium/chrome/browser/signin/AccountTrackerService.java

Index: chrome/android/java/src/org/chromium/chrome/browser/signin/AccountTrackerService.java
diff --git a/chrome/android/java/src/org/chromium/chrome/browser/signin/AccountTrackerService.java b/chrome/android/java/src/org/chromium/chrome/browser/signin/AccountTrackerService.java
new file mode 100644
index 0000000000000000000000000000000000000000..481016a2b9c05e3b79b22a5133b00207341d38a8
--- /dev/null
+++ b/chrome/android/java/src/org/chromium/chrome/browser/signin/AccountTrackerService.java
@@ -0,0 +1,150 @@
+// 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.signin;
+
+import android.content.Context;
+import android.os.AsyncTask;
+import android.util.Log;
+
+import org.chromium.base.ObserverList;
+import org.chromium.base.ThreadUtils;
+import org.chromium.sync.signin.AccountManagerHelper;
+
+/**
+* Android wrapper of AccountTrackerService which provides access from the java layer.
+* It offers the capability of fetching and seeding system accounts into AccountTrackerService in C++
+* layer, and notifies observers when it is complete.
+*/
+public class AccountTrackerService {
+    private static final String TAG = "AccountTrackerService";
+    private static AccountTrackerService sAccountTrackerService;
+    private static SystemAccountsSeedingStatus sSystemAccountsSeedingStatus =
+            SystemAccountsSeedingStatus.SEEDING_NOT_STARTED;
+    private static boolean sForceRefreshed = false;
+
+    private final Context mContext;
+    private final long mNativeAccountTrackerService;
+
+    private enum SystemAccountsSeedingStatus {
+        SEEDING_NOT_STARTED,
+        SEEDING_IN_PROGRESS,
+        SEEDING_DONE
+    }
+
+    /**
+    * Classes that want to listen for system accounts fetching and seeding should implement
+    * this interface and register with {@link #addSystemAccountsSeededListener}.
+    */
+    public interface OnSystemAccountsSeededListener {
+        void onSystemAccountsSeedingComplete();
+        void onSystemAccountsForceRefreshed();
+    }
+
+    private static final ObserverList<OnSystemAccountsSeededListener>
+            sSystemAccountsSeedingObservers = new ObserverList<OnSystemAccountsSeededListener>();
+
+    public static AccountTrackerService get(Context context) {
+        ThreadUtils.assertOnUiThread();
+        if (sAccountTrackerService == null) {
+            sAccountTrackerService = new AccountTrackerService(context);
+        }
+        return sAccountTrackerService;
+    }
+
+    private AccountTrackerService(Context context) {
+        mContext = context;
+        mNativeAccountTrackerService = nativeInit();
+    }
+
+    /**
+    * Check whether systems accounts have been seeded into AccountTrackerService in C++ layer.
+    */
+    public boolean isSystemAccountsSeeded() {
+        ThreadUtils.assertOnUiThread();
+        if (sSystemAccountsSeedingStatus == SystemAccountsSeedingStatus.SEEDING_DONE
+                && !sForceRefreshed) {

[Roger Tawa OOO till Jul 10th, 2015/08/21 20:29:15]

I don't think we need the !sForceRefreshed check here.  Same for line 85.

[gogerald1, 2015/08/21 20:47:08]

Done.

+            return true;
+        }
+
+        if (sSystemAccountsSeedingStatus == SystemAccountsSeedingStatus.SEEDING_NOT_STARTED) {
+            seedSystemAccounts();
+        }
+
+        return false;
+    }
+
+    /**
+    * Register an |observer| to observe system accounts seeding status.
+    */
+    public static void addSystemAccountsSeededListener(OnSystemAccountsSeededListener observer) {
+        ThreadUtils.assertOnUiThread();
+        sSystemAccountsSeedingObservers.addObserver(observer);
+        if (sSystemAccountsSeedingStatus == SystemAccountsSeedingStatus.SEEDING_DONE
+                && !sForceRefreshed) {
+            observer.onSystemAccountsSeedingComplete();
+        }
+    }
+
+    private void seedSystemAccounts() {
+        ThreadUtils.assertOnUiThread();
+        sSystemAccountsSeedingStatus = SystemAccountsSeedingStatus.SEEDING_IN_PROGRESS;
+        sForceRefreshed = false;
+        AccountManagerHelper accountManagerHelper = AccountManagerHelper.get(mContext);
+        java.util.List<String> accountNamesList = accountManagerHelper.getGoogleAccountNames();
+        final String[] accountNames = accountNamesList.toArray(new String[accountNamesList.size()]);
+        new AsyncTask<Void, Void, String[]>() {
+            @Override
+            public String[] doInBackground(Void... params) {
+                Log.d(TAG, "Getting id/email mapping");
+                String[] accountIds = new String[accountNames.length];
+                AccountIdProvider provider = AccountIdProvider.getInstance();
+                for (int i = 0; i < accountIds.length; ++i) {
+                    accountIds[i] = provider.getAccountId(mContext, accountNames[i]);
+                }
+                return accountIds;
+            }
+            @Override
+            public void onPostExecute(String[] accountIds) {
+                if (sForceRefreshed) {
+                    seedSystemAccounts();
+                } else {
+                    nativeSeedAccountsInfo(mNativeAccountTrackerService, accountIds, accountNames);
+                    sSystemAccountsSeedingStatus = SystemAccountsSeedingStatus.SEEDING_DONE;
+                    notifyObserversOnSeedingComplete();
+                }
+            }
+
+        }.execute();
+    }
+
+    private void notifyObserversOnSeedingComplete() {
+        for (OnSystemAccountsSeededListener observer : sSystemAccountsSeedingObservers) {
+            observer.onSystemAccountsSeedingComplete();
+        }
+    }
+
+    /**
+    * Force AccountTrackerService refresh/update systems accounts.
+    */
+    public void forceRefresh() {
+        ThreadUtils.assertOnUiThread();
+        sForceRefreshed = true;

[Roger Tawa OOO till Jul 10th, 2015/08/21 20:29:15]

Nit: rename to sForceRefresh

[gogerald1, 2015/08/21 20:47:08]

Done.

+        notifyObserversOnForceRefreshed();
+        if (sSystemAccountsSeedingStatus != SystemAccountsSeedingStatus.SEEDING_IN_PROGRESS) {
+            seedSystemAccounts();
+        }
+    }
+
+    private void notifyObserversOnForceRefreshed() {
+        for (OnSystemAccountsSeededListener observer : sSystemAccountsSeedingObservers) {
+            observer.onSystemAccountsForceRefreshed();
+        }
+    }
+
+    // Native methods.
+    private native long nativeInit();
+    private native void nativeSeedAccountsInfo(
+            long nativeAccountTrackerServiceAndroid, String[] gaiaIds, String[] accountNames);
+}