components/invalidation/p2p_invalidation_service.h

   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_