15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 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) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "remoting/jingle_glue/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" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (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" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (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) 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)XmppSignalStrategy::XmppSignalStrategy( 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<net::URLRequestContextGetter> request_context_getter, 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& username, 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& auth_token, 412a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const std::string& auth_token_service, 422a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const XmppSignalStrategy::XmppServerConfig& xmpp_server_config) 432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) : request_context_getter_(request_context_getter), 442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) username_(username), 452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) auth_token_(auth_token), 462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) auth_token_service_(auth_token_service), 472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) resource_name_(kDefaultResourceName), 482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_client_(NULL), 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) xmpp_server_config_(xmpp_server_config), 502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) state_(DISCONNECTED), 512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) error_(OK) { 522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#if defined(NDEBUG) 532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) CHECK(xmpp_server_config_.use_tls); 542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#endif 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)XmppSignalStrategy::~XmppSignalStrategy() { 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Destroying task runner will destroy XmppClient, but XmppClient may be on 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the stack and it doesn't handle this case properly, so we need to delay 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // destruction. 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::ThreadTaskRunnerHandle::Get()->DeleteSoon( 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, task_runner_.release()); 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::Connect() { 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Disconnect first if we are currently connected. 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Disconnect(); 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppClientSettings settings; 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::Jid login_jid(username_); 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_user(login_jid.node()); 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_host(login_jid.domain()); 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_resource(resource_name_); 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_token_service(auth_token_service_); 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) settings.set_auth_token(buzz::AUTH_MECHANISM_GOOGLE_TOKEN, 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) 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_ptr<jingle_glue::XmppClientSocketFactory> socket_factory( 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) new jingle_glue::XmppClientSocketFactory( 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::ClientSocketFactory::GetDefaultFactory(), 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) net::SSLConfig(), request_context_getter_, false)); 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::AsyncSocket* socket = new jingle_glue::ChromeAsyncSocket( 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) socket_factory.release(), kReadBufferSize, kWriteBufferSize); 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) task_runner_.reset(new jingle_glue::TaskPump()); 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_ = new buzz::XmppClient(task_runner_.get()); 94c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) xmpp_client_->Connect( 95c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) settings, std::string(), socket, CreatePreXmppAuth(settings)); 96c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) xmpp_client_->SignalStateChange 97c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) .connect(this, &XmppSignalStrategy::OnConnectionStateChanged); 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->engine()->AddStanzaHandler(this, buzz::XmppEngine::HL_TYPE); 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->Start(); 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(CONNECTING); 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::Disconnect() { 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (xmpp_client_) { 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->engine()->RemoveStanzaHandler(this); 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->Disconnect(); 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |xmpp_client_| should be set to NULL in OnConnectionStateChanged() 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // in response to Disconnect() call above. 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(xmpp_client_ == NULL); 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SignalStrategy::State XmppSignalStrategy::GetState() const { 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return state_; 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SignalStrategy::Error XmppSignalStrategy::GetError() const { 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return error_; 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)std::string XmppSignalStrategy::GetLocalJid() const { 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return xmpp_client_->jid().Str(); 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::AddListener(Listener* listener) { 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) listeners_.AddObserver(listener); 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::RemoveListener(Listener* listener) { 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) listeners_.RemoveObserver(listener); 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool XmppSignalStrategy::SendStanza(scoped_ptr<buzz::XmlElement> stanza) { 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!xmpp_client_) { 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) LOG(INFO) << "Dropping signalling message because XMPP " 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) "connection has been terminated."; 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppReturnStatus status = xmpp_client_->SendStanza(stanza.release()); 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return status == buzz::XMPP_RETURN_OK || status == buzz::XMPP_RETURN_PENDING; 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)std::string XmppSignalStrategy::GetNextId() { 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!xmpp_client_) { 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the connection has been terminated then it doesn't matter 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // what Id we return. 160c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return std::string(); 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return xmpp_client_->NextId(); 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool XmppSignalStrategy::HandleStanza(const buzz::XmlElement* stanza) { 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ObserverListBase<Listener>::Iterator it(listeners_); 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Listener* listener; 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) while ((listener = it.GetNext()) != NULL) { 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (listener->OnSignalStrategyIncomingStanza(stanza)) 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetAuthInfo(const std::string& username, 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& auth_token, 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& auth_token_service) { 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) username_ = username; 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) auth_token_ = auth_token; 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) auth_token_service_ = auth_token_service; 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetResourceName(const std::string &resource_name) { 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) resource_name_ = resource_name; 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::OnConnectionStateChanged( 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppEngine::State state) { 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(CalledOnValidThread()); 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (state == buzz::XmppEngine::STATE_OPEN) { 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_alive_timer_.Start( 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FROM_HERE, base::TimeDelta::FromSeconds(kKeepAliveIntervalSeconds), 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) this, &XmppSignalStrategy::SendKeepAlive); 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(CONNECTED); 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else if (state == buzz::XmppEngine::STATE_CLOSED) { 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Make sure we dump errors to the log. 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int subcode; 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::XmppEngine::Error error = xmpp_client_->GetError(&subcode); 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) LOG(INFO) << "XMPP connection was closed: error=" << error 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) << ", subcode=" << subcode; 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_alive_timer_.Stop(); 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Client is destroyed by the TaskRunner after the client is 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // closed. Reset the pointer so we don't try to use it later. 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_ = NULL; 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) switch (error) { 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_UNAUTHORIZED: 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_AUTH: 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) case buzz::XmppEngine::ERROR_MISSING_USERNAME: 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) error_ = AUTHENTICATION_FAILED; 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) default: 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) error_ = NETWORK_ERROR; 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SetState(DISCONNECTED); 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SetState(State new_state) { 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (state_ != new_state) { 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) state_ = new_state; 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) FOR_EACH_OBSERVER(Listener, listeners_, 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) OnSignalStrategyStateChange(new_state)); 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void XmppSignalStrategy::SendKeepAlive() { 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) xmpp_client_->SendRaw(" "); 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)buzz::PreXmppAuth* XmppSignalStrategy::CreatePreXmppAuth( 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const buzz::XmppClientSettings& settings) { 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) buzz::Jid jid(settings.user(), settings.host(), buzz::STR_EMPTY); 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) std::string mechanism = notifier::kDefaultGaiaAuthMechanism; 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (settings.token_service() == "oauth2") { 2455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mechanism = "X-OAUTH2"; 2465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return new notifier::GaiaTokenPreXmppAuth( 2495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) jid.Str(), settings.auth_token(), settings.token_service(), mechanism); 2505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace remoting 253