Files @ af6c160261c2
Branch filter:

Location: libtransport.git/include/transport/Transport.h - annotation

Jan Kaluza
Web interface: support service.base_location=/something/ to override default '/' root location used by the web interface
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
e678a46286f4
fe47e0979be9
e678a46286f4
e678a46286f4
fe47e0979be9
fe47e0979be9
fe47e0979be9
fe47e0979be9
e678a46286f4
e678a46286f4
c5edfd19b1aa
c8006a0ebab6
1e8eb7076f17
fe47e0979be9
fe47e0979be9
fe47e0979be9
fe47e0979be9
fe47e0979be9
e678a46286f4
fe47e0979be9
e678a46286f4
271a7134db1a
d39705842a2a
d39705842a2a
d39705842a2a
271a7134db1a
271a7134db1a
271a7134db1a
271a7134db1a
d39705842a2a
cc64a76c8be5
d39705842a2a
cc64a76c8be5
fe47e0979be9
271a7134db1a
271a7134db1a
c5edfd19b1aa
e678a46286f4
d39705842a2a
d39705842a2a
d39705842a2a
d39705842a2a
d39705842a2a
fe47e0979be9
d39705842a2a
cc64a76c8be5
cc64a76c8be5
cc64a76c8be5
cc64a76c8be5
28ca4ba95e42
cc64a76c8be5
cc64a76c8be5
28ca4ba95e42
99aff9256622
271a7134db1a
d39705842a2a
271a7134db1a
c5edfd19b1aa
c5edfd19b1aa
d39705842a2a
d39705842a2a
d39705842a2a
dd11e43325de
5f017bd15dc7
d39705842a2a
d39705842a2a
d39705842a2a
c8006a0ebab6
c8006a0ebab6
599469670eec
d39705842a2a
599469670eec
fe47e0979be9
599469670eec
599469670eec
99aff9256622
599469670eec
599469670eec
d39705842a2a
9c294ea31925
9c294ea31925
fe47e0979be9
fe47e0979be9
fe47e0979be9
d39705842a2a
d39705842a2a
cc64a76c8be5
cc64a76c8be5
cc64a76c8be5
c5edfd19b1aa
99aff9256622
4f9457bdd83a
fe47e0979be9
fe47e0979be9
fe47e0979be9
fe47e0979be9
fe47e0979be9
fe47e0979be9
4f9457bdd83a
fe47e0979be9
fe47e0979be9
e5aab1415d9e
e5aab1415d9e
fe47e0979be9
99aff9256622
fe47e0979be9
e23f8e3c7f9d
5f017bd15dc7
e678a46286f4
4f9457bdd83a
4f9457bdd83a
dd11e43325de
e678a46286f4
f035510e4798
941bba0427fe
c7f2b6298073
c5edfd19b1aa
e678a46286f4
bf4183c181eb
e678a46286f4
c8006a0ebab6
828ae9d2cb88
4f9457bdd83a
fe47e0979be9
c5edfd19b1aa
c5edfd19b1aa
c5edfd19b1aa
bc585576a9ab
e678a46286f4
e678a46286f4
/**
 * 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 <boost/bind.hpp>
#include "Swiften/Network/BoostTimerFactory.h"
#include "Swiften/Network/BoostIOServiceThread.h"
#include "Swiften/Network/NetworkFactories.h"
#include "Swiften/Elements/DiscoInfo.h"
#include "Swiften/Elements/Presence.h"
#include "Swiften/Elements/IQ.h"

namespace Transport {
	class StorageBackend;
	class Factory;
	class UserRegistry;
	class Frontend;
	class PresenceOracle;
	class Factory;
	class Config;
	class UserManager;

	class Component {
		public:
			/// Creates new Component instance.

			/// \param loop Main event loop.
			/// \param config Cofiguration; this class uses following Config values:
			/// 	- service.jid
			/// 	- service.password
			/// 	- service.server
			/// 	- service.port
			/// 	- service.server_mode
			/// \param factories Swift::NetworkFactories.
			/// \param factory Transport Abstract factory used to create basic transport structures.
			/// \param userRegistery UserRegistry class instance. It's needed only when running transport in server-mode.
			Component(Frontend *frontend, Swift::EventLoop *loop, Swift::NetworkFactories *factories, Config *config, Factory *factory, Transport::UserRegistry *userRegistry = NULL);

			/// Component destructor.
			~Component();

			/// Returns Swift::StanzaChannel associated with this Transport::Component.

			/// Returns True if the component is in server mode.

			/// \return True if the component is in server mode.
			bool inServerMode();

			/// Starts the Component.
			
			/// In server-mode, it starts listening on particular port for new client connections.
			/// In gateway-mode, it connects the XMPP server.
			void start();

			/// Stops the component.
			void stop();

			/// Returns Jabber ID of this transport.

			/// \return Jabber ID of this transport
			Swift::JID &getJID() { return m_jid; }

			/// Returns Swift::NetworkFactories which can be used to create new connections.

			/// \return Swift::NetworkFactories which can be used to create new connections.
			Swift::NetworkFactories *getNetworkFactories() { return m_factories; }

			/// Returns Transport Factory used to create basic Transport components.

			/// \return Transport Factory used to create basic Transport components.
			Factory *getFactory() { return m_factory; }

			/// This signal is emitted when server disconnects the transport because of some error.

			/// \param error disconnection error
			boost::signal<void (const std::string &error)> onConnectionError;

			/// This signal is emitted when transport successfully connects the server.
			boost::signal<void ()> onConnected;

			/// This signal is emitted when XML stanza is sent to server.

			Config *getConfig() { return m_config; }

			bool isRawXMLEnabled() {
				return m_rawXML;
			}

			/// It's emitted only for presences addressed to transport itself
			/// (for example to="j2j.domain.tld") and for presences comming to
			/// MUC (for example to="#chat%irc.freenode.org@irc.domain.tld")
			/// \param presence Presence.
			boost::signal<void (Swift::Presence::ref presence)> onUserPresenceReceived;

			boost::signal<void (boost::shared_ptr<Swift::IQ>)> onRawIQReceived;
			
			void handlePresence(Swift::Presence::ref presence);
			void handleConnected();
			void handleConnectionError(const std::string &error);
			void handleDataRead(const std::string &data);
			void handleDataWritten(const std::string &data);

			Frontend *getFrontend() {
				return m_frontend;
			}

			PresenceOracle *getPresenceOracle();

		private:
			void handleDiscoInfoResponse(boost::shared_ptr<Swift::DiscoInfo> info, Swift::ErrorPayload::ref error, const Swift::JID& jid);
			void handleCapsChanged(const Swift::JID& jid);

			void handleBackendConfigChanged();

			Swift::NetworkFactories *m_factories;
			Swift::Timer::ref m_reconnectTimer;
			PresenceOracle *m_presenceOracle;
			
			Transport::UserRegistry *m_userRegistry;
			StorageBackend *m_storageBackend;
			int m_reconnectCount;
			Config* m_config;
			Swift::JID m_jid;
			Factory *m_factory;
			Swift::EventLoop *m_loop;
			bool m_rawXML;
			Frontend *m_frontend;

		friend class User;
		friend class UserRegistration;
		friend class NetworkPluginServer;
	};
}