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 "base/callback_forward.h" 6 #include "base/memory/ref_counted.h" 7 #include "base/threading/non_thread_safe.h" 8 #include "components/invalidation/invalidation_service.h" 9 #include "components/invalidation/p2p_invalidator.h" 10 #include "components/keyed_service/core/keyed_service.h" 11 12 #ifndef COMPONENTS_INVALIDATION_P2P_INVALIDATION_SERVICE_H_ 13 #define COMPONENTS_INVALIDATION_P2P_INVALIDATION_SERVICE_H_ 14 15 namespace net { 16 class URLRequestContextGetter; 17 } 18 19 namespace syncer { 20 class P2PInvalidator; 21 } 22 23 namespace invalidation { 24 25 class InvalidationLogger; 26 27 // This service is a wrapper around P2PInvalidator. Unlike other 28 // InvalidationServices, it can both send and receive invalidations. It is used 29 // only in tests, where we're unable to connect to a real invalidations server. 30 class P2PInvalidationService : public base::NonThreadSafe, 31 public InvalidationService { 32 public: 33 P2PInvalidationService( 34 scoped_ptr<IdentityProvider> identity_provider, 35 const scoped_refptr<net::URLRequestContextGetter>& request_context, 36 syncer::P2PNotificationTarget notification_target); 37 virtual ~P2PInvalidationService(); 38 39 // InvalidationService implementation. 40 // It is an error to have registered handlers when the service is destroyed. 41 virtual void RegisterInvalidationHandler( 42 syncer::InvalidationHandler* handler) OVERRIDE; 43 virtual void UpdateRegisteredInvalidationIds( 44 syncer::InvalidationHandler* handler, 45 const syncer::ObjectIdSet& ids) OVERRIDE; 46 virtual void UnregisterInvalidationHandler( 47 syncer::InvalidationHandler* handler) OVERRIDE; 48 virtual syncer::InvalidatorState GetInvalidatorState() const OVERRIDE; 49 virtual std::string GetInvalidatorClientId() const OVERRIDE; 50 virtual InvalidationLogger* GetInvalidationLogger() OVERRIDE; 51 virtual void RequestDetailedStatus( 52 base::Callback<void(const base::DictionaryValue&)> caller) const OVERRIDE; 53 virtual IdentityProvider* GetIdentityProvider() OVERRIDE; 54 55 void UpdateCredentials(const std::string& username, 56 const std::string& password); 57 58 void SendInvalidation(const syncer::ObjectIdSet& ids); 59 60 private: 61 scoped_ptr<IdentityProvider> identity_provider_; 62 scoped_ptr<syncer::P2PInvalidator> invalidator_; 63 std::string invalidator_id_; 64 65 DISALLOW_COPY_AND_ASSIGN(P2PInvalidationService); 66 }; 67 68 } // namespace invalidation 69 70 #endif // COMPONENTS_INVALIDATION_P2P_INVALIDATION_SERVICE_H_ 71