void NetworkPluginServer::handleDisconnectedPayload(const std::string &data) {

	pbnetwork::Disconnected payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	m_component->m_userRegistry->onPasswordInvalid(payload.user(), payload.message());

	User *user = m_userManager->getUser(payload.user());

	if (!user) {

		return;

	}

	user->handleDisconnected(payload.message(), (Swift::SpectrumErrorPayload::Error) payload.error());

}

void NetworkPluginServer::handleVCardPayload(const std::string &data) {

	pbnetwork::VCard payload;

	if (payload.ParseFromString(data) == false) {

		std::cout << "PARSING ERROR\n";

		// TODO: ERROR

		return;

	}

	boost::shared_ptr<Swift::VCard> vcard(new Swift::VCard());

	vcard->setFullName(payload.fullname());

	vcard->setPhoto(Swift::createByteArray(payload.photo()));

	vcard->setNickname(payload.nickname());

	m_vcardResponder->sendVCard(payload.id(), vcard);

}

void NetworkPluginServer::handleAuthorizationPayload(const std::string &data) {

	pbnetwork::Buddy payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	User *user = m_userManager->getUser(payload.username());

	if (!user)

		return;

	// Create subscribe presence and forward it to XMPP side

	Swift::Presence::ref response = Swift::Presence::create();

	response->setTo(user->getJID());

	std::string name = payload.buddyname();

	name = Swift::JID::getEscapedNode(name);

// 	if (name.find_last_of("@") != std::string::npos) { // OK when commented

// 		name.replace(name.find_last_of("@"), 1, "%"); // OK when commented

// 	}

	response->setFrom(Swift::JID(name, m_component->getJID().toString()));

	response->setType(Swift::Presence::Subscribe);

	m_component->getStanzaChannel()->sendPresence(response);

}

void NetworkPluginServer::handleChatStatePayload(const std::string &data, Swift::ChatState::ChatStateType type) {

	pbnetwork::Buddy payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	User *user = m_userManager->getUser(payload.username());

	if (!user)

		return;

	// We're not creating new Conversation just because of chatstates.

	// Some networks/clients spams with chatstates a lot and it leads to bigger memory usage.

	NetworkConversation *conv = (NetworkConversation *) user->getConversationManager()->getConversation(payload.buddyname());

	if (!conv) {

		return;

	}

	// Forward chatstate

	boost::shared_ptr<Swift::Message> msg(new Swift::Message());

	msg->addPayload(boost::make_shared<Swift::ChatState>(type));

	conv->handleMessage(msg);

}

void NetworkPluginServer::handleBuddyChangedPayload(const std::string &data) {

	pbnetwork::Buddy payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	User *user = m_userManager->getUser(payload.username());

	if (!user)

		return;

	LocalBuddy *buddy = (LocalBuddy *) user->getRosterManager()->getBuddy(payload.buddyname());

	if (buddy) {

		handleBuddyPayload(buddy, payload);

		buddy->handleBuddyChanged();

	}

	else {

		buddy = new LocalBuddy(user->getRosterManager(), -1);

		buddy->setFlags(BUDDY_JID_ESCAPING);

		handleBuddyPayload(buddy, payload);

		user->getRosterManager()->setBuddy(buddy);

	}

}

void NetworkPluginServer::handleParticipantChangedPayload(const std::string &data) {

	pbnetwork::Participant payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	User *user = m_userManager->getUser(payload.username());

	if (!user)

		return;

	NetworkConversation *conv = (NetworkConversation *) user->getConversationManager()->getConversation(payload.room());

	if (!conv) {

		return;

	}

	conv->handleParticipantChanged(payload.nickname(), payload.flag(), payload.status(), payload.statusmessage(), payload.newname());

}

void NetworkPluginServer::handleRoomChangedPayload(const std::string &data) {

	pbnetwork::Room payload;

	if (payload.ParseFromString(data) == false) {

		return;

	}

	User *user = m_userManager->getUser(payload.username());

	if (!user)

		return;

	NetworkConversation *conv = (NetworkConversation *) user->getConversationManager()->getConversation(payload.room());

	if (!conv) {

		return;

	}

	conv->setNickname(payload.nickname());

}

void NetworkPluginServer::handleConvMessagePayload(const std::string &data, bool subject) {

	pbnetwork::ConversationMessage payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	User *user = m_userManager->getUser(payload.username());

	if (!user)

		return;

	// Message from legacy network triggers network acticity

	user->updateLastActivity();

	// Set proper body.

	boost::shared_ptr<Swift::Message> msg(new Swift::Message());

	if (subject) {

		msg->setSubject(payload.message());

	}

	else {

		msg->setBody(payload.message());

	}

	// Add xhtml-im payload.

	if (!payload.xhtml().empty()) {

		msg->addPayload(boost::make_shared<Swift::XHTMLIMPayload>(payload.xhtml()));

	}

	// Create new Conversation if it does not exist

	NetworkConversation *conv = (NetworkConversation *) user->getConversationManager()->getConversation(payload.buddyname());

	if (!conv) {

		conv = new NetworkConversation(user->getConversationManager(), payload.buddyname());

		conv->onMessageToSend.connect(boost::bind(&NetworkPluginServer::handleMessageReceived, this, _1, _2));

	}

	// Forward it

	conv->handleMessage(msg, payload.nickname());

}

void NetworkPluginServer::handleAttentionPayload(const std::string &data) {

	pbnetwork::ConversationMessage payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}