[Sync] Move //sync to //components/sync.

sync/test/android/javatests/src/org/chromium/sync/test/util/MockAccountManager.java

-// Copyright 2013 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.sync.test.util;
-
-import android.accounts.Account;
-import android.accounts.AccountManager;
-import android.accounts.AuthenticatorDescription;
-import android.content.Context;
-import android.content.Intent;
-import android.os.AsyncTask;
-
-import org.chromium.base.Callback;
-import org.chromium.base.Log;
-import org.chromium.base.VisibleForTesting;
-import org.chromium.sync.signin.AccountManagerDelegate;
-import org.chromium.sync.signin.AccountManagerHelper;
-
-import java.util.ArrayList;
-import java.util.HashSet;
-import java.util.Set;
-import java.util.UUID;
-import java.util.concurrent.LinkedBlockingDeque;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
-
-/**
- * The MockAccountManager helps out if you want to mock out all calls to the Android AccountManager.
- *
- * You should provide a set of accounts as a constructor argument, or use the more direct approach
- * and provide an array of AccountHolder objects.
- *
- * Currently, this implementation supports adding and removing accounts, handling credentials
- * (including confirming them), and handling of dummy auth tokens.
- *
- * If you want to auto-approve a given authtokentype, use addAccountHolderExplicitly(...) with
- * an AccountHolder you have built with hasBeenAccepted("yourAuthTokenType", true).
- *
- * If you want to auto-approve all auth token types for a given account, use the {@link
- * AccountHolder} builder method alwaysAccept(true).
- */
-public class MockAccountManager implements AccountManagerDelegate {
-
-    private static final String TAG = "MockAccountManager";
-
-    protected final Context mContext;
-
-    private final Set<AccountHolder> mAccounts;
-
-    // Tracks the number of in-progress getAccountsByType() tasks so that tests can wait for
-    // their completion.
-    private final ZeroCounter mGetAccountsTaskCounter;
-
-    @VisibleForTesting
-    public MockAccountManager(Context context, Context testContext, Account... accounts) {
-        mContext = context;
-        mGetAccountsTaskCounter = new ZeroCounter();
-        mAccounts = new HashSet<AccountHolder>();
-        if (accounts != null) {
-            for (Account account : accounts) {
-                mAccounts.add(AccountHolder.create().account(account).alwaysAccept(true).build());
-            }
-        }
-    }
-
-    private static class SingleThreadedExecutor extends ThreadPoolExecutor {
-        public SingleThreadedExecutor() {
-            super(1, 1, 1, TimeUnit.SECONDS, new LinkedBlockingDeque<Runnable>());
-        }
-    }
-
-    @Override
-    public Account[] getAccountsByType(String type) {
-        if (!AccountManagerHelper.GOOGLE_ACCOUNT_TYPE.equals(type)) {
-            throw new IllegalArgumentException("Invalid account type: " + type);
-        }
-        if (mAccounts == null) {
-            return new Account[0];
-        } else {
-            ArrayList<Account> validAccounts = new ArrayList<Account>();
-            for (AccountHolder ah : mAccounts) {
-                if (type.equals(ah.getAccount().type)) {
-                    validAccounts.add(ah.getAccount());
-                }
-            }
-
-            Account[] accounts = new Account[validAccounts.size()];
-            int i = 0;
-            for (Account account : validAccounts) {
-                accounts[i++] = account;
-            }
-            return accounts;
-        }
-    }
-
-    @Override
-    public void getAccountsByType(final String type, final Callback<Account[]> callback) {
-        mGetAccountsTaskCounter.increment();
-        new AsyncTask<Void, Void, Account[]>() {
-            @Override
-            protected Account[] doInBackground(Void... params) {
-                return getAccountsByType(type);
-            }
-
-            @Override
-            protected void onPostExecute(Account[] accounts) {
-                callback.onResult(accounts);
-                mGetAccountsTaskCounter.decrement();
-            }
-        }.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
-    }
-
-    @VisibleForTesting
-    public void waitForGetAccountsTask() throws InterruptedException {
-        // Wait until all tasks are done because we don't know which is being waited for.
-        mGetAccountsTaskCounter.waitUntilZero();
-    }
-
-    @VisibleForTesting
-    public boolean addAccountHolderExplicitly(AccountHolder accountHolder) {
-        return addAccountHolderExplicitly(accountHolder, false);
-    }
-
-    /**
-     * Add an AccountHolder directly.
-     *
-     * @param accountHolder the account holder to add
-     * @param broadcastEvent whether to broadcast an AccountChangedEvent
-     * @return whether the account holder was added successfully
-     */
-    public boolean addAccountHolderExplicitly(AccountHolder accountHolder,
-            boolean broadcastEvent) {
-        boolean result = mAccounts.add(accountHolder);
-        if (broadcastEvent) {
-            postAsyncAccountChangedEvent();
-        }
-        return result;
-    }
-
-    @VisibleForTesting
-    public boolean removeAccountHolderExplicitly(AccountHolder accountHolder) {
-        return removeAccountHolderExplicitly(accountHolder, false);
-    }
-
-    /**
-     * Remove an AccountHolder directly.
-     *
-     * @param accountHolder the account holder to remove
-     * @param broadcastEvent whether to broadcast an AccountChangedEvent
-     * @return whether the account holder was removed successfully
-     */
-    public boolean removeAccountHolderExplicitly(AccountHolder accountHolder,
-            boolean broadcastEvent) {
-        boolean result = mAccounts.remove(accountHolder);
-        if (broadcastEvent) {
-            postAsyncAccountChangedEvent();
-        }
-        return result;
-    }
-
-    @Override
-    public String getAuthToken(Account account, String authTokenScope) {
-        AccountHolder ah = getAccountHolder(account);
-        assert ah.hasBeenAccepted(authTokenScope);
-        synchronized (mAccounts) {
-            // Some tests register auth tokens with value null, and those should be preserved.
-            if (!ah.hasAuthTokenRegistered(authTokenScope)
-                    && ah.getAuthToken(authTokenScope) == null) {
-                // No authtoken registered. Need to create one.
-                String authToken = UUID.randomUUID().toString();
-                Log.d(TAG, "Created new auth token for " + ah.getAccount() + ": authTokenScope = "
-                                + authTokenScope + ", authToken = " + authToken);
-                ah = ah.withAuthToken(authTokenScope, authToken);
-                mAccounts.add(ah);
-            }
-        }
-        return ah.getAuthToken(authTokenScope);
-    }
-
-    @Override
-    public void invalidateAuthToken(String authToken) {
-        if (authToken == null) {
-            throw new IllegalArgumentException("AuthToken can not be null");
-        }
-        for (AccountHolder ah : mAccounts) {
-            if (ah.removeAuthToken(authToken)) {
-                break;
-            }
-        }
-    }
-
-    @Override
-    public AuthenticatorDescription[] getAuthenticatorTypes() {
-        AuthenticatorDescription googleAuthenticator = new AuthenticatorDescription(
-                AccountManagerHelper.GOOGLE_ACCOUNT_TYPE, "p1", 0, 0, 0, 0);
-
-        return new AuthenticatorDescription[] { googleAuthenticator };
-    }
-
-    @Override
-    public void hasFeatures(
-            Account account, final String[] features, final Callback<Boolean> callback) {
-        final AccountHolder accountHolder = getAccountHolder(account);
-        accountHolder.addFeaturesCallback(new Runnable() {
-            @Override
-            public void run() {
-                Set<String> accountFeatures = accountHolder.getFeatures();
-                boolean hasAllFeatures = true;
-                for (String feature : features) {
-                    if (!accountFeatures.contains(feature)) {
-                        Log.d(TAG, accountFeatures + " does not contain " + feature);
-                        hasAllFeatures = false;
-                    }
-                }
-                callback.onResult(hasAllFeatures);
-            }
-        });
-    }
-
-    private AccountHolder getAccountHolder(Account account) {
-        if (account == null) {
-            throw new IllegalArgumentException("Account can not be null");
-        }
-        for (AccountHolder accountHolder : mAccounts) {
-            if (account.equals(accountHolder.getAccount())) {
-                return accountHolder;
-            }
-        }
-        throw new IllegalArgumentException("Can not find AccountHolder for account " + account);
-    }
-
-    private void postAsyncAccountChangedEvent() {
-        // Mimic that this does not happen on the main thread.
-        new AsyncTask<Void, Void, Void>() {
-            @Override
-            protected Void doInBackground(Void... params) {
-                mContext.sendBroadcast(new Intent(AccountManager.LOGIN_ACCOUNTS_CHANGED_ACTION));
-                return null;
-            }
-        }.execute();
-    }
-
-    /**
-     * Simple concurrency helper class for waiting until a resource count becomes zero.
-     */
-    private static class ZeroCounter {
-        private static final int WAIT_TIMEOUT_MS = 10000;
-
-        private final Object mLock = new Object();
-        private int mCount = 0;
-
-        public void increment() {
-            synchronized (mLock) {
-                mCount++;
-            }
-        }
-
-        public void decrement() {
-            synchronized (mLock) {
-                if (--mCount == 0) {
-                    mLock.notifyAll();
-                }
-            }
-        }
-
-        public void waitUntilZero() throws InterruptedException {
-            synchronized (mLock) {
-                while (mCount != 0) {
-                    mLock.wait(WAIT_TIMEOUT_MS);
-                }
-            }
-        }
-    }
-}