Home | History | Annotate | Download | only in invalidation 
      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