src/chrome/browser/invalidation/invalidation_service_android.cc

   1 // Copyright (c) 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/invalidation/invalidation_service_android.h"
   6
   7 #include "chrome/browser/chrome_notification_types.h"
   8 #include "chrome/browser/invalidation/invalidation_controller_android.h"
   9 #include "content/public/browser/notification_service.h"
  10
  11 namespace invalidation {
  12
  13 InvalidationServiceAndroid::InvalidationServiceAndroid(
  14     Profile* profile,
  15     InvalidationControllerAndroid* invalidation_controller)
  16     : invalidator_state_(syncer::INVALIDATIONS_ENABLED),
  17       invalidation_controller_(invalidation_controller) {
  18   DCHECK(CalledOnValidThread());
  19   DCHECK(invalidation_controller);
  20   registrar_.Add(this, chrome::NOTIFICATION_SYNC_REFRESH_REMOTE,
  21                  content::Source<Profile>(profile));
  22 }
  23
  24 InvalidationServiceAndroid::~InvalidationServiceAndroid() { }
  25
  26 void InvalidationServiceAndroid::RegisterInvalidationHandler(
  27     syncer::InvalidationHandler* handler) {
  28   DCHECK(CalledOnValidThread());
  29   invalidator_registrar_.RegisterHandler(handler);
  30 }
  31
  32 void InvalidationServiceAndroid::UpdateRegisteredInvalidationIds(
  33     syncer::InvalidationHandler* handler,
  34     const syncer::ObjectIdSet& ids) {
  35   DCHECK(CalledOnValidThread());
  36   invalidator_registrar_.UpdateRegisteredIds(handler, ids);
  37   invalidation_controller_->SetRegisteredObjectIds(
  38       invalidator_registrar_.GetAllRegisteredIds());
  39 }
  40
  41 void InvalidationServiceAndroid::UnregisterInvalidationHandler(
  42     syncer::InvalidationHandler* handler) {
  43   DCHECK(CalledOnValidThread());
  44   invalidator_registrar_.UnregisterHandler(handler);
  45 }
  46
  47 void InvalidationServiceAndroid::AcknowledgeInvalidation(
  48     const invalidation::ObjectId& id,
  49     const syncer::AckHandle& ack_handle) {
  50   DCHECK(CalledOnValidThread());
  51   // Do nothing.  The Android invalidator does not support ack tracking.
  52 }
  53
  54 syncer::InvalidatorState
  55 InvalidationServiceAndroid::GetInvalidatorState() const {
  56   DCHECK(CalledOnValidThread());
  57   return invalidator_state_;
  58 }
  59
  60 std::string InvalidationServiceAndroid::GetInvalidatorClientId() const {
  61   DCHECK(CalledOnValidThread());
  62   // TODO: Return a valid ID here.  See crbug.com/172391.
  63   return "Bogus";
  64 }
  65
  66 void InvalidationServiceAndroid::Observe(
  67     int type,
  68     const content::NotificationSource& source,
  69     const content::NotificationDetails& details) {
  70   DCHECK(CalledOnValidThread());
  71   DCHECK_EQ(type, chrome::NOTIFICATION_SYNC_REFRESH_REMOTE);
  72
  73   content::Details<const syncer::ObjectIdInvalidationMap>
  74       state_details(details);
  75   const syncer::ObjectIdInvalidationMap object_invalidation_map =
  76       *(state_details.ptr());
  77
  78   // An empty map implies that we should invalidate all.
  79   const syncer::ObjectIdInvalidationMap& effective_invalidation_map =
  80       object_invalidation_map.Empty() ?
  81       syncer::ObjectIdInvalidationMap::InvalidateAll(
  82           invalidator_registrar_.GetAllRegisteredIds()) :
  83       object_invalidation_map;
  84
  85   invalidator_registrar_.DispatchInvalidationsToHandlers(
  86       effective_invalidation_map);
  87 }
  88
  89 void InvalidationServiceAndroid::TriggerStateChangeForTest(
  90     syncer::InvalidatorState state) {
  91   DCHECK(CalledOnValidThread());
  92   invalidator_state_ = state;
  93   invalidator_registrar_.UpdateInvalidatorState(invalidator_state_);
  94 }
  95
  96 } //  namespace invalidation