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
103
104
105
106
107
108
109
110
111
112
|
#include "talk/examples/login/jingleinfotask.h"
#include "talk/base/socketaddress.h"
#include "talk/xmpp/constants.h"
#include "talk/xmpp/xmppclient.h"
namespace buzz {
class JingleInfoTask::JingleInfoGetTask : public XmppTask {
public:
JingleInfoGetTask(Task * parent) : XmppTask(parent, XmppEngine::HL_SINGLE),
done_(false) {}
virtual int ProcessStart() {
scoped_ptr<XmlElement> get(MakeIq(STR_GET, JID_EMPTY, task_id()));
get->AddElement(new XmlElement(QN_JINGLE_INFO_QUERY, true));
if (SendStanza(get.get()) != XMPP_RETURN_OK) {
return STATE_ERROR;
}
return STATE_RESPONSE;
}
virtual int ProcessResponse() {
if (done_)
return STATE_DONE;
return STATE_BLOCKED;
}
protected:
virtual bool HandleStanza(const XmlElement * stanza) {
if (!MatchResponseIq(stanza, JID_EMPTY, task_id()))
return false;
if (stanza->Attr(QN_TYPE) != STR_RESULT)
return false;
// Queue the stanza with the parent so these don't get handled out of order
JingleInfoTask* parent = static_cast<JingleInfoTask*>(GetParent());
parent->QueueStanza(stanza);
// Wake ourselves so we can go into the done state
done_ = true;
Wake();
return true;
}
bool done_;
};
void JingleInfoTask::RefreshJingleInfoNow() {
JingleInfoGetTask* get_task = new JingleInfoGetTask(this);
get_task->Start();
}
bool
JingleInfoTask::HandleStanza(const XmlElement * stanza) {
if (!MatchRequestIq(stanza, "set", QN_JINGLE_INFO_QUERY))
return false;
// only respect relay push from the server
Jid from(stanza->Attr(QN_FROM));
if (from != JID_EMPTY &&
!from.BareEquals(GetClient()->jid()) &&
from != Jid(GetClient()->jid().domain()))
return false;
QueueStanza(stanza);
return true;
}
int
JingleInfoTask::ProcessStart() {
std::vector<std::string> relay_hosts;
std::vector<talk_base::SocketAddress> stun_hosts;
std::string relay_token;
const XmlElement * stanza = NextStanza();
if (stanza == NULL)
return STATE_BLOCKED;
const XmlElement * query = stanza->FirstNamed(QN_JINGLE_INFO_QUERY);
if (query == NULL)
return STATE_START;
const XmlElement *stun = query->FirstNamed(QN_JINGLE_INFO_STUN);
if (stun) {
for (const XmlElement *server = stun->FirstNamed(QN_JINGLE_INFO_SERVER);
server != NULL; server = server->NextNamed(QN_JINGLE_INFO_SERVER)) {
std::string host = server->Attr(QN_JINGLE_INFO_HOST);
std::string port = server->Attr(QN_JINGLE_INFO_UDP);
if (host != STR_EMPTY && host != STR_EMPTY)
stun_hosts.push_back(talk_base::SocketAddress(host, atoi(port.c_str())));
}
}
const XmlElement *relay = query->FirstNamed(QN_JINGLE_INFO_RELAY);
if (relay) {
relay_token = relay->TextNamed(QN_JINGLE_INFO_TOKEN);
for (const XmlElement *server = relay->FirstNamed(QN_JINGLE_INFO_SERVER);
server != NULL; server = server->NextNamed(QN_JINGLE_INFO_SERVER)) {
std::string host = server->Attr(QN_JINGLE_INFO_HOST);
if (host != STR_EMPTY) {
relay_hosts.push_back(host);
}
}
}
SignalJingleInfo(relay_token, relay_hosts, stun_hosts);
return STATE_START;
}
}
|
