blob: 4c5efa3eb5f82582f155cb08a20de4445c365075 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef COMPONENTS_INVALIDATION_GCM_INVALIDATION_BRIDGE_H_
#define COMPONENTS_INVALIDATION_GCM_INVALIDATION_BRIDGE_H_
#include "base/callback.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/non_thread_safe.h"
#include "components/gcm_driver/gcm_app_handler.h"
#include "components/gcm_driver/gcm_client.h"
#include "components/invalidation/gcm_network_channel_delegate.h"
#include "google_apis/gaia/oauth2_token_service.h"
class IdentityProvider;
namespace base {
class SingleThreadTaskRunner;
} // namespace base
namespace gcm {
class GCMDriver;
} // namespace gcm
namespace invalidation {
// GCMInvalidationBridge and GCMInvalidationBridge::Core implement functions
// needed for GCMNetworkChannel. GCMInvalidationBridge lives on UI thread while
// Core lives on IO thread. Core implements GCMNetworkChannelDelegate and posts
// all function calls to GCMInvalidationBridge which does actual work to perform
// them.
class GCMInvalidationBridge : public gcm::GCMAppHandler,
public OAuth2TokenService::Consumer,
public base::NonThreadSafe {
public:
class Core;
GCMInvalidationBridge(gcm::GCMDriver* gcm_driver,
IdentityProvider* identity_provider);
virtual ~GCMInvalidationBridge();
// OAuth2TokenService::Consumer implementation.
virtual void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
const std::string& access_token,
const base::Time& expiration_time) OVERRIDE;
virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
const GoogleServiceAuthError& error) OVERRIDE;
// gcm::GCMEventRouter implementation.
virtual void ShutdownHandler() OVERRIDE;
virtual void OnMessage(const std::string& app_id,
const gcm::GCMClient::IncomingMessage& message)
OVERRIDE;
virtual void OnMessagesDeleted(const std::string& app_id) OVERRIDE;
virtual void OnSendError(
const std::string& app_id,
const gcm::GCMClient::SendErrorDetails& send_error_details) OVERRIDE;
scoped_ptr<syncer::GCMNetworkChannelDelegate> CreateDelegate();
void CoreInitializationDone(
base::WeakPtr<Core> core,
scoped_refptr<base::SingleThreadTaskRunner> core_thread_task_runner);
// Functions reflecting GCMNetworkChannelDelegate interface. These are called
// on UI thread to perform actual work.
void RequestToken(
syncer::GCMNetworkChannelDelegate::RequestTokenCallback callback);
void InvalidateToken(const std::string& token);
void Register(syncer::GCMNetworkChannelDelegate::RegisterCallback callback);
void SubscribeForIncomingMessages();
void RegisterFinished(
syncer::GCMNetworkChannelDelegate::RegisterCallback callback,
const std::string& registration_id,
gcm::GCMClient::Result result);
private:
gcm::GCMDriver* const gcm_driver_;
IdentityProvider* const identity_provider_;
base::WeakPtr<Core> core_;
scoped_refptr<base::SingleThreadTaskRunner> core_thread_task_runner_;
// Fields related to RequestToken function.
scoped_ptr<OAuth2TokenService::Request> access_token_request_;
syncer::GCMNetworkChannelDelegate::RequestTokenCallback
request_token_callback_;
bool subscribed_for_incoming_messages_;
base::WeakPtrFactory<GCMInvalidationBridge> weak_factory_;
DISALLOW_COPY_AND_ASSIGN(GCMInvalidationBridge);
};
} // namespace invalidation
#endif // COMPONENTS_INVALIDATION_GCM_INVALIDATION_BRIDGE_H_
|
