1// Copyright 2014 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 "components/invalidation/invalidation_notifier.h" 6 7#include "base/bind.h" 8#include "base/logging.h" 9#include "base/message_loop/message_loop_proxy.h" 10#include "base/metrics/histogram.h" 11#include "components/invalidation/invalidation_handler.h" 12#include "google/cacheinvalidation/include/invalidation-client-factory.h" 13#include "jingle/notifier/listener/push_client.h" 14#include "net/url_request/url_request_context.h" 15#include "talk/xmpp/jid.h" 16#include "talk/xmpp/xmppclientsettings.h" 17 18namespace syncer { 19 20InvalidationNotifier::InvalidationNotifier( 21 scoped_ptr<SyncNetworkChannel> network_channel, 22 const std::string& invalidator_client_id, 23 const UnackedInvalidationsMap& saved_invalidations, 24 const std::string& invalidation_bootstrap_data, 25 const base::WeakPtr<InvalidationStateTracker>& invalidation_state_tracker, 26 scoped_refptr<base::SingleThreadTaskRunner> 27 invalidation_state_tracker_task_runner, 28 const std::string& client_info) 29 : state_(STOPPED), 30 saved_invalidations_(saved_invalidations), 31 invalidation_state_tracker_(invalidation_state_tracker), 32 invalidation_state_tracker_task_runner_( 33 invalidation_state_tracker_task_runner), 34 client_info_(client_info), 35 invalidator_client_id_(invalidator_client_id), 36 invalidation_bootstrap_data_(invalidation_bootstrap_data), 37 invalidation_listener_(network_channel.Pass()) { 38} 39 40InvalidationNotifier::~InvalidationNotifier() { 41 DCHECK(CalledOnValidThread()); 42} 43 44void InvalidationNotifier::RegisterHandler(InvalidationHandler* handler) { 45 DCHECK(CalledOnValidThread()); 46 registrar_.RegisterHandler(handler); 47} 48 49void InvalidationNotifier::UpdateRegisteredIds(InvalidationHandler* handler, 50 const ObjectIdSet& ids) { 51 DCHECK(CalledOnValidThread()); 52 registrar_.UpdateRegisteredIds(handler, ids); 53 invalidation_listener_.UpdateRegisteredIds(registrar_.GetAllRegisteredIds()); 54} 55 56void InvalidationNotifier::UnregisterHandler(InvalidationHandler* handler) { 57 DCHECK(CalledOnValidThread()); 58 registrar_.UnregisterHandler(handler); 59} 60 61InvalidatorState InvalidationNotifier::GetInvalidatorState() const { 62 DCHECK(CalledOnValidThread()); 63 return registrar_.GetInvalidatorState(); 64} 65 66void InvalidationNotifier::UpdateCredentials( 67 const std::string& email, const std::string& token) { 68 if (state_ == STOPPED) { 69 invalidation_listener_.Start( 70 base::Bind(&invalidation::CreateInvalidationClient), 71 invalidator_client_id_, 72 client_info_, 73 invalidation_bootstrap_data_, 74 saved_invalidations_, 75 invalidation_state_tracker_, 76 invalidation_state_tracker_task_runner_, 77 this); 78 state_ = STARTED; 79 } 80 invalidation_listener_.UpdateCredentials(email, token); 81} 82 83void InvalidationNotifier::RequestDetailedStatus( 84 base::Callback<void(const base::DictionaryValue&)> callback) const { 85 DCHECK(CalledOnValidThread()); 86 invalidation_listener_.RequestDetailedStatus(callback); 87} 88 89void InvalidationNotifier::OnInvalidate( 90 const ObjectIdInvalidationMap& invalidation_map) { 91 DCHECK(CalledOnValidThread()); 92 registrar_.DispatchInvalidationsToHandlers(invalidation_map); 93} 94 95void InvalidationNotifier::OnInvalidatorStateChange(InvalidatorState state) { 96 DCHECK(CalledOnValidThread()); 97 registrar_.UpdateInvalidatorState(state); 98} 99 100} // namespace syncer 101