Files @ 069cd71aa3d7
Branch filter:

Location: libtransport.git/src/conversation.cpp - annotation

HanzZ
Disconnect even invalid user, this can happen when password is valid, but session was not established yet
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
b5c026470f07
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
b5c026470f07
76c678dd6f1d
99d1c435b90f
99d1c435b90f
99d1c435b90f
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
99d1c435b90f
99d1c435b90f
943dc1925b7c
76c678dd6f1d
d39705842a2a
943dc1925b7c
76c678dd6f1d
76c678dd6f1d
b5c026470f07
76c678dd6f1d
76c678dd6f1d
2add374fbd61
943dc1925b7c
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
0a33a3100eb9
2add374fbd61
0a33a3100eb9
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
0a33a3100eb9
2add374fbd61
0a33a3100eb9
943dc1925b7c
943dc1925b7c
943dc1925b7c
943dc1925b7c
943dc1925b7c
943dc1925b7c
0a33a3100eb9
0a33a3100eb9
76c678dd6f1d
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
2add374fbd61
0a33a3100eb9
0a33a3100eb9
8e03fbec4701
6699a898fbec
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
8e03fbec4701
8e03fbec4701
8e03fbec4701
8e03fbec4701
8e03fbec4701
99d1c435b90f
8e03fbec4701
99d1c435b90f
99d1c435b90f
8e03fbec4701
8e03fbec4701
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
76c678dd6f1d
457d19d1ec41
8e03fbec4701
457d19d1ec41
8e03fbec4701
8e03fbec4701
8e03fbec4701
8e03fbec4701
8e03fbec4701
457d19d1ec41
457d19d1ec41
457d19d1ec41
457d19d1ec41
457d19d1ec41
8e03fbec4701
457d19d1ec41
457d19d1ec41
457d19d1ec41
0a33a3100eb9
0a33a3100eb9
0a33a3100eb9
8e03fbec4701
8e03fbec4701
8e03fbec4701
76c678dd6f1d
76c678dd6f1d
76c678dd6f1d
/**
 * XMPP - libpurple transport
 *
 * Copyright (C) 2009, Jan Kaluza <hanzz@soc.pidgin.im>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111-1301  USA
 */

#include <iostream>
#include "transport/conversation.h"
#include "transport/conversationmanager.h"
#include "transport/user.h"
#include "transport/transport.h"
#include "transport/buddy.h"
#include "transport/rostermanager.h"
#include "log4cxx/logger.h"

using namespace log4cxx;

namespace Transport {

// static LoggerPtr logger = Logger::getLogger("Conversation");

Conversation::Conversation(ConversationManager *conversationManager, const std::string &legacyName, bool isMUC) : m_conversationManager(conversationManager) {
	m_legacyName = legacyName;
	m_conversationManager->addConversation(this);
	m_muc = isMUC;
}

Conversation::~Conversation() {
}

void Conversation::handleMessage(boost::shared_ptr<Swift::Message> &message, const std::string &nickname) {
	if (m_muc) {
		message->setType(Swift::Message::Groupchat);
	}
	else {
		message->setType(Swift::Message::Chat);
	}
	if (message->getType() != Swift::Message::Groupchat) {
		
		message->setTo(m_conversationManager->getUser()->getJID().toBare());
		// normal message
		if (nickname.empty()) {
			Buddy *buddy = m_conversationManager->getUser()->getRosterManager()->getBuddy(m_legacyName);
			if (buddy) {
				message->setFrom(buddy->getJID());
			}
			else {
				// TODO: escape from and setFrom
			}
		}
		// PM message
		else {
			if (m_room.empty()) {
				message->setFrom(Swift::JID(nickname, m_conversationManager->getComponent()->getJID().toBare(), "user"));
			}
			else {
				message->setFrom(Swift::JID(m_room, m_conversationManager->getComponent()->getJID().toBare(), nickname));
			}
		}
		m_conversationManager->getComponent()->getStanzaChannel()->sendMessage(message);
	}
	else {
		message->setTo(m_conversationManager->getUser()->getJID().toString());
		message->setFrom(Swift::JID(m_legacyName, m_conversationManager->getComponent()->getJID().toBare(), nickname));
		m_conversationManager->getComponent()->getStanzaChannel()->sendMessage(message);
	}
}

void Conversation::handleParticipantChanged(const std::string &nick, int flag, int status, const std::string &statusMessage, const std::string &newname) {
	std::string nickname = nick;
	Swift::Presence::ref presence = Swift::Presence::create();
 	presence->setFrom(Swift::JID(m_legacyName, m_conversationManager->getComponent()->getJID().toBare(), nickname));
	presence->setTo(m_conversationManager->getUser()->getJID().toString());
	presence->setType(Swift::Presence::Available);

	if (!statusMessage.empty())
		presence->setStatus(statusMessage);

	Swift::StatusShow s((Swift::StatusShow::Type) status);

	if (s.getType() == Swift::StatusShow::None) {
		presence->setType(Swift::Presence::Unavailable);
	}

	presence->setShow(s.getType());

	Swift::MUCUserPayload *p = new Swift::MUCUserPayload ();
	if (m_nickname == nickname) {
		Swift::MUCUserPayload::StatusCode c;
		c.code = 110;
		p->addStatusCode(c);
	}

	
	Swift::MUCUserPayload::Item item(Swift::MUCOccupant::Member, Swift::MUCOccupant::Participant);

	if (flag & Moderator) {
		item = Swift::MUCUserPayload::Item(Swift::MUCOccupant::Admin, Swift::MUCOccupant::Moderator);
	}

	if (!newname.empty()) {
		item.nick = newname;
		Swift::MUCUserPayload::StatusCode c;
		c.code = 303;
		p->addStatusCode(c);
		presence->setType(Swift::Presence::Unavailable);
	}

	p->addItem(item);

	presence->addPayload(boost::shared_ptr<Swift::Payload>(p));
	m_conversationManager->getComponent()->getStanzaChannel()->sendPresence(presence);
	if (!newname.empty()) {
		handleParticipantChanged(newname, flag, status, statusMessage);
	}
}

}