| Index: webrtc/libjingle/xmpp/xmppengine_unittest.cc
|
| diff --git a/webrtc/libjingle/xmpp/xmppengine_unittest.cc b/webrtc/libjingle/xmpp/xmppengine_unittest.cc
|
| deleted file mode 100644
|
| index d5afead660e14690a3dc0354d77c34a500a92b3f..0000000000000000000000000000000000000000
|
| --- a/webrtc/libjingle/xmpp/xmppengine_unittest.cc
|
| +++ /dev/null
|
| @@ -1,327 +0,0 @@
|
| -/*
|
| - * Copyright 2004 The WebRTC Project Authors. All rights reserved.
|
| - *
|
| - * Use of this source code is governed by a BSD-style license
|
| - * that can be found in the LICENSE file in the root of the source
|
| - * tree. An additional intellectual property rights grant can be found
|
| - * in the file PATENTS. All contributing project authors may
|
| - * be found in the AUTHORS file in the root of the source tree.
|
| - */
|
| -
|
| -#include <iostream>
|
| -#include <memory>
|
| -#include <sstream>
|
| -#include <string>
|
| -
|
| -#include "webrtc/libjingle/xmllite/xmlelement.h"
|
| -#include "webrtc/libjingle/xmpp/constants.h"
|
| -#include "webrtc/libjingle/xmpp/plainsaslhandler.h"
|
| -#include "webrtc/libjingle/xmpp/saslplainmechanism.h"
|
| -#include "webrtc/libjingle/xmpp/util_unittest.h"
|
| -#include "webrtc/libjingle/xmpp/xmppengine.h"
|
| -#include "webrtc/base/common.h"
|
| -#include "webrtc/base/gunit.h"
|
| -
|
| -using buzz::Jid;
|
| -using buzz::QName;
|
| -using buzz::XmlElement;
|
| -using buzz::XmppEngine;
|
| -using buzz::XmppIqCookie;
|
| -using buzz::XmppIqHandler;
|
| -using buzz::XmppTestHandler;
|
| -using buzz::QN_ID;
|
| -using buzz::QN_IQ;
|
| -using buzz::QN_TYPE;
|
| -using buzz::QN_ROSTER_QUERY;
|
| -using buzz::XMPP_RETURN_OK;
|
| -using buzz::XMPP_RETURN_BADARGUMENT;
|
| -
|
| -// XmppEngineTestIqHandler
|
| -// This class grabs the response to an IQ stanza and stores it in a string.
|
| -class XmppEngineTestIqHandler : public XmppIqHandler {
|
| - public:
|
| - virtual void IqResponse(XmppIqCookie, const XmlElement * stanza) {
|
| - ss_ << stanza->Str();
|
| - }
|
| -
|
| - std::string IqResponseActivity() {
|
| - std::string result = ss_.str();
|
| - ss_.str("");
|
| - return result;
|
| - }
|
| -
|
| - private:
|
| - std::stringstream ss_;
|
| -};
|
| -
|
| -class XmppEngineTest : public testing::Test {
|
| - public:
|
| - XmppEngine* engine() { return engine_.get(); }
|
| - XmppTestHandler* handler() { return handler_.get(); }
|
| - virtual void SetUp() {
|
| - engine_.reset(XmppEngine::Create());
|
| - handler_.reset(new XmppTestHandler(engine_.get()));
|
| -
|
| - Jid jid("david@my-server");
|
| - rtc::InsecureCryptStringImpl pass;
|
| - pass.password() = "david";
|
| - engine_->SetSessionHandler(handler_.get());
|
| - engine_->SetOutputHandler(handler_.get());
|
| - engine_->AddStanzaHandler(handler_.get());
|
| - engine_->SetUser(jid);
|
| - engine_->SetSaslHandler(
|
| - new buzz::PlainSaslHandler(jid, rtc::CryptString(pass), true));
|
| - }
|
| - virtual void TearDown() {
|
| - handler_.reset();
|
| - engine_.reset();
|
| - }
|
| - void RunLogin();
|
| -
|
| - private:
|
| - std::unique_ptr<XmppEngine> engine_;
|
| - std::unique_ptr<XmppTestHandler> handler_;
|
| -};
|
| -
|
| -void XmppEngineTest::RunLogin() {
|
| - // Connect
|
| - EXPECT_EQ(XmppEngine::STATE_START, engine()->GetState());
|
| - engine()->Connect();
|
| - EXPECT_EQ(XmppEngine::STATE_OPENING, engine()->GetState());
|
| -
|
| - EXPECT_EQ("[OPENING]", handler_->SessionActivity());
|
| -
|
| - EXPECT_EQ("<stream:stream to=\"my-server\" xml:lang=\"*\" version=\"1.0\" "
|
| - "xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">\r\n", handler_->OutputActivity());
|
| -
|
| - std::string input =
|
| - "<stream:stream id=\"a5f2d8c9\" version=\"1.0\" "
|
| - "xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| -
|
| - input =
|
| - "<stream:features>"
|
| - "<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'>"
|
| - "<required/>"
|
| - "</starttls>"
|
| - "<mechanisms xmlns='urn:ietf:params:xml:ns:xmpp-sasl'>"
|
| - "<mechanism>DIGEST-MD5</mechanism>"
|
| - "<mechanism>PLAIN</mechanism>"
|
| - "</mechanisms>"
|
| - "</stream:features>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("<starttls xmlns=\"urn:ietf:params:xml:ns:xmpp-tls\"/>",
|
| - handler_->OutputActivity());
|
| -
|
| - EXPECT_EQ("", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| -
|
| - input = "<proceed xmlns='urn:ietf:params:xml:ns:xmpp-tls'/>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("[START-TLS my-server]"
|
| - "<stream:stream to=\"my-server\" xml:lang=\"*\" "
|
| - "version=\"1.0\" xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">\r\n", handler_->OutputActivity());
|
| -
|
| - EXPECT_EQ("", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| -
|
| - input = "<stream:stream id=\"01234567\" version=\"1.0\" "
|
| - "xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| -
|
| - input =
|
| - "<stream:features>"
|
| - "<mechanisms xmlns='urn:ietf:params:xml:ns:xmpp-sasl'>"
|
| - "<mechanism>DIGEST-MD5</mechanism>"
|
| - "<mechanism>PLAIN</mechanism>"
|
| - "</mechanisms>"
|
| - "</stream:features>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("<auth xmlns=\"urn:ietf:params:xml:ns:xmpp-sasl\" "
|
| - "mechanism=\"PLAIN\" "
|
| - "auth:allow-non-google-login=\"true\" "
|
| - "auth:client-uses-full-bind-result=\"true\" "
|
| - "xmlns:auth=\"http://www.google.com/talk/protocol/auth\""
|
| - ">AGRhdmlkAGRhdmlk</auth>",
|
| - handler_->OutputActivity());
|
| -
|
| - EXPECT_EQ("", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| -
|
| - input = "<success xmlns='urn:ietf:params:xml:ns:xmpp-sasl'/>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("<stream:stream to=\"my-server\" xml:lang=\"*\" version=\"1.0\" "
|
| - "xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">\r\n", handler_->OutputActivity());
|
| -
|
| - EXPECT_EQ("", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| -
|
| - input = "<stream:stream id=\"01234567\" version=\"1.0\" "
|
| - "xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| -
|
| - input = "<stream:features>"
|
| - "<bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'/>"
|
| - "<session xmlns='urn:ietf:params:xml:ns:xmpp-session'/>"
|
| - "</stream:features>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("<iq type=\"set\" id=\"0\">"
|
| - "<bind xmlns=\"urn:ietf:params:xml:ns:xmpp-bind\"/></iq>",
|
| - handler_->OutputActivity());
|
| -
|
| - EXPECT_EQ("", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| -
|
| - input = "<iq type='result' id='0'>"
|
| - "<bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'><jid>"
|
| - "david@my-server/test</jid></bind></iq>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| -
|
| - EXPECT_EQ("<iq type=\"set\" id=\"1\">"
|
| - "<session xmlns=\"urn:ietf:params:xml:ns:xmpp-session\"/></iq>",
|
| - handler_->OutputActivity());
|
| -
|
| - EXPECT_EQ("", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| -
|
| - input = "<iq type='result' id='1'/>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| -
|
| - EXPECT_EQ("[OPEN]", handler_->SessionActivity());
|
| - EXPECT_EQ("", handler_->StanzaActivity());
|
| - EXPECT_EQ(Jid("david@my-server/test"), engine()->FullJid());
|
| -}
|
| -
|
| -// TestSuccessfulLogin()
|
| -// This function simply tests to see if a login works. This includes
|
| -// encryption and authentication
|
| -TEST_F(XmppEngineTest, TestSuccessfulLoginAndDisconnect) {
|
| - RunLogin();
|
| - engine()->Disconnect();
|
| - EXPECT_EQ("</stream:stream>[CLOSED]", handler()->OutputActivity());
|
| - EXPECT_EQ("[CLOSED]", handler()->SessionActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| -}
|
| -
|
| -TEST_F(XmppEngineTest, TestSuccessfulLoginAndConnectionClosed) {
|
| - RunLogin();
|
| - engine()->ConnectionClosed(0);
|
| - EXPECT_EQ("[CLOSED]", handler()->OutputActivity());
|
| - EXPECT_EQ("[CLOSED][ERROR-CONNECTION-CLOSED]", handler()->SessionActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| -}
|
| -
|
| -
|
| -// TestNotXmpp()
|
| -// This tests the error case when connecting to a non XMPP service
|
| -TEST_F(XmppEngineTest, TestNotXmpp) {
|
| - // Connect
|
| - engine()->Connect();
|
| - EXPECT_EQ("<stream:stream to=\"my-server\" xml:lang=\"*\" version=\"1.0\" "
|
| - "xmlns:stream=\"http://etherx.jabber.org/streams\" "
|
| - "xmlns=\"jabber:client\">\r\n", handler()->OutputActivity());
|
| -
|
| - // Send garbage response (courtesy of apache)
|
| - std::string input = "<!DOCTYPE HTML PUBLIC \"-//IETF//DTD HTML 2.0//EN\">";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| -
|
| - EXPECT_EQ("[CLOSED]", handler()->OutputActivity());
|
| - EXPECT_EQ("[OPENING][CLOSED][ERROR-XML]", handler()->SessionActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| -}
|
| -
|
| -// TestPassthrough()
|
| -// This tests that arbitrary stanzas can be passed to the server through
|
| -// the engine.
|
| -TEST_F(XmppEngineTest, TestPassthrough) {
|
| - // Queue up an app stanza
|
| - XmlElement application_stanza(QName("test", "app-stanza"));
|
| - application_stanza.AddText("this-is-a-test");
|
| - engine()->SendStanza(&application_stanza);
|
| -
|
| - // Do the whole login handshake
|
| - RunLogin();
|
| -
|
| - EXPECT_EQ("<test:app-stanza xmlns:test=\"test\">this-is-a-test"
|
| - "</test:app-stanza>", handler()->OutputActivity());
|
| -
|
| - // do another stanza
|
| - XmlElement roster_get(QN_IQ);
|
| - roster_get.AddAttr(QN_TYPE, "get");
|
| - roster_get.AddAttr(QN_ID, engine()->NextId());
|
| - roster_get.AddElement(new XmlElement(QN_ROSTER_QUERY, true));
|
| - engine()->SendStanza(&roster_get);
|
| - EXPECT_EQ("<iq type=\"get\" id=\"2\"><query xmlns=\"jabber:iq:roster\"/>"
|
| - "</iq>", handler()->OutputActivity());
|
| -
|
| - // now say the server ends the stream
|
| - engine()->HandleInput("</stream:stream>", 16);
|
| - EXPECT_EQ("[CLOSED][ERROR-DOCUMENT-CLOSED]", handler()->SessionActivity());
|
| - EXPECT_EQ("[CLOSED]", handler()->OutputActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| -}
|
| -
|
| -// TestIqCallback()
|
| -// This tests the routing of Iq stanzas and responses.
|
| -TEST_F(XmppEngineTest, TestIqCallback) {
|
| - XmppEngineTestIqHandler iq_response;
|
| - XmppIqCookie cookie;
|
| -
|
| - // Do the whole login handshake
|
| - RunLogin();
|
| -
|
| - // Build an iq request
|
| - XmlElement roster_get(QN_IQ);
|
| - roster_get.AddAttr(QN_TYPE, "get");
|
| - roster_get.AddAttr(QN_ID, engine()->NextId());
|
| - roster_get.AddElement(new XmlElement(QN_ROSTER_QUERY, true));
|
| - engine()->SendIq(&roster_get, &iq_response, &cookie);
|
| - EXPECT_EQ("<iq type=\"get\" id=\"2\"><query xmlns=\"jabber:iq:roster\"/>"
|
| - "</iq>", handler()->OutputActivity());
|
| - EXPECT_EQ("", handler()->SessionActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| - EXPECT_EQ("", iq_response.IqResponseActivity());
|
| -
|
| - // now say the server responds to the iq
|
| - std::string input = "<iq type='result' id='2'>"
|
| - "<query xmlns='jabber:iq:roster'><item>foo</item>"
|
| - "</query></iq>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("", handler()->OutputActivity());
|
| - EXPECT_EQ("", handler()->SessionActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| - EXPECT_EQ("<cli:iq type=\"result\" id=\"2\" xmlns:cli=\"jabber:client\">"
|
| - "<query xmlns=\"jabber:iq:roster\"><item>foo</item></query>"
|
| - "</cli:iq>", iq_response.IqResponseActivity());
|
| -
|
| - EXPECT_EQ(XMPP_RETURN_BADARGUMENT, engine()->RemoveIqHandler(cookie, NULL));
|
| -
|
| - // Do it again with another id to test cancel
|
| - roster_get.SetAttr(QN_ID, engine()->NextId());
|
| - engine()->SendIq(&roster_get, &iq_response, &cookie);
|
| - EXPECT_EQ("<iq type=\"get\" id=\"3\"><query xmlns=\"jabber:iq:roster\"/>"
|
| - "</iq>", handler()->OutputActivity());
|
| - EXPECT_EQ("", handler()->SessionActivity());
|
| - EXPECT_EQ("", handler()->StanzaActivity());
|
| - EXPECT_EQ("", iq_response.IqResponseActivity());
|
| -
|
| - // cancel the handler this time
|
| - EXPECT_EQ(XMPP_RETURN_OK, engine()->RemoveIqHandler(cookie, NULL));
|
| -
|
| - // now say the server responds to the iq: the iq handler should not get it.
|
| - input = "<iq type='result' id='3'><query xmlns='jabber:iq:roster'><item>bar"
|
| - "</item></query></iq>";
|
| - engine()->HandleInput(input.c_str(), input.length());
|
| - EXPECT_EQ("<cli:iq type=\"result\" id=\"3\" xmlns:cli=\"jabber:client\">"
|
| - "<query xmlns=\"jabber:iq:roster\"><item>bar</item></query>"
|
| - "</cli:iq>", handler()->StanzaActivity());
|
| - EXPECT_EQ("", iq_response.IqResponseActivity());
|
| - EXPECT_EQ("", handler()->OutputActivity());
|
| - EXPECT_EQ("", handler()->SessionActivity());
|
| -}
|
|
|