Changeset - 320738eda85a
Parent rev.
Child rev.
[Not reviewed]
0 5 2
HanzZ - 14 years ago 2012-02-26 14:03:48
hanzz.k@gmail.com
Gateway interaction
7 files changed with 122 insertions and 1 deletions:
ChangeLog
1
include/Swiften/Serializer/PayloadSerializers/GatewayPayloadSerializer.cpp
1
1
include/transport/gatewayresponder.h
43
include/transport/usermanager.h
4
spectrum/src/main.cpp
4
src/gatewayresponder.cpp
63
src/transport.cpp
6
0 comments (0 inline, 0 general)
ChangeLog
➞
Show inline comments
 
Version 2.0.0-beta  (X-X-X):
 
	General:
 
	* Added PostreSQL support (thanks to Jadestorm).
 
	* Added XEP-0100 (Gateway interaction) support.
 
	* Send presences only "from" bare JID (fixed bug with buddies appearing
 
	  twice in the roster and potential unregistering issues).
 
	* Fixed potential MySQL/SQLite3 deadlocks.
 
	* Fixed disconnecting in server-mode when client does not send unavailable
 
	  presence before disconnection.
 
	* Fixed crash in server-mode when client send its custom jabber:iq:storage
 
	  payload.
 
	* Fixed registration from Pidgin.
 
	* Unsubscribe presence sent to some buddy doesn't disconnect the account.
 
	* Remote Roster requests are not sent to resources, but to bare JID.
 
	* Added automatic reconnection in case of non-fatal error.
 
	* Added more error messages.
include/Swiften/Serializer/PayloadSerializers/GatewayPayloadSerializer.cpp
➞
Show inline comments
 
@@ -11,25 +11,25 @@
 
#include <Swiften/Serializer/XML/XMLElement.h>
 
#include <Swiften/Serializer/PayloadSerializerCollection.h>
 

			




	
	
	
		
 
namespace Swift {

			




	
	
	
		
 

			




	
	
	
		
 
GatewayPayloadSerializer::GatewayPayloadSerializer()

			




	
	
	
		
 
	: GenericPayloadSerializer<GatewayPayload>() {

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
std::string GatewayPayloadSerializer::serializePayload(boost::shared_ptr<GatewayPayload> payload)  const {

			




	
	
	
		
 
	XMLElement query("query", "jabber:iq:gateway");

			




	
	
	
		
 

			




	
	
	
		
 
	if (!payload->getJID().isValid()) {

			




	
	
	
		
 
	if (payload->getJID().isValid()) {

			




	
	
	
		
 
		boost::shared_ptr<XMLElement> jid(new XMLElement("jid", "", payload->getJID().toBare().toString()));

			




	
	
	
		
 
		query.addNode(jid);

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	if (!payload->getDesc().empty()) {

			




	
	
	
		
 
		boost::shared_ptr<XMLElement> desc(new XMLElement("desc", "", payload->getDesc()));

			




	
	
	
		
 
		query.addNode(desc);

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	if (!payload->getPrompt().empty()) {

			




	
	
	
		
 
		boost::shared_ptr<XMLElement> prompt(new XMLElement("prompt", "", payload->getPrompt()));

			




	
	
	
		
 
		query.addNode(prompt);

			




        

    


    
    

    

        

                

                    include/transport/gatewayresponder.h
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
new file 100644

			




	
	
	
		
 
/**

			




	
	
	
		
 
 * libtransport -- C++ library for easy XMPP Transports development

			




	
	
	
		
 
 *

			




	
	
	
		
 
 * Copyright (C) 2011, Jan Kaluza <hanzz.k@gmail.com>

			




	
	
	
		
 
 *

			




	
	
	
		
 
 * 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

			




	
	
	
		
 
 */

			




	
	
	
		
 

			




	
	
	
		
 
#pragma once

			




	
	
	
		
 

			




	
	
	
		
 
#include <vector>

			




	
	
	
		
 
#include "Swiften/Swiften.h"

			




	
	
	
		
 
#include "Swiften/Queries/Responder.h"

			




	
	
	
		
 
#include "Swiften/Elements/GatewayPayload.h"

			




	
	
	
		
 

			




	
	
	
		
 
namespace Transport {

			




	
	
	
		
 

			




	
	
	
		
 
class UserManager;

			




	
	
	
		
 

			




	
	
	
		
 
class GatewayResponder : public Swift::Responder<Swift::GatewayPayload> {

			




	
	
	
		
 
	public:

			




	
	
	
		
 
		GatewayResponder(Swift::IQRouter *router, UserManager *userManager);

			




	
	
	
		
 
		~GatewayResponder();

			




	
	
	
		
 

			




	
	
	
		
 
	private:

			




	
	
	
		
 
		virtual bool handleGetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::GatewayPayload> payload);

			




	
	
	
		
 
		virtual bool handleSetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::GatewayPayload> payload);

			




	
	
	
		
 
		UserManager *m_userManager;

			




	
	
	
		
 
};

			




	
	
	
		
 

			




	
	
	
		
 
}

			




	
	
		
 
\ No newline at end of file

			




        

    


    
    

    

        

                

                    include/transport/usermanager.h
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -95,24 +95,28 @@ class UserManager : public Swift::EntityCapsProvider {

			




	
	
	
		
 
		/// Returns true if user is connected.

			




	
	
	
		
 
		/// \return True if user is connected.

			




	
	
	
		
 
		bool isUserConnected(const std::string &barejid) const {

			




	
	
	
		
 
			return m_users.find(barejid) != m_users.end();

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		/// Returns pointer to UserRegistry.

			




	
	
	
		
 
		/// \return Pointer to UserRegistry.

			




	
	
	
		
 
		UserRegistry *getUserRegistry() {

			




	
	
	
		
 
			return m_userRegistry;

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		Component *getComponent() {

			




	
	
	
		
 
			return m_component;

			




	
	
	
		
 
		}

			




	
	
	
		
 

			




	
	
	
		
 
		/// Connects user manually.

			




	
	
	
		
 
		/// \param user JID of user.

			




	
	
	
		
 
		void connectUser(const Swift::JID &user);

			




	
	
	
		
 

			




	
	
	
		
 
		/// Disconnects user manually.

			




	
	
	
		
 
		/// \param user JID of user.

			




	
	
	
		
 
		void disconnectUser(const Swift::JID &user);

			




	
	
	
		
 

			




	
	
	
		
 
	private:

			




	
	
	
		
 
		void handlePresence(Swift::Presence::ref presence);

			




	
	
	
		
 
		void handleMessageReceived(Swift::Message::ref message);

			




	
	
	
		
 
		void handleGeneralPresenceReceived(Swift::Presence::ref presence);

			




        

    


    
    

    

        

                

                    spectrum/src/main.cpp
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -3,24 +3,25 @@

			




	
	
	
		
 
#include "transport/filetransfermanager.h"

			




	
	
	
		
 
#include "transport/usermanager.h"

			




	
	
	
		
 
#include "transport/logger.h"

			




	
	
	
		
 
#include "transport/sqlite3backend.h"

			




	
	
	
		
 
#include "transport/mysqlbackend.h"

			




	
	
	
		
 
#include "transport/pqxxbackend.h"

			




	
	
	
		
 
#include "transport/userregistration.h"

			




	
	
	
		
 
#include "transport/networkpluginserver.h"

			




	
	
	
		
 
#include "transport/admininterface.h"

			




	
	
	
		
 
#include "transport/statsresponder.h"

			




	
	
	
		
 
#include "transport/usersreconnecter.h"

			




	
	
	
		
 
#include "transport/util.h"

			




	
	
	
		
 
#include "transport/gatewayresponder.h"

			




	
	
	
		
 
#include "Swiften/EventLoop/SimpleEventLoop.h"

			




	
	
	
		
 
#include <boost/filesystem.hpp>

			




	
	
	
		
 
#include <boost/algorithm/string.hpp>

			




	
	
	
		
 
#ifndef WIN32

			




	
	
	
		
 
#include "sys/signal.h"

			




	
	
	
		
 
#include <pwd.h>

			




	
	
	
		
 
#include <grp.h>

			




	
	
	
		
 
#include <sys/resource.h>

			




	
	
	
		
 
#include "libgen.h"

			




	
	
	
		
 
#else

			




	
	
	
		
 
#include <windows.h>

			




	
	
	
		
 
#endif

			




	
	
		
 
@@ -412,24 +413,27 @@ int main(int argc, char **argv)

			




	
	
	
		
 

			




	
	
	
		
 
		usersReconnecter = new UsersReconnecter(&transport, storageBackend);

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	FileTransferManager ftManager(&transport, &userManager);

			




	
	
	
		
 

			




	
	
	
		
 
	NetworkPluginServer plugin(&transport, &config, &userManager, &ftManager);

			




	
	
	
		
 

			




	
	
	
		
 
	AdminInterface adminInterface(&transport, &userManager, &plugin, storageBackend);

			




	
	
	
		
 
	StatsResponder statsResponder(&transport, &userManager, &plugin, storageBackend);

			




	
	
	
		
 
	statsResponder.start();

			




	
	
	
		
 

			




	
	
	
		
 
	GatewayResponder gatewayResponder(transport.getIQRouter(), &userManager);

			




	
	
	
		
 
	gatewayResponder.start();

			




	
	
	
		
 

			




	
	
	
		
 
	eventLoop_ = &eventLoop;

			




	
	
	
		
 

			




	
	
	
		
 
	eventLoop.run();

			




	
	
	
		
 

			




	
	
	
		
 
	if (userRegistration) {

			




	
	
	
		
 
		userRegistration->stop();

			




	
	
	
		
 
		delete userRegistration;

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	if (usersReconnecter) {

			




	
	
	
		
 
		delete usersReconnecter;

			




	
	
	
		
 
	}

			




        

    


    
    

    

        

                

                    src/gatewayresponder.cpp
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
new file 100644

			




	
	
	
		
 
/**

			




	
	
	
		
 
 * 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/gatewayresponder.h"

			




	
	
	
		
 

			




	
	
	
		
 
#include <iostream>

			




	
	
	
		
 
#include <boost/bind.hpp>

			




	
	
	
		
 
#include "Swiften/Queries/IQRouter.h"

			




	
	
	
		
 
#include "Swiften/Elements/RawXMLPayload.h"

			




	
	
	
		
 
#include "Swiften/Swiften.h"

			




	
	
	
		
 
#include "transport/usermanager.h"

			




	
	
	
		
 
#include "transport/user.h"

			




	
	
	
		
 
#include "transport/transport.h"

			




	
	
	
		
 
#include "log4cxx/logger.h"

			




	
	
	
		
 

			




	
	
	
		
 
using namespace log4cxx;

			




	
	
	
		
 

			




	
	
	
		
 
using namespace Swift;

			




	
	
	
		
 
using namespace boost;

			




	
	
	
		
 

			




	
	
	
		
 
namespace Transport {

			




	
	
	
		
 

			




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

			




	
	
	
		
 

			




	
	
	
		
 
GatewayResponder::GatewayResponder(Swift::IQRouter *router, UserManager *userManager) : Swift::Responder<GatewayPayload>(router) {

			




	
	
	
		
 
	m_userManager = userManager;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
GatewayResponder::~GatewayResponder() {

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
bool GatewayResponder::handleGetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::GatewayPayload> payload) {

			




	
	
	
		
 
	sendResponse(from, id, boost::shared_ptr<GatewayPayload>(new GatewayPayload(Swift::JID(), "Enter legacy network contact ID.", "Contact ID")));

			




	
	
	
		
 
	return true;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
bool GatewayResponder::handleSetRequest(const Swift::JID& from, const Swift::JID& to, const std::string& id, boost::shared_ptr<Swift::GatewayPayload> payload) {

			




	
	
	
		
 
	std::string prompt = payload->getPrompt();

			




	
	
	
		
 
	std::string escaped = Swift::JID::getEscapedNode(prompt);

			




	
	
	
		
 
	std::string jid = escaped + "@" + m_userManager->getComponent()->getJID().toBare().toString();

			




	
	
	
		
 
	

			




	
	
	
		
 
	sendResponse(from, id, boost::shared_ptr<GatewayPayload>(new GatewayPayload(jid)));

			




	
	
	
		
 
	return true;

			




	
	
	
		
 
}

			




	
	
	
		
 

			




	
	
	
		
 
}

			




        

    


    
    

    

        

                

                    src/transport.cpp
                

                

                  
                      
                        

                      ➞

                      
                        
                  

                  
                      
                  
                      
                  
                      
                  
                      
                  
                  
                

                

                    Show inline comments
                    
                

        

        

            



	
	
		
 
@@ -27,24 +27,26 @@

			




	
	
	
		
 
#include "discoinforesponder.h"

			




	
	
	
		
 
#include "discoitemsresponder.h"

			




	
	
	
		
 
#include "storageparser.h"

			




	
	
	
		
 
#include "Swiften/TLS/OpenSSL/OpenSSLServerContext.h"

			




	
	
	
		
 
#include "Swiften/TLS/PKCS12Certificate.h"

			




	
	
	
		
 
#include "Swiften/TLS/OpenSSL/OpenSSLServerContextFactory.h"

			




	
	
	
		
 
#include "Swiften/Parser/PayloadParsers/AttentionParser.h"

			




	
	
	
		
 
#include "Swiften/Serializer/PayloadSerializers/AttentionSerializer.h"

			




	
	
	
		
 
#include "Swiften/Parser/PayloadParsers/XHTMLIMParser.h"

			




	
	
	
		
 
#include "Swiften/Serializer/PayloadSerializers/XHTMLIMSerializer.h"

			




	
	
	
		
 
#include "Swiften/Parser/PayloadParsers/StatsParser.h"

			




	
	
	
		
 
#include "Swiften/Serializer/PayloadSerializers/StatsSerializer.h"

			




	
	
	
		
 
#include "Swiften/Parser/PayloadParsers/GatewayPayloadParser.h"

			




	
	
	
		
 
#include "Swiften/Serializer/PayloadSerializers/GatewayPayloadSerializer.h"

			




	
	
	
		
 
#include "Swiften/Serializer/PayloadSerializers/SpectrumErrorSerializer.h"

			




	
	
	
		
 
#include "transport/BlockParser.h"

			




	
	
	
		
 
#include "transport/BlockSerializer.h"

			




	
	
	
		
 
#include "Swiften/Parser/PayloadParsers/InvisibleParser.h"

			




	
	
	
		
 
#include "Swiften/Serializer/PayloadSerializers/InvisibleSerializer.h"

			




	
	
	
		
 
#include "log4cxx/logger.h"

			




	
	
	
		
 
#include "log4cxx/consoleappender.h"

			




	
	
	
		
 
#include "log4cxx/patternlayout.h"

			




	
	
	
		
 
#include "log4cxx/propertyconfigurator.h"

			




	
	
	
		
 
#include "Swiften/Swiften.h"

			




	
	
	
		
 

			




	
	
	
		
 
using namespace Swift;

			




	
	
		
 
@@ -86,57 +88,61 @@ Component::Component(Swift::EventLoop *loop, Swift::NetworkFactories *factories,

			




	
	
	
		
 
			LOG4CXX_WARN(logger, "No PKCS#12 certificate used. TLS is disabled.");

			




	
	
	
		
 
		}

			




	
	
	
		
 
// 		m_server->start();

			




	
	
	
		
 
		m_stanzaChannel = m_server->getStanzaChannel();

			




	
	
	
		
 
		m_iqRouter = m_server->getIQRouter();

			




	
	
	
		
 

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<StorageParser>("private", "jabber:iq:private"));

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::AttentionParser>("attention", "urn:xmpp:attention:0"));

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::XHTMLIMParser>("html", "http://jabber.org/protocol/xhtml-im"));

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<Transport::BlockParser>("block", "urn:xmpp:block:0"));

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::InvisibleParser>("invisible", "urn:xmpp:invisible:0"));

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::StatsParser>("query", "http://jabber.org/protocol/stats"));

			




	
	
	
		
 
		m_server->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::GatewayPayloadParser>("query", "jabber:iq:gateway"));

			




	
	
	
		
 

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Swift::AttentionSerializer());

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Swift::XHTMLIMSerializer());

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Transport::BlockSerializer());

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Swift::InvisibleSerializer());

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Swift::StatsSerializer());

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Swift::SpectrumErrorSerializer());

			




	
	
	
		
 
		m_server->addPayloadSerializer(new Swift::GatewayPayloadSerializer());

			




	
	
	
		
 

			




	
	
	
		
 
		m_server->onDataRead.connect(boost::bind(&Component::handleDataRead, this, _1));

			




	
	
	
		
 
		m_server->onDataWritten.connect(boost::bind(&Component::handleDataWritten, this, _1));

			




	
	
	
		
 
	}

			




	
	
	
		
 
	else {

			




	
	
	
		
 
		LOG4CXX_INFO(logger, "Creating component in gateway mode");

			




	
	
	
		
 
		m_component = new Swift::Component(loop, m_factories, m_jid, CONFIG_STRING(m_config, "service.password"));

			




	
	
	
		
 
		m_component->setSoftwareVersion("", "");

			




	
	
	
		
 
		m_component->onConnected.connect(bind(&Component::handleConnected, this));

			




	
	
	
		
 
		m_component->onError.connect(boost::bind(&Component::handleConnectionError, this, _1));

			




	
	
	
		
 
		m_component->onDataRead.connect(boost::bind(&Component::handleDataRead, this, _1));

			




	
	
	
		
 
		m_component->onDataWritten.connect(boost::bind(&Component::handleDataWritten, this, _1));

			




	
	
	
		
 

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<StorageParser>("private", "jabber:iq:private"));

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::AttentionParser>("attention", "urn:xmpp:attention:0"));

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::XHTMLIMParser>("html", "http://jabber.org/protocol/xhtml-im"));

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<Transport::BlockParser>("block", "urn:xmpp:block:0"));

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::InvisibleParser>("invisible", "urn:xmpp:invisible:0"));

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::StatsParser>("query", "http://jabber.org/protocol/stats"));

			




	
	
	
		
 
		m_component->addPayloadParserFactory(new GenericPayloadParserFactory<Swift::GatewayPayloadParser>("query", "jabber:iq:gateway"));

			




	
	
	
		
 

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Swift::AttentionSerializer());

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Swift::XHTMLIMSerializer());

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Transport::BlockSerializer());

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Swift::InvisibleSerializer());

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Swift::StatsSerializer());

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Swift::SpectrumErrorSerializer());

			




	
	
	
		
 
		m_component->addPayloadSerializer(new Swift::GatewayPayloadSerializer());

			




	
	
	
		
 

			




	
	
	
		
 
		m_stanzaChannel = m_component->getStanzaChannel();

			




	
	
	
		
 
		m_iqRouter = m_component->getIQRouter();

			




	
	
	
		
 
	}

			




	
	
	
		
 

			




	
	
	
		
 
	m_capsMemoryStorage = new CapsMemoryStorage();

			




	
	
	
		
 
	m_capsManager = new CapsManager(m_capsMemoryStorage, m_stanzaChannel, m_iqRouter);

			




	
	
	
		
 
	m_entityCapsManager = new EntityCapsManager(m_capsManager, m_stanzaChannel);

			




	
	
	
		
 
 	m_entityCapsManager->onCapsChanged.connect(boost::bind(&Component::handleCapsChanged, this, _1));

			




	
	
	
		
 
	

			




	
	
	
		
 
	m_presenceOracle = new Transport::PresenceOracle(m_stanzaChannel);

			




	
	
	
		
 
	m_presenceOracle->onPresenceChange.connect(bind(&Component::handlePresence, this, _1));

			




        

    



    


    



    



      

      





    
    0 comments (0 inline, 0 general)
    





    


  

  







  


    




    








    
        Server instance: srv01-3934
    
    
        This site is powered by
            Kallithea,
        which is
        © 2010–2021 by various authors & licensed under GPLv3.
            – Support