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
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
|
// Copyright (c) 2012 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 <string>
#include "jingle/notifier/communicator/single_login_attempt.h"
#include "base/basictypes.h"
#include "base/logging.h"
#include "base/strings/string_number_conversions.h"
#include "base/strings/string_split.h"
#include "jingle/notifier/base/const_communicator.h"
#include "jingle/notifier/base/gaia_token_pre_xmpp_auth.h"
#include "jingle/notifier/listener/xml_element_util.h"
#include "net/base/host_port_pair.h"
#include "third_party/webrtc/libjingle/xmllite/xmlelement.h"
#include "webrtc/libjingle/xmpp/constants.h"
#include "webrtc/libjingle/xmpp/xmppclientsettings.h"
namespace notifier {
SingleLoginAttempt::Delegate::~Delegate() {}
SingleLoginAttempt::SingleLoginAttempt(const LoginSettings& login_settings,
Delegate* delegate)
: login_settings_(login_settings),
delegate_(delegate),
settings_list_(
MakeConnectionSettingsList(login_settings_.GetServers(),
login_settings_.try_ssltcp_first())),
current_settings_(settings_list_.begin()) {
if (settings_list_.empty()) {
NOTREACHED();
return;
}
TryConnect(*current_settings_);
}
SingleLoginAttempt::~SingleLoginAttempt() {}
// In the code below, we assume that calling a delegate method may end
// up in ourselves being deleted, so we always call it last.
//
// TODO(akalin): Add unit tests to enforce the behavior above.
void SingleLoginAttempt::OnConnect(
base::WeakPtr<buzz::XmppTaskParentInterface> base_task) {
DVLOG(1) << "Connected to " << current_settings_->ToString();
delegate_->OnConnect(base_task);
}
namespace {
// This function is more permissive than
// net::HostPortPair::FromString(). If the port is missing or
// unparseable, it assumes the default XMPP port. The hostname may be
// empty.
net::HostPortPair ParseRedirectText(const std::string& redirect_text) {
std::vector<std::string> parts = base::SplitString(
redirect_text, ":", base::TRIM_WHITESPACE, base::SPLIT_WANT_ALL);
net::HostPortPair redirect_server;
redirect_server.set_port(kDefaultXmppPort);
if (parts.empty()) {
return redirect_server;
}
redirect_server.set_host(parts[0]);
if (parts.size() <= 1) {
return redirect_server;
}
// Try to parse the port, falling back to kDefaultXmppPort.
int port = kDefaultXmppPort;
if (!base::StringToInt(parts[1], &port)) {
port = kDefaultXmppPort;
}
if (port <= 0 || port > kuint16max) {
port = kDefaultXmppPort;
}
redirect_server.set_port(port);
return redirect_server;
}
} // namespace
void SingleLoginAttempt::OnError(buzz::XmppEngine::Error error, int subcode,
const buzz::XmlElement* stream_error) {
DVLOG(1) << "Error: " << error << ", subcode: " << subcode
<< (stream_error
? (", stream error: " + XmlElementToString(*stream_error))
: std::string());
DCHECK_EQ(error == buzz::XmppEngine::ERROR_STREAM, stream_error != NULL);
// Check for redirection. We expect something like:
//
// <stream:error><see-other-host xmlns="urn:ietf:params:xml:ns:xmpp-streams"/><str:text xmlns:str="urn:ietf:params:xml:ns:xmpp-streams">talk.google.com</str:text></stream:error> [2]
//
// There are some differences from the spec [1]:
//
// - we expect a separate text element with the redirection info
// (which is the format Google Talk's servers use), whereas the
// spec puts the redirection info directly in the see-other-host
// element;
// - we check for redirection only during login, whereas the
// server can send down a redirection at any time according to
// the spec. (TODO(akalin): Figure out whether we need to handle
// redirection at any other point.)
//
// [1]: http://xmpp.org/internet-drafts/draft-saintandre-rfc3920bis-08.html#streams-error-conditions-see-other-host
// [2]: http://forums.miranda-im.org/showthread.php?24376-GoogleTalk-drops
if (stream_error) {
const buzz::XmlElement* other =
stream_error->FirstNamed(buzz::QN_XSTREAM_SEE_OTHER_HOST);
if (other) {
const buzz::XmlElement* text =
stream_error->FirstNamed(buzz::QN_XSTREAM_TEXT);
if (text) {
// Yep, its a "stream:error" with "see-other-host" text,
// let's parse out the server:port, and then reconnect
// with that.
const net::HostPortPair& redirect_server =
ParseRedirectText(text->BodyText());
// ParseRedirectText shouldn't return a zero port.
DCHECK_NE(redirect_server.port(), 0u);
// If we don't have a host, ignore the redirection and treat
// it like a regular error.
if (!redirect_server.host().empty()) {
delegate_->OnRedirect(
ServerInformation(
redirect_server,
current_settings_->ssltcp_support));
// May be deleted at this point.
return;
}
}
}
}
if (error == buzz::XmppEngine::ERROR_UNAUTHORIZED) {
DVLOG(1) << "Credentials rejected";
delegate_->OnCredentialsRejected();
return;
}
if (current_settings_ == settings_list_.end()) {
NOTREACHED();
return;
}
++current_settings_;
if (current_settings_ == settings_list_.end()) {
DVLOG(1) << "Could not connect to any XMPP server";
delegate_->OnSettingsExhausted();
return;
}
TryConnect(*current_settings_);
}
void SingleLoginAttempt::TryConnect(
const ConnectionSettings& connection_settings) {
DVLOG(1) << "Trying to connect to " << connection_settings.ToString();
// Copy the user settings and fill in the connection parameters from
// |connection_settings|.
buzz::XmppClientSettings client_settings = login_settings_.user_settings();
connection_settings.FillXmppClientSettings(&client_settings);
buzz::Jid jid(client_settings.user(), client_settings.host(),
buzz::STR_EMPTY);
buzz::PreXmppAuth* pre_xmpp_auth =
new GaiaTokenPreXmppAuth(
jid.Str(), client_settings.auth_token(),
client_settings.token_service(),
login_settings_.auth_mechanism());
xmpp_connection_.reset(
new XmppConnection(client_settings,
login_settings_.request_context_getter(),
this,
pre_xmpp_auth));
}
} // namespace notifier
|
