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.
5 #include "chrome/browser/invalidation/invalidation_service_android.h"
7 #include "base/callback.h"
8 #include "chrome/browser/chrome_notification_types.h"
9 #include "chrome/browser/invalidation/invalidation_controller_android.h"
10 #include "components/invalidation/object_id_invalidation_map.h"
11 #include "content/public/browser/notification_service.h"
13 namespace invalidation {
15 InvalidationServiceAndroid::InvalidationServiceAndroid(
17 InvalidationControllerAndroid* invalidation_controller)
18 : invalidator_state_(syncer::INVALIDATIONS_ENABLED),
19 invalidation_controller_(invalidation_controller),
21 DCHECK(CalledOnValidThread());
22 DCHECK(invalidation_controller);
23 registrar_.Add(this, chrome::NOTIFICATION_SYNC_REFRESH_REMOTE,
24 content::Source<Profile>(profile));
27 InvalidationServiceAndroid::~InvalidationServiceAndroid() { }
29 void InvalidationServiceAndroid::RegisterInvalidationHandler(
30 syncer::InvalidationHandler* handler) {
31 DCHECK(CalledOnValidThread());
32 invalidator_registrar_.RegisterHandler(handler);
33 logger_.OnRegistration(handler->GetOwnerName());
36 void InvalidationServiceAndroid::UpdateRegisteredInvalidationIds(
37 syncer::InvalidationHandler* handler,
38 const syncer::ObjectIdSet& ids) {
39 DCHECK(CalledOnValidThread());
40 invalidator_registrar_.UpdateRegisteredIds(handler, ids);
41 invalidation_controller_->SetRegisteredObjectIds(
42 invalidator_registrar_.GetAllRegisteredIds());
43 logger_.OnUpdateIds(invalidator_registrar_.GetSanitizedHandlersIdsMap());
46 void InvalidationServiceAndroid::UnregisterInvalidationHandler(
47 syncer::InvalidationHandler* handler) {
48 DCHECK(CalledOnValidThread());
49 invalidator_registrar_.UnregisterHandler(handler);
50 logger_.OnUnregistration(handler->GetOwnerName());
53 syncer::InvalidatorState
54 InvalidationServiceAndroid::GetInvalidatorState() const {
55 DCHECK(CalledOnValidThread());
56 return invalidator_state_;
59 std::string InvalidationServiceAndroid::GetInvalidatorClientId() const {
60 DCHECK(CalledOnValidThread());
61 return invalidation_controller_->GetInvalidatorClientId();
64 InvalidationLogger* InvalidationServiceAndroid::GetInvalidationLogger() {
68 void InvalidationServiceAndroid::RequestDetailedStatus(
69 base::Callback<void(const base::DictionaryValue&)> return_callback) const {
72 IdentityProvider* InvalidationServiceAndroid::GetIdentityProvider() {
76 void InvalidationServiceAndroid::Observe(
78 const content::NotificationSource& source,
79 const content::NotificationDetails& details) {
80 DCHECK(CalledOnValidThread());
81 DCHECK_EQ(type, chrome::NOTIFICATION_SYNC_REFRESH_REMOTE);
83 content::Details<const syncer::ObjectIdInvalidationMap>
84 state_details(details);
85 const syncer::ObjectIdInvalidationMap object_invalidation_map =
86 *(state_details.ptr());
88 // An empty map implies that we should invalidate all.
89 const syncer::ObjectIdInvalidationMap& effective_invalidation_map =
90 object_invalidation_map.Empty() ?
91 syncer::ObjectIdInvalidationMap::InvalidateAll(
92 invalidator_registrar_.GetAllRegisteredIds()) :
93 object_invalidation_map;
95 invalidator_registrar_.DispatchInvalidationsToHandlers(
96 effective_invalidation_map);
97 logger_.OnInvalidation(effective_invalidation_map);
100 void InvalidationServiceAndroid::TriggerStateChangeForTest(
101 syncer::InvalidatorState state) {
102 DCHECK(CalledOnValidThread());
103 invalidator_state_ = state;
104 invalidator_registrar_.UpdateInvalidatorState(invalidator_state_);
107 } // namespace invalidation