xmpp_signal_strategy.cc revision 116680a4aac90f2aa7413d9095a592090648e557
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/base/thread.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "third_party/libjingle/source/talk/xmpp/prexmppauth.h" 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "third_party/libjingle/source/talk/xmpp/saslcookiemechanism.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) 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Read buffer size used by ChromeAsyncSocket for read and write buffers. Most 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// of XMPP messages are smaller than 4kB. 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const size_t kReadBufferSize = 4096; 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const size_t kWriteBufferSize = 4096; 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace remoting { 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 373551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)XmppSignalStrategy::XmppServerConfig::XmppServerConfig() {} 383551c9c881056c480085172ff9840cab31610854Torne (Richard Coles)XmppSignalStrategy::XmppServerConfig::~XmppServerConfig() {} 393551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)XmppSignalStrategy::XmppSignalStrategy( 4168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) net::ClientSocketFactory* socket_factory, 4268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) scoped_refptr<net::URLRequestContextGetter> request_context_getter, 432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const XmppSignalStrategy::XmppServerConfig& xmpp_server_config) 4468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) : socket_factory_(socket_factory), 4568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) request_context_getter_(request_context_getter), 462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) resource_name_(kDefaultResourceName), 472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_client_(NULL), 482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_(xmpp_server_config), 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) state_(DISCONNECTED), 502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) error_(OK) { 512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#if defined(NDEBUG) 522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) CHECK(xmpp_server_config_.use_tls); 532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#endif 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)XmppSignalStrategy::~XmppSignalStrategy() { 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Destroying task runner will destroy XmppClient, but XmppClient may be on 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the stack and it doesn't handle this case properly, so we need to delay 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // destruction. 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::ThreadTaskRunnerHandle::Get()->DeleteSoon( 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, task_runner_.release()); 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::Connect() { 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Disconnect first if we are currently connected. 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppClientSettings settings; 733551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) buzz::Jid login_jid(xmpp_server_config_.username); 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_user(login_jid.node()); 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_host(login_jid.domain()); 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_resource(resource_name_); 773551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) settings.set_token_service(xmpp_server_config_.auth_service); 783551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) settings.set_auth_token(buzz::AUTH_MECHANISM_GOOGLE_TOKEN, 793551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.auth_token); 802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) settings.set_server(talk_base::SocketAddress( 812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_.host, xmpp_server_config_.port)); 822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) settings.set_use_tls( 832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_.use_tls ? buzz::TLS_ENABLED : buzz::TLS_DISABLED); 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 8568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) scoped_ptr<jingle_glue::XmppClientSocketFactory> xmpp_socket_factory( 8668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) new jingle_glue::XmppClientSocketFactory( 8768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) socket_factory_, net::SSLConfig(), request_context_getter_, false)); 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::AsyncSocket* socket = new jingle_glue::ChromeAsyncSocket( 8968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) xmpp_socket_factory.release(), kReadBufferSize, kWriteBufferSize); 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) task_runner_.reset(new jingle_glue::TaskPump()); 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_ = new buzz::XmppClient(task_runner_.get()); 93c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) xmpp_client_->Connect( 94c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) settings, std::string(), socket, CreatePreXmppAuth(settings)); 95c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) xmpp_client_->SignalStateChange 96c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) .connect(this, &XmppSignalStrategy::OnConnectionStateChanged); 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->engine()->AddStanzaHandler(this, buzz::XmppEngine::HL_TYPE); 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->Start(); 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(CONNECTING); 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::Disconnect() { 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (xmpp_client_) { 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->engine()->RemoveStanzaHandler(this); 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->Disconnect(); 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |xmpp_client_| should be set to NULL in OnConnectionStateChanged() 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // in response to Disconnect() call above. 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(xmpp_client_ == NULL); 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SignalStrategy::State XmppSignalStrategy::GetState() const { 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return state_; 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SignalStrategy::Error XmppSignalStrategy::GetError() const { 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error_; 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)std::string XmppSignalStrategy::GetLocalJid() const { 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return xmpp_client_->jid().Str(); 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::AddListener(Listener* listener) { 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) listeners_.AddObserver(listener); 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::RemoveListener(Listener* listener) { 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) listeners_.RemoveObserver(listener); 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool XmppSignalStrategy::SendStanza(scoped_ptr<buzz::XmlElement> stanza) { 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!xmpp_client_) { 145f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) VLOG(0) << "Dropping signalling message because XMPP " 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) "connection has been terminated."; 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppReturnStatus status = xmpp_client_->SendStanza(stanza.release()); 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return status == buzz::XMPP_RETURN_OK || status == buzz::XMPP_RETURN_PENDING; 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)std::string XmppSignalStrategy::GetNextId() { 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!xmpp_client_) { 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the connection has been terminated then it doesn't matter 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // what Id we return. 159c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return std::string(); 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return xmpp_client_->NextId(); 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool XmppSignalStrategy::HandleStanza(const buzz::XmlElement* stanza) { 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ObserverListBase<Listener>::Iterator it(listeners_); 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Listener* listener; 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while ((listener = it.GetNext()) != NULL) { 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (listener->OnSignalStrategyIncomingStanza(stanza)) 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetAuthInfo(const std::string& username, 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& auth_token, 1773551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) const std::string& auth_service) { 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1793551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.username = username; 1803551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.auth_token = auth_token; 1813551c9c881056c480085172ff9840cab31610854Torne (Richard Coles) xmpp_server_config_.auth_service = auth_service; 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetResourceName(const std::string &resource_name) { 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resource_name_ = resource_name; 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::OnConnectionStateChanged( 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppEngine::State state) { 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (state == buzz::XmppEngine::STATE_OPEN) { 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_alive_timer_.Start( 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, base::TimeDelta::FromSeconds(kKeepAliveIntervalSeconds), 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, &XmppSignalStrategy::SendKeepAlive); 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(CONNECTED); 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (state == buzz::XmppEngine::STATE_CLOSED) { 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Make sure we dump errors to the log. 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int subcode; 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppEngine::Error error = xmpp_client_->GetError(&subcode); 202f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) VLOG(0) << "XMPP connection was closed: error=" << error 203f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) << ", subcode=" << subcode; 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_alive_timer_.Stop(); 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Client is destroyed by the TaskRunner after the client is 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // closed. Reset the pointer so we don't try to use it later. 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_ = NULL; 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (error) { 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_UNAUTHORIZED: 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_AUTH: 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_MISSING_USERNAME: 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) error_ = AUTHENTICATION_FAILED; 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) error_ = NETWORK_ERROR; 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(DISCONNECTED); 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetState(State new_state) { 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (state_ != new_state) { 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) state_ = new_state; 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FOR_EACH_OBSERVER(Listener, listeners_, 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) OnSignalStrategyStateChange(new_state)); 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SendKeepAlive() { 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->SendRaw(" "); 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)buzz::PreXmppAuth* XmppSignalStrategy::CreatePreXmppAuth( 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const buzz::XmppClientSettings& settings) { 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::Jid jid(settings.user(), settings.host(), buzz::STR_EMPTY); 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) std::string mechanism = notifier::kDefaultGaiaAuthMechanism; 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (settings.token_service() == "oauth2") { 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mechanism = "X-OAUTH2"; 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new notifier::GaiaTokenPreXmppAuth( 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jid.Str(), settings.auth_token(), settings.token_service(), mechanism); 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace remoting 252