1 // Copyright (c) 2011 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 // An implementation of SyncNotifier that wraps an invalidation 6 // client. Handles the details of connecting to XMPP and hooking it 7 // up to the invalidation client. 8 // 9 // You probably don't want to use this directly; use 10 // NonBlockingInvalidationNotifier. 11 12 #ifndef CHROME_BROWSER_SYNC_NOTIFIER_INVALIDATION_NOTIFIER_H_ 13 #define CHROME_BROWSER_SYNC_NOTIFIER_INVALIDATION_NOTIFIER_H_ 14 #pragma once 15 16 #include <string> 17 18 #include "base/basictypes.h" 19 #include "base/compiler_specific.h" 20 #include "base/memory/scoped_ptr.h" 21 #include "base/observer_list.h" 22 #include "base/threading/non_thread_safe.h" 23 #include "chrome/browser/sync/notifier/chrome_invalidation_client.h" 24 #include "chrome/browser/sync/notifier/state_writer.h" 25 #include "chrome/browser/sync/notifier/sync_notifier.h" 26 #include "chrome/browser/sync/syncable/model_type.h" 27 #include "jingle/notifier/base/notifier_options.h" 28 #include "jingle/notifier/communicator/login.h" 29 30 namespace sync_notifier { 31 32 // This class must live on the IO thread. 33 class InvalidationNotifier 34 : public SyncNotifier, 35 public notifier::LoginDelegate, 36 public ChromeInvalidationClient::Listener, 37 public StateWriter { 38 public: 39 InvalidationNotifier( 40 const notifier::NotifierOptions& notifier_options, 41 const std::string& client_info); 42 43 virtual ~InvalidationNotifier(); 44 45 // SyncNotifier implementation. 46 virtual void AddObserver(SyncNotifierObserver* observer) OVERRIDE; 47 virtual void RemoveObserver(SyncNotifierObserver* observer) OVERRIDE; 48 virtual void SetState(const std::string& state) OVERRIDE; 49 virtual void UpdateCredentials( 50 const std::string& email, const std::string& token) OVERRIDE; 51 virtual void UpdateEnabledTypes( 52 const syncable::ModelTypeSet& types) OVERRIDE; 53 virtual void SendNotification() OVERRIDE; 54 55 // notifier::LoginDelegate implementation. 56 virtual void OnConnect(base::WeakPtr<talk_base::Task> base_task) OVERRIDE; 57 virtual void OnDisconnect() OVERRIDE; 58 59 // ChromeInvalidationClient::Listener implementation. 60 virtual void OnInvalidate( 61 const syncable::ModelTypePayloadMap& type_payloads) OVERRIDE; 62 virtual void OnSessionStatusChanged(bool has_session) OVERRIDE; 63 64 // StateWriter implementation. 65 virtual void WriteState(const std::string& state) OVERRIDE; 66 67 private: 68 base::NonThreadSafe non_thread_safe_; 69 70 // We start off in the STOPPED state. When we get our initial 71 // credentials, we connect and move to the CONNECTING state. When 72 // we're connected we start the invalidation client and move to the 73 // STARTED state. We never go back to a previous state. 74 enum State { 75 STOPPED, 76 CONNECTING, 77 STARTED 78 }; 79 State state_; 80 81 // Used to build parameters for |login_|. 82 const notifier::NotifierOptions notifier_options_; 83 84 // Passed to |invalidation_client_|. 85 const std::string client_info_; 86 87 // Our observers (which must live on the same thread). 88 ObserverList<SyncNotifierObserver> observers_; 89 90 // The state to pass to |chrome_invalidation_client_|. 91 std::string invalidation_state_; 92 93 // The XMPP connection manager. 94 scoped_ptr<notifier::Login> login_; 95 96 // The invalidation client. 97 ChromeInvalidationClient invalidation_client_; 98 99 DISALLOW_COPY_AND_ASSIGN(InvalidationNotifier); 100 }; 101 102 } // namespace sync_notifier 103 104 #endif // CHROME_BROWSER_SYNC_NOTIFIER_INVALIDATION_NOTIFIER_H_ 105
