[Android] Remove InvalidationGcmUpstreamSender implementation

InvalidationGcmUpstreamSender uses deprecated ChromeSigninController.
This class is also part of the old invalidation code and can be removed.
This cl removes the implementation of the class in order to reduce usage
of ChromeSigninController. An empty override of deliverMessage() is kept
to avoid crashes.

Possibly this whole class will be removed in the future.

Bug: 1074072
Change-Id: I4874a1582cbcb30d63884c7c764a8932b963bedf
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2202976Reviewed-by: Tommy Nyquist <nyquist@chromium.org>
Commit-Queue: Tanmoy Mollik <triploblastic@chromium.org>
Cr-Commit-Position: refs/heads/master@{#770059}

chrome/android/java/src/org/chromium/chrome/browser/services/gcm/InvalidationGcmUpstreamSender.java

@@ -4,132 +4,14 @@
 
 package org.chromium.chrome.browser.services.gcm;
 
-import android.accounts.Account;
-import android.annotation.SuppressLint;
-import android.content.Context;
 import android.os.Bundle;
-import android.os.Parcel;
-import android.util.Log;
 
-import androidx.annotation.MainThread;
-import androidx.annotation.Nullable;
-
-import com.google.android.gms.gcm.GoogleCloudMessaging;
 import com.google.ipc.invalidation.ticl.android2.channel.GcmUpstreamSenderService;
 
-import org.chromium.base.ContextUtils;
-import org.chromium.base.ThreadUtils;
-import org.chromium.base.task.PostTask;
-import org.chromium.base.task.TaskTraits;
-import org.chromium.chrome.browser.init.ProcessInitializationHandler;
-import org.chromium.components.signin.AccountManagerFacadeProvider;
-import org.chromium.components.signin.ChromeSigninController;
-import org.chromium.components.signin.identitymanager.IdentityManager;
-import org.chromium.components.sync.SyncConstants;
-import org.chromium.content_public.browser.UiThreadTaskTraits;
-
-import java.io.IOException;
-import java.util.UUID;
-
 /**
  * Sends Upstream messages for Invalidations using GCM.
  */
 public class InvalidationGcmUpstreamSender extends GcmUpstreamSenderService {
-    private static final String TAG = "InvalidationGcmUpstream";
-
-    // GCM Payload Limit in bytes.
-    private static final int GCM_PAYLOAD_LIMIT = 4000;
-
     @Override
-    public void deliverMessage(final String to, final Bundle data) {
-        final Bundle dataToSend = createDeepCopy(data);
-
-        PostTask.postTask(UiThreadTaskTraits.DEFAULT, new Runnable() {
-            @Override
-            public void run() {
-                doDeliverMessage(ContextUtils.getApplicationContext(), to, dataToSend);
-            }
-        });
-    }
-
-    @MainThread
-    private void doDeliverMessage(
-            final Context applicationContext, final String to, final Bundle data) {
-        ThreadUtils.assertOnUiThread();
-        ProcessInitializationHandler.getInstance().initializePreNative();
-
-        @Nullable
-        Account account = ChromeSigninController.get().getSignedInUser();
-        if (account == null) {
-            // This should never happen, because this code should only be run if a user is
-            // signed-in.
-            Log.w(TAG, "No signed-in user; cannot send message to data center");
-            return;
-        }
-
-        // Attempt to retrieve a token for the user.
-        // crbug.com/1014098: Do not use IdentityServicesProvider because the profile may not be
-        // initialized yet.
-        IdentityManager.getAccessTokenWithFacade(AccountManagerFacadeProvider.getInstance(),
-                account, SyncConstants.CHROME_SYNC_OAUTH2_SCOPE,
-                new IdentityManager.GetAccessTokenCallback() {
-                    @Override
-                    public void onGetTokenSuccess(final String token) {
-                        PostTask.postTask(TaskTraits.BEST_EFFORT_MAY_BLOCK, () -> {
-                            sendUpstreamMessage(to, data, token, applicationContext);
-                        });
-                    }
-
-                    @Override
-                    public void onGetTokenFailure(boolean isTransientError) {
-                        GcmUma.recordGcmUpstreamHistogram(ContextUtils.getApplicationContext(),
-                                GcmUma.UMA_UPSTREAM_TOKEN_REQUEST_FAILED);
-                    }
-                });
-    }
-
-    /*
-     * This function runs on a thread pool executor thread.
-     */
-    private void sendUpstreamMessage(String to, Bundle data, String token, Context context) {
-        // Add the OAuth2 token to the bundle. The token should have the prefix Bearer added to it.
-        data.putString("Authorization", "Bearer " + token);
-        if (!isMessageWithinLimit(data)) {
-            GcmUma.recordGcmUpstreamHistogram(context, GcmUma.UMA_UPSTREAM_SIZE_LIMIT_EXCEEDED);
-            return;
-        }
-        String msgId = UUID.randomUUID().toString();
-        try {
-            GoogleCloudMessaging.getInstance(ContextUtils.getApplicationContext())
-                    .send(to, msgId, 1, data);
-        } catch (IOException | IllegalArgumentException exception) {
-            Log.w(TAG, "Send message failed");
-            GcmUma.recordGcmUpstreamHistogram(context, GcmUma.UMA_UPSTREAM_SEND_FAILED);
-        }
-    }
-
-    private boolean isMessageWithinLimit(Bundle data) {
-        int size = 0;
-        for (String key : data.keySet()) {
-            size += key.length() + data.getString(key).length();
-        }
-        if (size > GCM_PAYLOAD_LIMIT) {
-            return false;
-        }
-        return true;
-    }
-
-    /*
-     * Creates and returns a deep copy of the original Bundle.
-     */
-    // TODO(crbug.com/635567): Fix this properly.
-    @SuppressLint("ParcelClassLoader")
-    private Bundle createDeepCopy(Bundle original) {
-        Parcel temp = Parcel.obtain();
-        original.writeToParcel(temp, 0);
-        temp.setDataPosition(0);
-        Bundle copy = temp.readBundle();
-        temp.recycle();
-        return copy;
-    }
+    public void deliverMessage(final String to, final Bundle data) {}
 }