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
|
// Copyright 2015 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.
#include "remoting/signaling/push_notification_subscriber.h"
#include "base/bind.h"
#include "base/callback.h"
#include "remoting/base/logging.h"
#include "remoting/signaling/iq_sender.h"
#include "remoting/signaling/jid_util.h"
#include "third_party/webrtc/libjingle/xmllite/xmlelement.h"
namespace remoting {
namespace {
const char kGooglePushNamespace[] = "google:push";
} // namespace
PushNotificationSubscriber::Subscription::Subscription() {
}
PushNotificationSubscriber::Subscription::~Subscription() {
}
PushNotificationSubscriber::PushNotificationSubscriber(
SignalStrategy* signal_strategy,
const SubscriptionList& subscriptions)
: signal_strategy_(signal_strategy), subscriptions_(subscriptions) {
signal_strategy_->AddListener(this);
}
PushNotificationSubscriber::~PushNotificationSubscriber() {
signal_strategy_->RemoveListener(this);
}
void PushNotificationSubscriber::OnSignalStrategyStateChange(
SignalStrategy::State state) {
if (state == SignalStrategy::CONNECTED) {
for (const Subscription& subscription : subscriptions_) {
Subscribe(subscription);
}
subscriptions_.clear(); // no longer needed
}
}
bool PushNotificationSubscriber::OnSignalStrategyIncomingStanza(
const buzz::XmlElement* stanza) {
// Ignore all XMPP stanzas.
return false;
}
void PushNotificationSubscriber::Subscribe(const Subscription& subscription) {
VLOG(0) << "Subscribing to push notifications on channel: "
<< subscription.channel << ".";
std::string bare_jid;
SplitJidResource(signal_strategy_->GetLocalJid(), &bare_jid, nullptr);
// Build a subscription request.
buzz::XmlElement* subscribe_element =
new buzz::XmlElement(buzz::QName(kGooglePushNamespace, "subscribe"));
buzz::XmlElement* item_element =
new buzz::XmlElement(buzz::QName(kGooglePushNamespace, "item"));
subscribe_element->AddElement(item_element);
item_element->SetAttr(buzz::QName(std::string(), "channel"),
subscription.channel);
item_element->SetAttr(buzz::QName(std::string(), "from"), subscription.from);
// Send the request.
iq_sender_.reset(new IqSender(signal_strategy_));
iq_request_ = iq_sender_->SendIq(
"set", bare_jid, make_scoped_ptr(subscribe_element),
base::Bind(&PushNotificationSubscriber::OnSubscriptionResult,
base::Unretained(this)));
}
void PushNotificationSubscriber::OnSubscriptionResult(
IqRequest* request,
const buzz::XmlElement* response) {
std::string response_type =
response->Attr(buzz::QName(std::string(), "type"));
if (response_type != "result") {
LOG(ERROR) << "Invalid response type for subscription: " << response_type;
}
// The IqSender and IqRequest are no longer needed after receiving a
// reply to the subscription request.
iq_request_.reset();
iq_sender_.reset();
}
} // namespace remoting
|
