#ifndef BIBOUMI_COMPONENT_INCLUDED # define BIBOUMI_COMPONENT_INCLUDED #include <xmpp/xmpp_component.hpp> #include <bridge/bridge.hpp> #include <memory> #include <string> #include <map> struct ListElement; /** * A callback called when the waited iq result is received (it is matched * against the iq id) */ using iq_responder_callback_t = std::function<void(Bridge* bridge, const Stanza& stanza)>; /** * Interact with the Biboumi Bridge */ class BiboumiComponent: public XmppComponent { public: explicit BiboumiComponent(std::shared_ptr<Poller> poller, const std::string& hostname, const std::string& secret); ~BiboumiComponent() = default; /** * Returns the bridge for the given user. If it does not exist, return * nullptr. */ Bridge* find_user_bridge(const std::string& user_jid); /** * Return a list of all the managed bridges. */ std::list<Bridge*> get_bridges() const; /** * Send a "close" message to all our connected peers. That message * depends on the protocol used (this may be a QUIT irc message, or a * <stream/>, etc). We may also directly close the connection, or we may * wait for the remote peer to acknowledge it before closing. */ void shutdown(); /** * Run a check on all bridges, to remove all disconnected (socket is * closed, or no channel is joined) IrcClients. Some kind of garbage collector. */ void clean(); /** * Send a result IQ with the gateway disco informations. */ void send_self_disco_info(const std::string& id, const std::string& jid_to); /** * Send an iq version request */ void send_iq_version_request(const std::string& from, const std::string& jid_to); /** * Send a ping request */ void send_ping_request(const std::string& from, const std::string& jid_to, const std::string& id); /** * Send the channels list in one big stanza */ void send_iq_room_list_result(const std::string& id, const std::string& to_jid, const std::string& from, const std::vector<ListElement>& rooms_list); /** * Handle the various stanza types */ void handle_presence(const Stanza& stanza); void handle_message(const Stanza& stanza); void handle_iq(const Stanza& stanza); private: /** * Return the bridge associated with the given full JID. Create a new one * if none already exist. */ Bridge* get_user_bridge(const std::string& user_jid); /** * A map of id -> callback. When we want to wait for an iq result, we add * the callback to this map, with the iq id as the key. When an iq result * is received, we look for a corresponding callback in this map. If * found, we call it and remove it. */ std::map<std::string, iq_responder_callback_t> waiting_iq; /** * One bridge for each user of the component. Indexed by the user's full * jid */ std::unordered_map<std::string, std::unique_ptr<Bridge>> bridges; AdhocCommandsHandler irc_server_adhoc_commands_handler; AdhocCommandsHandler irc_channel_adhoc_commands_handler; BiboumiComponent(const BiboumiComponent&) = delete; BiboumiComponent(BiboumiComponent&&) = delete; BiboumiComponent& operator=(const BiboumiComponent&) = delete; BiboumiComponent& operator=(BiboumiComponent&&) = delete; }; #endif // BIBOUMI_COMPONENT_INCLUDED