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
|
// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "components/invalidation/impl/fcm_sync_network_channel.h"
#include "base/logging.h"
#include "base/observer_list.h"
namespace invalidation {
FCMSyncNetworkChannel::FCMSyncNetworkChannel() : received_messages_count_(0) {}
FCMSyncNetworkChannel::~FCMSyncNetworkChannel() = default;
void FCMSyncNetworkChannel::SetMessageReceiver(
MessageCallback incoming_receiver) {
incoming_receiver_ = std::move(incoming_receiver);
}
void FCMSyncNetworkChannel::SetTokenReceiver(TokenCallback token_receiver) {
token_receiver_ = token_receiver;
if (!token_.empty())
token_receiver_.Run(token_);
}
void FCMSyncNetworkChannel::AddObserver(Observer* observer) {
observers_.AddObserver(observer);
}
void FCMSyncNetworkChannel::RemoveObserver(Observer* observer) {
observers_.RemoveObserver(observer);
}
void FCMSyncNetworkChannel::NotifyChannelStateChange(FcmChannelState state) {
for (auto& observer : observers_)
observer.OnFCMChannelStateChanged(state);
}
bool FCMSyncNetworkChannel::DeliverIncomingMessage(
const std::string& payload,
const std::string& private_topic,
const std::string& public_topic,
int64_t version) {
if (!incoming_receiver_) {
DLOG(ERROR) << "No receiver for incoming notification";
return false;
}
received_messages_count_++;
incoming_receiver_.Run(payload, private_topic, public_topic, version);
return true;
}
bool FCMSyncNetworkChannel::DeliverToken(const std::string& token) {
token_ = token;
if (!token_receiver_) {
DLOG(ERROR) << "No receiver for token";
return false;
}
token_receiver_.Run(token_);
return true;
}
} // namespace invalidation
|
