1116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch// Copyright 2014 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 5116680a4aac90f2aa7413d9095a592090648e557Ben Murdoch#include "remoting/signaling/xmpp_signal_strategy.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/location.h" 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/single_thread_task_runner.h" 115e3f23d412006dc4db4e659864679f29341e113fTorne (Richard Coles)#include "base/strings/string_util.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/thread_task_runner_handle.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "jingle/glue/chrome_async_socket.h" 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "jingle/glue/task_pump.h" 1568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "jingle/glue/xmpp_client_socket_factory.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "jingle/notifier/base/gaia_constants.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "jingle/notifier/base/gaia_token_pre_xmpp_auth.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/socket/client_socket_factory.h" 1968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "net/url_request/url_request_context_getter.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "third_party/libjingle/source/talk/xmpp/prexmppauth.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "third_party/libjingle/source/talk/xmpp/saslcookiemechanism.h" 225f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles)#include "third_party/webrtc/base/thread.h" 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const char kDefaultResourceName[] = "chromoting"; 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use 58 seconds keep-alive interval, in case routers terminate 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// connections that are idle for more than a minute. 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const int kKeepAliveIntervalSeconds = 50; 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 301320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// Read buffer size used by ChromeAsyncSocket for read and write buffers. 311320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// 321320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// TODO(sergeyu): Currently jingle::ChromeAsyncSocket fails Write() when the 331320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// write buffer is full and talk::XmppClient just ignores the error. As result 341320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// chunks of data sent to the server are dropped (and they may not be full XMPP 351320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// stanzas). The problem needs to be fixed either in XmppClient on 361320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// ChromeAsyncSocket (e.g. ChromeAsyncSocket could close the connection when 371320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// buffer is full). 381320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucciconst size_t kReadBufferSize = 64 * 1024; 391320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucciconst size_t kWriteBufferSize = 64 * 1024; 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace remoting { 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 433551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)XmppSignalStrategy::XmppServerConfig::XmppServerConfig() {} 443551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)XmppSignalStrategy::XmppServerConfig::~XmppServerConfig() {} 453551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)XmppSignalStrategy::XmppSignalStrategy( 4768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) net::ClientSocketFactory* socket_factory, 4868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) scoped_refptr<net::URLRequestContextGetter> request_context_getter, 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const XmppSignalStrategy::XmppServerConfig& xmpp_server_config) 5068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) : socket_factory_(socket_factory), 5168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) request_context_getter_(request_context_getter), 522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) resource_name_(kDefaultResourceName), 532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_client_(NULL), 542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_(xmpp_server_config), 552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) state_(DISCONNECTED), 562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) error_(OK) { 572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#if defined(NDEBUG) 582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) CHECK(xmpp_server_config_.use_tls); 592a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#endif 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)XmppSignalStrategy::~XmppSignalStrategy() { 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Destroying task runner will destroy XmppClient, but XmppClient may be on 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the stack and it doesn't handle this case properly, so we need to delay 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // destruction. 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::ThreadTaskRunnerHandle::Get()->DeleteSoon( 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, task_runner_.release()); 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::Connect() { 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Disconnect first if we are currently connected. 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppClientSettings settings; 793551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) buzz::Jid login_jid(xmpp_server_config_.username); 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_user(login_jid.node()); 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_host(login_jid.domain()); 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_resource(resource_name_); 833551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) settings.set_token_service(xmpp_server_config_.auth_service); 843551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) settings.set_auth_token(buzz::AUTH_MECHANISM_GOOGLE_TOKEN, 853551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.auth_token); 865f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) settings.set_server(rtc::SocketAddress( 872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_.host, xmpp_server_config_.port)); 882a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) settings.set_use_tls( 892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_.use_tls ? buzz::TLS_ENABLED : buzz::TLS_DISABLED); 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 9168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) scoped_ptr<jingle_glue::XmppClientSocketFactory> xmpp_socket_factory( 9268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) new jingle_glue::XmppClientSocketFactory( 9368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) socket_factory_, net::SSLConfig(), request_context_getter_, false)); 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::AsyncSocket* socket = new jingle_glue::ChromeAsyncSocket( 9568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) xmpp_socket_factory.release(), kReadBufferSize, kWriteBufferSize); 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) task_runner_.reset(new jingle_glue::TaskPump()); 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_ = new buzz::XmppClient(task_runner_.get()); 99c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) xmpp_client_->Connect( 100c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) settings, std::string(), socket, CreatePreXmppAuth(settings)); 101c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) xmpp_client_->SignalStateChange 102c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) .connect(this, &XmppSignalStrategy::OnConnectionStateChanged); 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->engine()->AddStanzaHandler(this, buzz::XmppEngine::HL_TYPE); 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->Start(); 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(CONNECTING); 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::Disconnect() { 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (xmpp_client_) { 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->engine()->RemoveStanzaHandler(this); 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->Disconnect(); 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |xmpp_client_| should be set to NULL in OnConnectionStateChanged() 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // in response to Disconnect() call above. 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(xmpp_client_ == NULL); 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SignalStrategy::State XmppSignalStrategy::GetState() const { 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return state_; 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SignalStrategy::Error XmppSignalStrategy::GetError() const { 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error_; 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)std::string XmppSignalStrategy::GetLocalJid() const { 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return xmpp_client_->jid().Str(); 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::AddListener(Listener* listener) { 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) listeners_.AddObserver(listener); 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::RemoveListener(Listener* listener) { 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) listeners_.RemoveObserver(listener); 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool XmppSignalStrategy::SendStanza(scoped_ptr<buzz::XmlElement> stanza) { 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!xmpp_client_) { 151f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) VLOG(0) << "Dropping signalling message because XMPP " 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) "connection has been terminated."; 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppReturnStatus status = xmpp_client_->SendStanza(stanza.release()); 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return status == buzz::XMPP_RETURN_OK || status == buzz::XMPP_RETURN_PENDING; 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)std::string XmppSignalStrategy::GetNextId() { 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!xmpp_client_) { 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the connection has been terminated then it doesn't matter 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // what Id we return. 165c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return std::string(); 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return xmpp_client_->NextId(); 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool XmppSignalStrategy::HandleStanza(const buzz::XmlElement* stanza) { 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ObserverListBase<Listener>::Iterator it(listeners_); 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Listener* listener; 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while ((listener = it.GetNext()) != NULL) { 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (listener->OnSignalStrategyIncomingStanza(stanza)) 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetAuthInfo(const std::string& username, 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& auth_token, 1833551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) const std::string& auth_service) { 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1853551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.username = username; 1863551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.auth_token = auth_token; 1873551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.auth_service = auth_service; 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetResourceName(const std::string &resource_name) { 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resource_name_ = resource_name; 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::OnConnectionStateChanged( 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppEngine::State state) { 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (state == buzz::XmppEngine::STATE_OPEN) { 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_alive_timer_.Start( 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, base::TimeDelta::FromSeconds(kKeepAliveIntervalSeconds), 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, &XmppSignalStrategy::SendKeepAlive); 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(CONNECTED); 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (state == buzz::XmppEngine::STATE_CLOSED) { 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Make sure we dump errors to the log. 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int subcode; 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppEngine::Error error = xmpp_client_->GetError(&subcode); 208f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) VLOG(0) << "XMPP connection was closed: error=" << error 209f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) << ", subcode=" << subcode; 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_alive_timer_.Stop(); 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Client is destroyed by the TaskRunner after the client is 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // closed. Reset the pointer so we don't try to use it later. 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_ = NULL; 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (error) { 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_UNAUTHORIZED: 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_AUTH: 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_MISSING_USERNAME: 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) error_ = AUTHENTICATION_FAILED; 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) error_ = NETWORK_ERROR; 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(DISCONNECTED); 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetState(State new_state) { 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (state_ != new_state) { 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) state_ = new_state; 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FOR_EACH_OBSERVER(Listener, listeners_, 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) OnSignalStrategyStateChange(new_state)); 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SendKeepAlive() { 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->SendRaw(" "); 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)buzz::PreXmppAuth* XmppSignalStrategy::CreatePreXmppAuth( 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const buzz::XmppClientSettings& settings) { 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::Jid jid(settings.user(), settings.host(), buzz::STR_EMPTY); 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) std::string mechanism = notifier::kDefaultGaiaAuthMechanism; 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (settings.token_service() == "oauth2") { 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mechanism = "X-OAUTH2"; 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new notifier::GaiaTokenPreXmppAuth( 2545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jid.Str(), settings.auth_token(), settings.token_service(), mechanism); 2555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace remoting 258