Files @ 9477e3f83882
Branch filter:

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

HanzZ
Working accounts sharing :)
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
7a0e5e31e6e2
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
8ab47cce7012
8ab47cce7012
8ab47cce7012
ac7bbb6cccf3
c00d5149d528
c00d5149d528
c00d5149d528
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
c00d5149d528
c00d5149d528
7a0e5e31e6e2
525a07a4d19a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
07859ef3936a
23782242786f
23782242786f
8ab47cce7012
8ab47cce7012
c00d5149d528
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
8ab47cce7012
c00d5149d528
c00d5149d528
c00d5149d528
8ab47cce7012
9477e3f83882
07859ef3936a
07859ef3936a
07859ef3936a
525a07a4d19a
525a07a4d19a
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
c00d5149d528
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
c00d5149d528
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
c00d5149d528
a6781df77f76
ac7bbb6cccf3
ac7bbb6cccf3
c00d5149d528
a6781df77f76
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
c00d5149d528
ac7bbb6cccf3
ac7bbb6cccf3
ac7bbb6cccf3
a6781df77f76
ac7bbb6cccf3
ac7bbb6cccf3
525a07a4d19a
525a07a4d19a
525a07a4d19a
07859ef3936a
/**
 * 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 "transport/rosterresponder.h"

#include <iostream>
#include <boost/bind.hpp>
#include "Swiften/Queries/IQRouter.h"
#include "Swiften/Swiften.h"
#include "transport/user.h"
#include "transport/usermanager.h"
#include "transport/rostermanager.h"
#include "transport/buddy.h"
#include "log4cxx/logger.h"

using namespace log4cxx;

using namespace Swift;
using namespace boost;

namespace Transport {

static LoggerPtr logger = Logger::getLogger("RosterResponder");

RosterResponder::RosterResponder(Swift::IQRouter *router, UserManager *userManager) : Swift::Responder<RosterPayload>(router) {
	m_userManager = userManager;
}

RosterResponder::~RosterResponder() {
}

bool RosterResponder::handleGetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::RosterPayload> payload) {
	// Get means we're in server mode and user wants to fetch his roster.
	// For now we send empty reponse, but TODO: Get buddies from database and send proper stored roster.
	User *user = m_userManager->getUser(from.toBare().toString());
	if (!user) {
		LOG4CXX_INFO(logger, from.toBare().toString() << ": Sending roster");
		// Client can send jabber:iq:roster IQ before presence, so we do little hack here to
		// trigger logging in.
		// UserManager should create user now, if everything is OK.
		Swift::Presence::ref response = Swift::Presence::create();
		response->setTo(to);
		response->setFrom(from);
		response->setType(Swift::Presence::Available);
		m_userManager->handlePresence(response);

		// if it's not created, lets finish this get
		user = m_userManager->getUser(from.toBare().toString());
		if (!user) {
			sendResponse(from, id, boost::shared_ptr<RosterPayload>(new RosterPayload()));
			return true;
		}
	}
	else {
		LOG4CXX_WARN(logger, from.toBare().toString() << ": User is not logged in");
	}
	sendResponse(from, id, user->getRosterManager()->generateRosterPayload());
	user->getRosterManager()->sendCurrentPresences(from);
	return true;
}

bool RosterResponder::handleSetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::RosterPayload> payload) {
	sendResponse(from, id, boost::shared_ptr<RosterPayload>(new RosterPayload()));

	User *user = m_userManager->getUser(from.toBare().toString());
	if (!user) {
		LOG4CXX_WARN(logger, from.toBare().toString() << ": User is not logged in");
		return true;
	}

	if (payload->getItems().size() == 0) {
		LOG4CXX_WARN(logger, from.toBare().toString() << ": Roster push with no item");
		return true;
	}

	Swift::RosterItemPayload item = payload->getItems()[0];

	Buddy *buddy = user->getRosterManager()->getBuddy(Buddy::JIDToLegacyName(item.getJID()));
	if (buddy) {
		if (item.getSubscription() == Swift::RosterItemPayload::Remove) {
			LOG4CXX_INFO(logger, from.toBare().toString() << ": Removing buddy " << buddy->getName());
			onBuddyRemoved(buddy);
		}
		else {
			LOG4CXX_INFO(logger, from.toBare().toString() << ": Updating buddy " << buddy->getName());
			onBuddyUpdated(buddy, item);
		}
	}
	else if (item.getSubscription() != Swift::RosterItemPayload::Remove) {
		// Roster push for this new buddy is sent by RosterManager
		BuddyInfo buddyInfo;
		buddyInfo.id = -1;
		buddyInfo.alias = item.getName();
		buddyInfo.legacyName = Buddy::JIDToLegacyName(item.getJID());
		buddyInfo.subscription = "both";
		buddyInfo.flags = 0;
		LOG4CXX_INFO(logger, from.toBare().toString() << ": Adding buddy " << buddyInfo.legacyName);

		buddy = user->getComponent()->getFactory()->createBuddy(user->getRosterManager(), buddyInfo);
		user->getRosterManager()->setBuddy(buddy);
		onBuddyAdded(buddy, item);
	}

	return true;
}

}