jamosdev
/
rhubarb-lip-sync
mirror of https://github.com/DanielSWolf/rhubarb-lip-sync.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
rhubarb-lip-sync/rhubarb/lib/webrtc-8d2248ff/webrtc/libjingle/xmpp/hangoutpubsubclient_unittes...

755 lines
28 KiB
C++
Raw Permalink Normal View History

Added WebRTC library
2016-06-21 20:13:05 +00:00
/*
* Copyright 2011 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 <memory>
#include <string>
#include "webrtc/libjingle/xmllite/qname.h"
#include "webrtc/libjingle/xmllite/xmlelement.h"
#include "webrtc/libjingle/xmpp/constants.h"
#include "webrtc/libjingle/xmpp/fakexmppclient.h"
#include "webrtc/libjingle/xmpp/hangoutpubsubclient.h"
#include "webrtc/libjingle/xmpp/jid.h"
#include "webrtc/base/faketaskrunner.h"
#include "webrtc/base/gunit.h"
#include "webrtc/base/sigslot.h"
class TestHangoutPubSubListener : public sigslot::has_slots<> {
public:
TestHangoutPubSubListener() :
request_error_count(0),
publish_audio_mute_error_count(0),
publish_video_mute_error_count(0),
publish_video_pause_error_count(0),
publish_presenter_error_count(0),
publish_recording_error_count(0),
remote_mute_error_count(0) {
}
void OnPresenterStateChange(
const std::string& nick, bool was_presenting, bool is_presenting) {
last_presenter_nick = nick;
last_was_presenting = was_presenting;
last_is_presenting = is_presenting;
}
void OnAudioMuteStateChange(
const std::string& nick, bool was_muted, bool is_muted) {
last_audio_muted_nick = nick;
last_was_audio_muted = was_muted;
last_is_audio_muted = is_muted;
}
void OnVideoMuteStateChange(
const std::string& nick, bool was_muted, bool is_muted) {
last_video_muted_nick = nick;
last_was_video_muted = was_muted;
last_is_video_muted = is_muted;
}
void OnVideoPauseStateChange(
const std::string& nick, bool was_paused, bool is_paused) {
last_video_paused_nick = nick;
last_was_video_paused = was_paused;
last_is_video_paused = is_paused;
}
void OnRecordingStateChange(
const std::string& nick, bool was_recording, bool is_recording) {
last_recording_nick = nick;
last_was_recording = was_recording;
last_is_recording = is_recording;
}
void OnRemoteMute(
const std::string& mutee_nick,
const std::string& muter_nick,
bool should_mute_locally) {
last_mutee_nick = mutee_nick;
last_muter_nick = muter_nick;
last_should_mute = should_mute_locally;
}
void OnMediaBlock(
const std::string& blockee_nick,
const std::string& blocker_nick) {
last_blockee_nick = blockee_nick;
last_blocker_nick = blocker_nick;
}
void OnRequestError(const std::string& node, const buzz::XmlElement* stanza) {
++request_error_count;
request_error_node = node;
}
void OnPublishAudioMuteError(const std::string& task_id,
const buzz::XmlElement* stanza) {
++publish_audio_mute_error_count;
error_task_id = task_id;
}
void OnPublishVideoMuteError(const std::string& task_id,
const buzz::XmlElement* stanza) {
++publish_video_mute_error_count;
error_task_id = task_id;
}
void OnPublishVideoPauseError(const std::string& task_id,
const buzz::XmlElement* stanza) {
++publish_video_pause_error_count;
error_task_id = task_id;
}
void OnPublishPresenterError(const std::string& task_id,
const buzz::XmlElement* stanza) {
++publish_presenter_error_count;
error_task_id = task_id;
}
void OnPublishRecordingError(const std::string& task_id,
const buzz::XmlElement* stanza) {
++publish_recording_error_count;
error_task_id = task_id;
}
void OnRemoteMuteResult(const std::string& task_id,
const std::string& mutee_nick) {
result_task_id = task_id;
remote_mute_mutee_nick = mutee_nick;
}
void OnRemoteMuteError(const std::string& task_id,
const std::string& mutee_nick,
const buzz::XmlElement* stanza) {
++remote_mute_error_count;
error_task_id = task_id;
remote_mute_mutee_nick = mutee_nick;
}
void OnMediaBlockResult(const std::string& task_id,
const std::string& blockee_nick) {
result_task_id = task_id;
media_blockee_nick = blockee_nick;
}
void OnMediaBlockError(const std::string& task_id,
const std::string& blockee_nick,
const buzz::XmlElement* stanza) {
++media_block_error_count;
error_task_id = task_id;
media_blockee_nick = blockee_nick;
}
std::string last_presenter_nick;
bool last_is_presenting;
bool last_was_presenting;
std::string last_audio_muted_nick;
bool last_is_audio_muted;
bool last_was_audio_muted;
std::string last_video_muted_nick;
bool last_is_video_muted;
bool last_was_video_muted;
std::string last_video_paused_nick;
bool last_is_video_paused;
bool last_was_video_paused;
std::string last_recording_nick;
bool last_is_recording;
bool last_was_recording;
std::string last_mutee_nick;
std::string last_muter_nick;
bool last_should_mute;
std::string last_blockee_nick;
std::string last_blocker_nick;
int request_error_count;
std::string request_error_node;
int publish_audio_mute_error_count;
int publish_video_mute_error_count;
int publish_video_pause_error_count;
int publish_presenter_error_count;
int publish_recording_error_count;
int remote_mute_error_count;
std::string result_task_id;
std::string error_task_id;
std::string remote_mute_mutee_nick;
int media_block_error_count;
std::string media_blockee_nick;
};
class HangoutPubSubClientTest : public testing::Test {
public:
HangoutPubSubClientTest() :
pubsubjid("room@domain.com"),
nick("me") {
runner.reset(new rtc::FakeTaskRunner());
xmpp_client = new buzz::FakeXmppClient(runner.get());
client.reset(new buzz::HangoutPubSubClient(xmpp_client, pubsubjid, nick));
listener.reset(new TestHangoutPubSubListener());
client->SignalPresenterStateChange.connect(
listener.get(), &TestHangoutPubSubListener::OnPresenterStateChange);
client->SignalAudioMuteStateChange.connect(
listener.get(), &TestHangoutPubSubListener::OnAudioMuteStateChange);
client->SignalVideoMuteStateChange.connect(
listener.get(), &TestHangoutPubSubListener::OnVideoMuteStateChange);
client->SignalVideoPauseStateChange.connect(
listener.get(), &TestHangoutPubSubListener::OnVideoPauseStateChange);
client->SignalRecordingStateChange.connect(
listener.get(), &TestHangoutPubSubListener::OnRecordingStateChange);
client->SignalRemoteMute.connect(
listener.get(), &TestHangoutPubSubListener::OnRemoteMute);
client->SignalMediaBlock.connect(
listener.get(), &TestHangoutPubSubListener::OnMediaBlock);
client->SignalRequestError.connect(
listener.get(), &TestHangoutPubSubListener::OnRequestError);
client->SignalPublishAudioMuteError.connect(
listener.get(), &TestHangoutPubSubListener::OnPublishAudioMuteError);
client->SignalPublishVideoMuteError.connect(
listener.get(), &TestHangoutPubSubListener::OnPublishVideoMuteError);
client->SignalPublishVideoPauseError.connect(
listener.get(), &TestHangoutPubSubListener::OnPublishVideoPauseError);
client->SignalPublishPresenterError.connect(
listener.get(), &TestHangoutPubSubListener::OnPublishPresenterError);
client->SignalPublishRecordingError.connect(
listener.get(), &TestHangoutPubSubListener::OnPublishRecordingError);
client->SignalRemoteMuteResult.connect(
listener.get(), &TestHangoutPubSubListener::OnRemoteMuteResult);
client->SignalRemoteMuteError.connect(
listener.get(), &TestHangoutPubSubListener::OnRemoteMuteError);
client->SignalMediaBlockResult.connect(
listener.get(), &TestHangoutPubSubListener::OnMediaBlockResult);
client->SignalMediaBlockError.connect(
listener.get(), &TestHangoutPubSubListener::OnMediaBlockError);
}
std::unique_ptr<rtc::FakeTaskRunner> runner;
// xmpp_client deleted by deleting runner.
buzz::FakeXmppClient* xmpp_client;
std::unique_ptr<buzz::HangoutPubSubClient> client;
std::unique_ptr<TestHangoutPubSubListener> listener;
buzz::Jid pubsubjid;
std::string nick;
};
TEST_F(HangoutPubSubClientTest, TestRequest) {
ASSERT_EQ(0U, xmpp_client->sent_stanzas().size());
client->RequestAll();
std::string expected_presenter_request =
"<cli:iq type=\"get\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pub:pubsub xmlns:pub=\"http://jabber.org/protocol/pubsub\">"
"<pub:items node=\"google:presenter\"/>"
"</pub:pubsub>"
"</cli:iq>";
std::string expected_media_request =
"<cli:iq type=\"get\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pub:pubsub xmlns:pub=\"http://jabber.org/protocol/pubsub\">"
"<pub:items node=\"google:muc#media\"/>"
"</pub:pubsub>"
"</cli:iq>";
ASSERT_EQ(2U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_presenter_request, xmpp_client->sent_stanzas()[0]->Str());
EXPECT_EQ(expected_media_request, xmpp_client->sent_stanzas()[1]->Str());
std::string presenter_response =
"<iq xmlns='jabber:client' id='0' type='result' from='room@domain.com'>"
" <pubsub xmlns='http://jabber.org/protocol/pubsub'>"
" <items node='google:presenter'>"
" <item id='12344'>"
" <presenter xmlns='google:presenter' nick='presenting-nick2'/>"
" <pre:presentation-item xmlns:pre='google:presenter'"
" pre:presentation-type='s'/>"
" </item>"
" <item id='12345'>"
" <presenter xmlns='google:presenter' nick='presenting-nick'/>"
" <pre:presentation-item xmlns:pre='google:presenter'"
" pre:presentation-type='o'/>"
" </item>"
// Some clients are "bad" in that they'll jam multiple states in
// all at once. We have to deal with it.
" <item id='12346'>"
" <presenter xmlns='google:presenter' nick='presenting-nick'/>"
" <pre:presentation-item xmlns:pre='google:presenter'"
" pre:presentation-type='s'/>"
" </item>"
" </items>"
" </pubsub>"
"</iq>";
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(presenter_response));
EXPECT_EQ("presenting-nick", listener->last_presenter_nick);
EXPECT_FALSE(listener->last_was_presenting);
EXPECT_TRUE(listener->last_is_presenting);
std::string media_response =
"<iq xmlns='jabber:client' id='0' type='result' from='room@domain.com'>"
" <pubsub xmlns='http://jabber.org/protocol/pubsub'>"
" <items node='google:muc#media'>"
" <item id='audio-mute:muted-nick'>"
" <audio-mute nick='muted-nick' xmlns='google:muc#media'/>"
" </item>"
" <item id='video-mute:video-muted-nick'>"
" <video-mute nick='video-muted-nick' xmlns='google:muc#media'/>"
" </item>"
" <item id='video-pause:video-paused-nick'>"
" <video-pause nick='video-paused-nick' xmlns='google:muc#media'/>"
" </item>"
" <item id='recording:recording-nick'>"
" <recording nick='recording-nick' xmlns='google:muc#media'/>"
" </item>"
" </items>"
" </pubsub>"
"</iq>";
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(media_response));
EXPECT_EQ("muted-nick", listener->last_audio_muted_nick);
EXPECT_FALSE(listener->last_was_audio_muted);
EXPECT_TRUE(listener->last_is_audio_muted);
EXPECT_EQ("video-muted-nick", listener->last_video_muted_nick);
EXPECT_FALSE(listener->last_was_video_muted);
EXPECT_TRUE(listener->last_is_video_muted);
EXPECT_EQ("video-paused-nick", listener->last_video_paused_nick);
EXPECT_FALSE(listener->last_was_video_paused);
EXPECT_TRUE(listener->last_is_video_paused);
EXPECT_EQ("recording-nick", listener->last_recording_nick);
EXPECT_FALSE(listener->last_was_recording);
EXPECT_TRUE(listener->last_is_recording);
std::string incoming_presenter_resets_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:presenter'>"
" <item id='12348'>"
" <presenter xmlns='google:presenter' nick='presenting-nick'/>"
" <pre:presentation-item xmlns:pre='google:presenter'"
" pre:presentation-type='o'/>"
" </item>"
" </items>"
" </event>"
"</message>";
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_presenter_resets_message));
EXPECT_EQ("presenting-nick", listener->last_presenter_nick);
//EXPECT_TRUE(listener->last_was_presenting);
EXPECT_FALSE(listener->last_is_presenting);
std::string incoming_presenter_retracts_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:presenter'>"
" <retract id='12344'/>"
" </items>"
" </event>"
"</message>";
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_presenter_retracts_message));
EXPECT_EQ("presenting-nick2", listener->last_presenter_nick);
EXPECT_TRUE(listener->last_was_presenting);
EXPECT_FALSE(listener->last_is_presenting);
std::string incoming_media_retracts_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:muc#media'>"
" <item id='audio-mute:muted-nick'>"
" </item>"
" <retract id='video-mute:video-muted-nick'/>"
" <retract id='video-pause:video-paused-nick'/>"
" <retract id='recording:recording-nick'/>"
" </items>"
" </event>"
"</message>";
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_media_retracts_message));
EXPECT_EQ("muted-nick", listener->last_audio_muted_nick);
EXPECT_TRUE(listener->last_was_audio_muted);
EXPECT_FALSE(listener->last_is_audio_muted);
EXPECT_EQ("video-paused-nick", listener->last_video_paused_nick);
EXPECT_TRUE(listener->last_was_video_paused);
EXPECT_FALSE(listener->last_is_video_paused);
EXPECT_EQ("recording-nick", listener->last_recording_nick);
EXPECT_TRUE(listener->last_was_recording);
EXPECT_FALSE(listener->last_is_recording);
std::string incoming_presenter_changes_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:presenter'>"
" <item id='presenting-nick2'>"
" <presenter xmlns='google:presenter' nick='presenting-nick2'/>"
" <pre:presentation-item xmlns:pre='google:presenter'"
" pre:presentation-type='s'/>"
" </item>"
" </items>"
" </event>"
"</message>";
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_presenter_changes_message));
EXPECT_EQ("presenting-nick2", listener->last_presenter_nick);
EXPECT_FALSE(listener->last_was_presenting);
EXPECT_TRUE(listener->last_is_presenting);
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_presenter_changes_message));
EXPECT_EQ("presenting-nick2", listener->last_presenter_nick);
EXPECT_TRUE(listener->last_was_presenting);
EXPECT_TRUE(listener->last_is_presenting);
std::string incoming_media_changes_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:muc#media'>"
" <item id='audio-mute:muted-nick2'>"
" <audio-mute nick='muted-nick2' xmlns='google:muc#media'/>"
" </item>"
" <item id='video-pause:video-paused-nick2'>"
" <video-pause nick='video-paused-nick2' xmlns='google:muc#media'/>"
" </item>"
" <item id='recording:recording-nick2'>"
" <recording nick='recording-nick2' xmlns='google:muc#media'/>"
" </item>"
" </items>"
" </event>"
"</message>";
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_media_changes_message));
EXPECT_EQ("muted-nick2", listener->last_audio_muted_nick);
EXPECT_FALSE(listener->last_was_audio_muted);
EXPECT_TRUE(listener->last_is_audio_muted);
EXPECT_EQ("video-paused-nick2", listener->last_video_paused_nick);
EXPECT_FALSE(listener->last_was_video_paused);
EXPECT_TRUE(listener->last_is_video_paused);
EXPECT_EQ("recording-nick2", listener->last_recording_nick);
EXPECT_FALSE(listener->last_was_recording);
EXPECT_TRUE(listener->last_is_recording);
std::string incoming_remote_mute_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:muc#media'>"
" <item id='audio-mute:mutee' publisher='room@domain.com/muter'>"
" <audio-mute nick='mutee' xmlns='google:muc#media'/>"
" </item>"
" </items>"
" </event>"
"</message>";
listener->last_is_audio_muted = false;
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_remote_mute_message));
EXPECT_EQ("mutee", listener->last_mutee_nick);
EXPECT_EQ("muter", listener->last_muter_nick);
EXPECT_FALSE(listener->last_should_mute);
EXPECT_EQ("mutee", listener->last_audio_muted_nick);
EXPECT_TRUE(listener->last_is_audio_muted);
std::string incoming_remote_mute_me_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:muc#media'>"
" <item id='audio-mute:me' publisher='room@domain.com/muter'>"
" <audio-mute nick='me' xmlns='google:muc#media'/>"
" </item>"
" </items>"
" </event>"
"</message>";
listener->last_is_audio_muted = false;
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_remote_mute_me_message));
EXPECT_EQ("me", listener->last_mutee_nick);
EXPECT_EQ("muter", listener->last_muter_nick);
EXPECT_TRUE(listener->last_should_mute);
EXPECT_EQ("me", listener->last_audio_muted_nick);
EXPECT_TRUE(listener->last_is_audio_muted);
std::string incoming_media_block_message =
"<message xmlns='jabber:client' from='room@domain.com'>"
" <event xmlns='http://jabber.org/protocol/pubsub#event'>"
" <items node='google:muc#media'>"
" <item id='block:blocker:blockee'"
" publisher='room@domain.com/blocker'>"
" <block nick='blockee' xmlns='google:muc#media'/>"
" </item>"
" </items>"
" </event>"
"</message>";
xmpp_client->HandleStanza(
buzz::XmlElement::ForStr(incoming_media_block_message));
EXPECT_EQ("blockee", listener->last_blockee_nick);
EXPECT_EQ("blocker", listener->last_blocker_nick);
}
TEST_F(HangoutPubSubClientTest, TestRequestError) {
client->RequestAll();
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'>"
" <error type='auth'>"
" <forbidden xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>"
" </error>"
"</iq>";
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->request_error_count);
EXPECT_EQ("google:presenter", listener->request_error_node);
}
TEST_F(HangoutPubSubClientTest, TestPublish) {
client->PublishPresenterState(true);
std::string expected_presenter_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:presenter\">"
"<item id=\"me\">"
"<presenter xmlns=\"google:presenter\""
" nick=\"me\"/>"
"<pre:presentation-item"
" pre:presentation-type=\"s\" xmlns:pre=\"google:presenter\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(1U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_presenter_iq,
xmpp_client->sent_stanzas()[0]->Str());
client->PublishAudioMuteState(true);
std::string expected_audio_mute_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:muc#media\">"
"<item id=\"audio-mute:me\">"
"<audio-mute xmlns=\"google:muc#media\" nick=\"me\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(2U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_audio_mute_iq, xmpp_client->sent_stanzas()[1]->Str());
client->PublishVideoPauseState(true);
std::string expected_video_pause_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:muc#media\">"
"<item id=\"video-pause:me\">"
"<video-pause xmlns=\"google:muc#media\" nick=\"me\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(3U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_video_pause_iq, xmpp_client->sent_stanzas()[2]->Str());
client->PublishRecordingState(true);
std::string expected_recording_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:muc#media\">"
"<item id=\"recording:me\">"
"<recording xmlns=\"google:muc#media\" nick=\"me\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(4U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_recording_iq, xmpp_client->sent_stanzas()[3]->Str());
client->RemoteMute("mutee");
std::string expected_remote_mute_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:muc#media\">"
"<item id=\"audio-mute:mutee\">"
"<audio-mute xmlns=\"google:muc#media\" nick=\"mutee\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(5U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_remote_mute_iq, xmpp_client->sent_stanzas()[4]->Str());
client->PublishPresenterState(false);
std::string expected_presenter_retract_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:presenter\">"
"<item id=\"me\">"
"<presenter xmlns=\"google:presenter\""
" nick=\"me\"/>"
"<pre:presentation-item"
" pre:presentation-type=\"o\" xmlns:pre=\"google:presenter\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(6U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_presenter_retract_iq,
xmpp_client->sent_stanzas()[5]->Str());
client->PublishAudioMuteState(false);
std::string expected_audio_mute_retract_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<retract node=\"google:muc#media\" notify=\"true\">"
"<item id=\"audio-mute:me\"/>"
"</retract>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(7U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_audio_mute_retract_iq,
xmpp_client->sent_stanzas()[6]->Str());
client->PublishVideoPauseState(false);
std::string expected_video_pause_retract_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<retract node=\"google:muc#media\" notify=\"true\">"
"<item id=\"video-pause:me\"/>"
"</retract>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(8U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_video_pause_retract_iq,
xmpp_client->sent_stanzas()[7]->Str());
client->BlockMedia("blockee");
std::string expected_media_block_iq =
"<cli:iq type=\"set\" to=\"room@domain.com\" id=\"0\" "
"xmlns:cli=\"jabber:client\">"
"<pubsub xmlns=\"http://jabber.org/protocol/pubsub\">"
"<publish node=\"google:muc#media\">"
"<item id=\"block:me:blockee\">"
"<block xmlns=\"google:muc#media\" nick=\"blockee\"/>"
"</item>"
"</publish>"
"</pubsub>"
"</cli:iq>";
ASSERT_EQ(9U, xmpp_client->sent_stanzas().size());
EXPECT_EQ(expected_media_block_iq, xmpp_client->sent_stanzas()[8]->Str());
}
TEST_F(HangoutPubSubClientTest, TestPublishPresenterError) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'/>";
client->PublishPresenterState(true);
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->publish_presenter_error_count);
EXPECT_EQ("0", listener->error_task_id);
}
TEST_F(HangoutPubSubClientTest, TestPublishAudioMuteError) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'/>";
client->PublishAudioMuteState(true);
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->publish_audio_mute_error_count);
EXPECT_EQ("0", listener->error_task_id);
}
TEST_F(HangoutPubSubClientTest, TestPublishVideoPauseError) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'/>";
client->PublishVideoPauseState(true);
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->publish_video_pause_error_count);
EXPECT_EQ("0", listener->error_task_id);
}
TEST_F(HangoutPubSubClientTest, TestPublishRecordingError) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'/>";
client->PublishRecordingState(true);
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->publish_recording_error_count);
EXPECT_EQ("0", listener->error_task_id);
}
TEST_F(HangoutPubSubClientTest, TestPublishRemoteMuteResult) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='result' from='room@domain.com'/>";
client->RemoteMute("joe");
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ("joe", listener->remote_mute_mutee_nick);
EXPECT_EQ("0", listener->result_task_id);
}
TEST_F(HangoutPubSubClientTest, TestRemoteMuteError) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'/>";
client->RemoteMute("joe");
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->remote_mute_error_count);
EXPECT_EQ("joe", listener->remote_mute_mutee_nick);
EXPECT_EQ("0", listener->error_task_id);
}
TEST_F(HangoutPubSubClientTest, TestPublishMediaBlockResult) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='result' from='room@domain.com'/>";
client->BlockMedia("joe");
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ("joe", listener->media_blockee_nick);
EXPECT_EQ("0", listener->result_task_id);
}
TEST_F(HangoutPubSubClientTest, TestMediaBlockError) {
std::string result_iq =
"<iq xmlns='jabber:client' id='0' type='error' from='room@domain.com'/>";
client->BlockMedia("joe");
xmpp_client->HandleStanza(buzz::XmlElement::ForStr(result_iq));
EXPECT_EQ(1, listener->remote_mute_error_count);
EXPECT_EQ("joe", listener->media_blockee_nick);
EXPECT_EQ("0", listener->error_task_id);
}