diff --git a/src/tests/user.cpp b/src/tests/user.cpp
index 864cbebae387f2458e071cedffb2107dcdabf374..a35ac423b93396f8e53fe3ca7a3189920eb7392b 100644
--- a/src/tests/user.cpp
+++ b/src/tests/user.cpp
@@ -23,20 +23,65 @@ using namespace Transport;
 class UserTest : public CPPUNIT_NS :: TestFixture, public BasicTest {
 	CPPUNIT_TEST_SUITE(UserTest);
 	CPPUNIT_TEST(sendCurrentPresence);
+    CPPUNIT_TEST(handlePresence);
+	CPPUNIT_TEST(handlePresenceJoinRoom);
+	CPPUNIT_TEST(handlePresenceLeaveRoom);
+	CPPUNIT_TEST(handleDisconnected);
 	CPPUNIT_TEST_SUITE_END();
 
 	public:
+		std::string room;
+		std::string roomNickname;
+		std::string roomPassword;
+		bool readyToConnect;
+		bool disconnected;
+		Swift::Presence::ref changedPresence;
+
 		void setUp (void) {
+			disconnected = false;
+			readyToConnect = false;
+			changedPresence = Swift::Presence::ref();
+			room = "";
+			roomNickname = "";
+			roomPassword = "";
+
 			setMeUp();
+			userManager->onUserCreated.connect(boost::bind(&UserTest::handleUserCreated, this, _1));
 			connectUser();
 			received.clear();
 		}
 
 		void tearDown (void) {
+			received.clear();
 			disconnectUser();
 			tearMeDown();
 		}
 
+	void handleUserCreated(User *user) {
+		user->onReadyToConnect.connect(boost::bind(&UserTest::handleUserReadyToConnect, this, user));
+		user->onPresenceChanged.connect(boost::bind(&UserTest::handleUserPresenceChanged, this, user, _1));
+		user->onRoomJoined.connect(boost::bind(&UserTest::handleRoomJoined, this, user, _1, _2, _3));
+		user->onRoomLeft.connect(boost::bind(&UserTest::handleRoomLeft, this, user, _1));
+	}
+
+	void handleUserReadyToConnect(User *user) {
+		readyToConnect = true;
+	}
+
+	void handleUserPresenceChanged(User *user, Swift::Presence::ref presence) {
+		changedPresence = presence;
+	}
+
+	void handleRoomJoined(User *user, const std::string &r, const std::string &nickname, const std::string &password) {
+		room = r;
+		roomNickname = nickname;
+		roomPassword = password;
+	}
+
+	void handleRoomLeft(User *user, const std::string &r) {
+		room = r;
+	}
+
 	void connectUser() {
 		CPPUNIT_ASSERT_EQUAL(0, userManager->getUserCount());
 		userRegistry->isValidUserPassword(Swift::JID("user@localhost/resource"), serverFromClientSession.get(), Swift::createSafeByteArray("password"));
@@ -51,11 +96,14 @@ class UserTest : public CPPUNIT_NS :: TestFixture, public BasicTest {
 		CPPUNIT_ASSERT(user->isReadyToConnect() == true);
 		CPPUNIT_ASSERT(user->isConnected() == false);
 
+		CPPUNIT_ASSERT_EQUAL(true, readyToConnect);
+
 		user->setConnected(true);
 		CPPUNIT_ASSERT(user->isConnected() == true);
 
 		CPPUNIT_ASSERT_EQUAL(1, (int) received.size());
 		CPPUNIT_ASSERT(getStanza(received[0])->getPayload<Swift::DiscoInfo>());
+		received.clear();
 	}
 
 	void sendCurrentPresence() {
@@ -66,7 +114,84 @@ class UserTest : public CPPUNIT_NS :: TestFixture, public BasicTest {
 		CPPUNIT_ASSERT_EQUAL(0, (int) received.size());
 	}
 
+	void handlePresence() {
+		Swift::Presence::ref response = Swift::Presence::create();
+		response->setTo("localhost");
+		response->setFrom("user@localhost/resource");
+		response->setShow(Swift::StatusShow::Away);
+
+		injectPresence(response);
+		loop->processEvents();
+
+		// no presence received in server mode, just disco#info
+		CPPUNIT_ASSERT_EQUAL(1, (int) received.size());
+		CPPUNIT_ASSERT(getStanza(received[0])->getPayload<Swift::DiscoInfo>());
+
+		CPPUNIT_ASSERT(changedPresence);
+		CPPUNIT_ASSERT_EQUAL(Swift::StatusShow::Away, changedPresence->getShow());
+	}
+
+	void handlePresenceJoinRoom() {
+		Swift::Presence::ref response = Swift::Presence::create();
+		response->setTo("#room@localhost/hanzz");
+		response->setFrom("user@localhost/resource");
+
+		Swift::MUCPayload *payload = new Swift::MUCPayload();
+		payload->setPassword("password");
+		response->addPayload(boost::shared_ptr<Swift::Payload>(payload));
+		injectPresence(response);
+		loop->processEvents();
+
+		// no presence received in server mode, just disco#info
+		CPPUNIT_ASSERT_EQUAL(1, (int) received.size());
+		CPPUNIT_ASSERT(getStanza(received[0])->getPayload<Swift::DiscoInfo>());
+
+		CPPUNIT_ASSERT_EQUAL(std::string("#room"), room);
+		CPPUNIT_ASSERT_EQUAL(std::string("hanzz"), roomNickname);
+		CPPUNIT_ASSERT_EQUAL(std::string("password"), roomPassword);
+	}
+
+	void handlePresenceLeaveRoom() {
+		Swift::Presence::ref response = Swift::Presence::create();
+		response->setTo("#room@localhost/hanzz");
+		response->setFrom("user@localhost/resource");
+		response->setType(Swift::Presence::Unavailable);
+
+		Swift::MUCPayload *payload = new Swift::MUCPayload();
+		payload->setPassword("password");
+		response->addPayload(boost::shared_ptr<Swift::Payload>(payload));
+		injectPresence(response);
+		loop->processEvents();
+
+		CPPUNIT_ASSERT_EQUAL(0, (int) received.size());
+
+		CPPUNIT_ASSERT_EQUAL(std::string("#room"), room);
+		CPPUNIT_ASSERT_EQUAL(std::string(""), roomNickname);
+		CPPUNIT_ASSERT_EQUAL(std::string(""), roomPassword);
+	}
+
+	void handleDisconnected() {
+		User *user = userManager->getUser("user@localhost");
+		user->handleDisconnected("Connection error");
+		loop->processEvents();
+
+		CPPUNIT_ASSERT(streamEnded);
+		user = userManager->getUser("user@localhost");
+		CPPUNIT_ASSERT(!user);
+
+		CPPUNIT_ASSERT_EQUAL(2, (int) received.size());
+		Swift::Message *m = dynamic_cast<Swift::Message *>(getStanza(received[0]));
+		CPPUNIT_ASSERT_EQUAL(std::string("Connection error"), m->getBody());
+
+		CPPUNIT_ASSERT(dynamic_cast<Swift::StreamError *>(received[1].get()));
+		CPPUNIT_ASSERT_EQUAL(std::string("Connection error"), dynamic_cast<Swift::StreamError *>(received[1].get())->getText());
+
+		disconnected = true;
+	}
+
 	void disconnectUser() {
+		if (disconnected)
+			return;
 		userManager->disconnectUser("user@localhost");
 		dynamic_cast<Swift::DummyTimerFactory *>(factories->getTimerFactory())->setTime(10);
 		loop->processEvents();