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 #include "sync/notifier/object_id_invalidation_map.h"
  11
  12 namespace invalidation {
  13
  14 InvalidationServiceAndroid::InvalidationServiceAndroid(
  15     Profile* profile,
  16     InvalidationControllerAndroid* invalidation_controller)
  17     : invalidator_state_(syncer::INVALIDATIONS_ENABLED),
  18       invalidation_controller_(invalidation_controller) {
  19   DCHECK(CalledOnValidThread());
  20   DCHECK(invalidation_controller);
  21   registrar_.Add(this, chrome::NOTIFICATION_SYNC_REFRESH_REMOTE,
  22                  content::Source<Profile>(profile));
  23 }
  24
  25 InvalidationServiceAndroid::~InvalidationServiceAndroid() { }
  26
  27 void InvalidationServiceAndroid::RegisterInvalidationHandler(
  28     syncer::InvalidationHandler* handler) {
  29   DCHECK(CalledOnValidThread());
  30   invalidator_registrar_.RegisterHandler(handler);
  31 }
  32
  33 void InvalidationServiceAndroid::UpdateRegisteredInvalidationIds(
  34     syncer::InvalidationHandler* handler,
  35     const syncer::ObjectIdSet& ids) {
  36   DCHECK(CalledOnValidThread());
  37   invalidator_registrar_.UpdateRegisteredIds(handler, ids);
  38   invalidation_controller_->SetRegisteredObjectIds(
  39       invalidator_registrar_.GetAllRegisteredIds());
  40 }
  41
  42 void InvalidationServiceAndroid::UnregisterInvalidationHandler(
  43     syncer::InvalidationHandler* handler) {
  44   DCHECK(CalledOnValidThread());
  45   invalidator_registrar_.UnregisterHandler(handler);
  46 }
  47
  48 syncer::InvalidatorState
  49 InvalidationServiceAndroid::GetInvalidatorState() const {
  50   DCHECK(CalledOnValidThread());
  51   return invalidator_state_;
  52 }
  53
  54 std::string InvalidationServiceAndroid::GetInvalidatorClientId() const {
  55   DCHECK(CalledOnValidThread());
  56   return invalidation_controller_->GetInvalidatorClientId();
  57 }
  58
  59 InvalidationLogger* InvalidationServiceAndroid::GetInvalidationLogger() {
  60   return NULL;
  61 }
  62
  63 void InvalidationServiceAndroid::Observe(
  64     int type,
  65     const content::NotificationSource& source,
  66     const content::NotificationDetails& details) {
  67   DCHECK(CalledOnValidThread());
  68   DCHECK_EQ(type, chrome::NOTIFICATION_SYNC_REFRESH_REMOTE);
  69
  70   content::Details<const syncer::ObjectIdInvalidationMap>
  71       state_details(details);
  72   const syncer::ObjectIdInvalidationMap object_invalidation_map =
  73       *(state_details.ptr());
  74
  75   // An empty map implies that we should invalidate all.
  76   const syncer::ObjectIdInvalidationMap& effective_invalidation_map =
  77       object_invalidation_map.Empty() ?
  78       syncer::ObjectIdInvalidationMap::InvalidateAll(
  79           invalidator_registrar_.GetAllRegisteredIds()) :
  80       object_invalidation_map;
  81
  82   invalidator_registrar_.DispatchInvalidationsToHandlers(
  83       effective_invalidation_map);
  84 }
  85
  86 void InvalidationServiceAndroid::TriggerStateChangeForTest(
  87     syncer::InvalidatorState state) {
  88   DCHECK(CalledOnValidThread());
  89   invalidator_state_ = state;
  90   invalidator_registrar_.UpdateInvalidatorState(invalidator_state_);
  91 }
  92
  93 } //  namespace invalidation