Enable invalidations for arbitrary objects on Android.

chrome/browser/invalidation/invalidation_service_android.h

 // Copyright (c) 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.
 
 #ifndef CHROME_BROWSER_INVALIDATION_INVALIDATION_SERVICE_ANDROID_H_
 #define CHROME_BROWSER_INVALIDATION_INVALIDATION_SERVICE_ANDROID_H_
 
+#include <vector>
+
 #include "base/basictypes.h"
+#include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/threading/non_thread_safe.h"
 #include "chrome/browser/invalidation/invalidation_service.h"
 #include "components/browser_context_keyed_service/browser_context_keyed_service.h"
 #include "content/public/browser/notification_observer.h"
 #include "content/public/browser/notification_registrar.h"
 #include "sync/notifier/invalidator_registrar.h"
 
+#if defined(OS_ANDROID)
+#include "base/android/jni_android.h"
+#include "base/android/jni_helper.h"
+#endif  // defined(OS_ANDROID)
+
 class Profile;
 
 namespace invalidation {
 
 // This InvalidationService is used to deliver invalidations on Android.  The
 // Android operating system has its own mechanisms for delivering invalidations.
 // This class uses the NotificationService to communicate with a thin wrapper
 // around Android's invalidations service.
 class InvalidationServiceAndroid
     : public base::NonThreadSafe,
@@ skipping 23 matching lines @@
 
   // content::NotificationObserver implementation.
   virtual void Observe(int type,
                        const content::NotificationSource& source,
                        const content::NotificationDetails& details) OVERRIDE;
 
   // The InvalidationServiceAndroid always reports that it is enabled.
   // This is used only by unit tests.
   void TriggerStateChangeForTest(syncer::InvalidatorState state);
 
+  // Replace the callback invoked when the Android invalidation controller
+  // registration is updated.
+  // The first parameter of the callback is the list of object sources, and the
+  // second parameter is the parallel list of object names.
+  // Used only for unit tests.
+  typedef base::Callback<
+      void(const std::vector<int>&, const std::vector<std::string>&)>
+          UpdateRegistrationCallback;
+  void SetUpdateRegistrationCallbackForTest(
+      const UpdateRegistrationCallback& callback);
+
  private:
+  // Update object registration with the Android invalidation controller.
+  void UpdateRegistration();
+
+  // Determine if any object in a set needs to be registered with the Android
+  // invalidation controller.
+  bool IsRegistrationRequired(const syncer::ObjectIdSet& ids);
+
+  // Determine if an object with the given id needs to be registered with the
+  // Android invalidation controller.
+  bool IsRegistrationRequired(const invalidation::ObjectId& id);
+
   syncer::InvalidatorRegistrar invalidator_registrar_;
   content::NotificationRegistrar registrar_;
   syncer::InvalidatorState invalidator_state_;
 
+#if defined(OS_ANDROID)
+  // The Android invalidation controller.
+  base::android::ScopedJavaGlobalRef<jobject> invalidation_controller_;
+#endif  // defined(OS_ANDROID)
+
+  // The callback to invoke in unit tests when updating the object registration.
+  UpdateRegistrationCallback update_registration_callback_;
+
   DISALLOW_COPY_AND_ASSIGN(InvalidationServiceAndroid);
 };
 
+#if defined(OS_ANDROID)
+bool RegisterInvalidationController(JNIEnv* env);
+#endif  // defined(OS_ANDROID)
+
 }  // namespace invalidation
 
 #endif  // CHROME_BROWSER_INVALIDATION_INVALIDATION_SERVICE_ANDROID_H_