libtransport.git Changeset - 17fe52b61f81

Changeset - 17fe52b61f81

Parent rev.

Child rev.

[Not reviewed]

0 4 0

Jan Kaluza - 10 years ago 2016-01-20 07:36:05
jkaluza@redhat.com

Fix #98 - Leave the room internally when disconnecting user from room because of error.

4 files changed with 47 insertions and 13 deletions:

include/transport/User.h

libtransport/Conversation.cpp

libtransport/User.cpp

tests/libtransport/user.cpp

0 comments (0 inline, 0 general)

include/transport/User.h

➞

Show inline comments

@@ @@ -138,6 +138,8 @@ class User { @@
 			m_reconnectLimit = limit;
+		}
 		void leaveRoom(const std::string &room);
 		boost::signal<void ()> onReadyToConnect;
 		boost::signal<void (Swift::Presence::ref presence)> onPresenceChanged;
 		boost::signal<void (Swift::Presence::ref presence)> onRawPresenceReceived;

libtransport/Conversation.cpp

➞

Show inline comments

 		m_conversationManager->getComponent()->getFrontend()->sendMessage(m_subject);
 		m_subject.reset();
+	}
 	// We send error presences only to inform user that he is disconnected
 	// from the room. This code must be extended in case we start sending error
 	// presences in other situations.
 	if (presence->getType() == Swift::Presence::Error) {
 		m_conversationManager->getUser()->leaveRoom(m_legacyName);
+	}
+}
+}

libtransport/User.cpp

➞

Show inline comments

@@ @@ -151,6 +151,23 @@ void User::setCacheMessages(bool cacheMessages) { @@
 	m_cacheMessages = cacheMessages;
+}
 void User::leaveRoom(const std::string &room) {
 	onRoomLeft(room);
 	BOOST_FOREACH(Swift::Presence::ref &p, m_joinedRooms) {
 		if (Buddy::JIDToLegacyName(p->getTo()) == room) {
 			m_joinedRooms.remove(p);
 			break;
+		}
+	}
 	Conversation *conv = m_conversationManager->getConversation(room);
 	if (conv) {
 		m_conversationManager->removeConversation(conv);
 		delete conv;
+	}
+}
 void User::handlePresence(Swift::Presence::ref presence, bool forceJoin) {
 	LOG4CXX_INFO(logger, "PRESENCE " << presence->getFrom().toString() << " " << presence->getTo().toString());
 	if (!m_connected) {
 			if (getUserSetting("stay_connected") != "1") {
 				LOG4CXX_INFO(logger, m_jid.toString() << ": Going to left room " << room);
 				onRawPresenceReceived(presence);
 				onRoomLeft(room);
 				BOOST_FOREACH(Swift::Presence::ref &p, m_joinedRooms) {
 					if (p->getTo() == presence->getTo()) {
 						m_joinedRooms.remove(p);
 						break;
+					}
+				}
 				if (conv) {
 					m_conversationManager->removeConversation(conv);
 					delete conv;
+				}
 				leaveRoom(room);
+			}
 			return;

tests/libtransport/user.cpp

➞

Show inline comments

 	CPPUNIT_TEST(handleDisconnected);
 	CPPUNIT_TEST(handleDisconnectedReconnect);
 	CPPUNIT_TEST(joinRoomHandleDisconnectedRejoin);
 	CPPUNIT_TEST(joinRoomAfterFlagNotAuthorized);
 	CPPUNIT_TEST_SUITE_END();
 	public:
 		// simulate that backend joined the room
 		TestingConversation *conv = new TestingConversation(user->getConversationManager(), "room", true);
 		conv->addJID("user@localhost/resource");
 		conv->setNickname("hanzz");
 		user->getConversationManager()->addConversation(conv);
 		received.clear();
 		CPPUNIT_ASSERT_EQUAL(0, (int) received.size());
+	}
 	void joinRoomAfterFlagNotAuthorized() {
 		User *user = userManager->getUser("user@localhost");
 		handlePresenceJoinRoom();
 		Conversation *conv = user->getConversationManager()->getConversation("room");
 		conv->handleParticipantChanged("hanzz", Conversation::PARTICIPANT_FLAG_NOT_AUTHORIZED, Swift::StatusShow::Away, "my status message");
 		loop->processEvents();
 		CPPUNIT_ASSERT_EQUAL(1, (int) received.size());
 		CPPUNIT_ASSERT(dynamic_cast<Swift::Presence *>(getStanza(received[0])));
 		CPPUNIT_ASSERT_EQUAL(Swift::Presence::Error, dynamic_cast<Swift::Presence *>(getStanza(received[0]))->getType());
 		CPPUNIT_ASSERT(getStanza(received[0])->getPayload<Swift::ErrorPayload>());
 		CPPUNIT_ASSERT_EQUAL(Swift::ErrorPayload::NotAuthorized, getStanza(received[0])->getPayload<Swift::ErrorPayload>()->getCondition());
 		received.clear();
 		handlePresenceJoinRoom();
+	}
 };
 CPPUNIT_TEST_SUITE_REGISTRATION (UserTest);

0 comments (0 inline, 0 general)