summaryrefslogtreecommitdiff
path: root/include/tgbot/EventBroadcaster.h
diff options
context:
space:
mode:
Diffstat (limited to 'include/tgbot/EventBroadcaster.h')
-rw-r--r--include/tgbot/EventBroadcaster.h238
1 files changed, 119 insertions, 119 deletions
diff --git a/include/tgbot/EventBroadcaster.h b/include/tgbot/EventBroadcaster.h
index 0a4ebe9..d879ab4 100644
--- a/include/tgbot/EventBroadcaster.h
+++ b/include/tgbot/EventBroadcaster.h
@@ -47,127 +47,127 @@ class EventBroadcaster {
friend EventHandler;
public:
- typedef std::function<void (const Message::Ptr)> MessageListener;
- typedef std::function<void (const InlineQuery::Ptr)> InlineQueryListener;
- typedef std::function<void (const ChosenInlineResult::Ptr)> ChosenInlineResultListener;
- typedef std::function<void (const CallbackQuery::Ptr)> CallbackQueryListener;
-
- /**
- * @brief Registers listener which receives all messages which the bot can ever receive.
- * @param listener Listener.
- */
- inline void onAnyMessage(const MessageListener& listener) {
- _onAnyMessageListeners.push_back(listener);
- }
-
- /**
- * @brief Registers listener which receives all messages with commands (messages with leading '/' char).
- * @param commandName Command name which listener can handle.
- * @param listener Listener.
- */
- inline void onCommand(const std::string& commandName, const MessageListener& listener) {
- _onCommandListeners[commandName] = listener;
- }
-
- /**
- * @brief Registers listener which receives all messages with commands (messages with leading '/' char).
- * @param commandsList Commands names which listener can handle.
- * @param listener Listener.
- */
- inline void onCommand(const std::initializer_list<std::string>& commandsList, const MessageListener& listener) {
- for (const auto& command : commandsList)
- {
- _onCommandListeners[command] = listener;
- }
- }
-
- /**
- * @brief Registers listener which receives all messages with commands (messages with leading '/' char) which haven't been handled by other listeners.
- * @param listener Listener.
- */
- inline void onUnknownCommand(const MessageListener& listener) {
- _onUnknownCommandListeners.push_back(listener);
- }
-
- /**
- * @brief Registers listener which receives all messages without commands (messages with no leading '/' char)
- * @param listener Listener.
- */
- inline void onNonCommandMessage(const MessageListener& listener) {
- _onNonCommandMessageListeners.push_back(listener);
- }
-
- /**
- * @brief Registers listener which receives all the inline query.
- * @param listener Listener.
- */
- inline void onInlineQuery(const InlineQueryListener& listener) {
- _onInlineQueryListeners.push_back(listener);
- }
-
- /**
- * @brief Registers listener which receives all the chosen inline result.
- * @param listener Listener.
- */
- inline void onChosenInlineResult(const ChosenInlineResultListener& listener){
- _onChosenInlineResultListeners.push_back(listener);
- }
-
- inline void onCallbackQuery(const CallbackQueryListener& listener){
- _onCallbackQueryListeners.push_back(listener);
- }
+ typedef std::function<void (const Message::Ptr)> MessageListener;
+ typedef std::function<void (const InlineQuery::Ptr)> InlineQueryListener;
+ typedef std::function<void (const ChosenInlineResult::Ptr)> ChosenInlineResultListener;
+ typedef std::function<void (const CallbackQuery::Ptr)> CallbackQueryListener;
+
+ /**
+ * @brief Registers listener which receives all messages which the bot can ever receive.
+ * @param listener Listener.
+ */
+ inline void onAnyMessage(const MessageListener& listener) {
+ _onAnyMessageListeners.push_back(listener);
+ }
+
+ /**
+ * @brief Registers listener which receives all messages with commands (messages with leading '/' char).
+ * @param commandName Command name which listener can handle.
+ * @param listener Listener.
+ */
+ inline void onCommand(const std::string& commandName, const MessageListener& listener) {
+ _onCommandListeners[commandName] = listener;
+ }
+
+ /**
+ * @brief Registers listener which receives all messages with commands (messages with leading '/' char).
+ * @param commandsList Commands names which listener can handle.
+ * @param listener Listener.
+ */
+ inline void onCommand(const std::initializer_list<std::string>& commandsList, const MessageListener& listener) {
+ for (const auto& command : commandsList)
+ {
+ _onCommandListeners[command] = listener;
+ }
+ }
+
+ /**
+ * @brief Registers listener which receives all messages with commands (messages with leading '/' char) which haven't been handled by other listeners.
+ * @param listener Listener.
+ */
+ inline void onUnknownCommand(const MessageListener& listener) {
+ _onUnknownCommandListeners.push_back(listener);
+ }
+
+ /**
+ * @brief Registers listener which receives all messages without commands (messages with no leading '/' char)
+ * @param listener Listener.
+ */
+ inline void onNonCommandMessage(const MessageListener& listener) {
+ _onNonCommandMessageListeners.push_back(listener);
+ }
+
+ /**
+ * @brief Registers listener which receives all the inline query.
+ * @param listener Listener.
+ */
+ inline void onInlineQuery(const InlineQueryListener& listener) {
+ _onInlineQueryListeners.push_back(listener);
+ }
+
+ /**
+ * @brief Registers listener which receives all the chosen inline result.
+ * @param listener Listener.
+ */
+ inline void onChosenInlineResult(const ChosenInlineResultListener& listener){
+ _onChosenInlineResultListeners.push_back(listener);
+ }
+
+ inline void onCallbackQuery(const CallbackQueryListener& listener){
+ _onCallbackQueryListeners.push_back(listener);
+ }
private:
- template<typename ListenerType, typename ObjectType>
- inline void broadcast(const std::vector<ListenerType>& listeners, const ObjectType object) const {
- if (!object)
- return;
-
- for (const ListenerType& item : listeners) {
- item(object);
- }
- }
-
- inline void broadcastAnyMessage(const Message::Ptr message) const {
- broadcast<MessageListener, Message::Ptr>(_onAnyMessageListeners, message);
- }
-
- inline bool broadcastCommand(const std::string command, const Message::Ptr message) const {
- std::unordered_map<std::string, MessageListener>::const_iterator iter = _onCommandListeners.find(command);
- if (iter == _onCommandListeners.end()) {
- return false;
- }
- iter->second(message);
- return true;
- }
-
- inline void broadcastUnknownCommand(const Message::Ptr message) const {
- broadcast<MessageListener, Message::Ptr>(_onUnknownCommandListeners, message);
- }
-
- inline void broadcastNonCommandMessage(const Message::Ptr message) const {
- broadcast<MessageListener, Message::Ptr>(_onNonCommandMessageListeners, message);
- }
-
- inline void broadcastInlineQuery(const InlineQuery::Ptr query) const {
- broadcast<InlineQueryListener, InlineQuery::Ptr>(_onInlineQueryListeners, query);
- }
-
- inline void broadcastChosenInlineResult(const ChosenInlineResult::Ptr result) const {
- broadcast<ChosenInlineResultListener, ChosenInlineResult::Ptr>(_onChosenInlineResultListeners, result);
- }
-
- inline void broadcastCallbackQuery(const CallbackQuery::Ptr result) const {
- broadcast<CallbackQueryListener, CallbackQuery::Ptr>(_onCallbackQueryListeners, result);
- }
-
- std::vector<MessageListener> _onAnyMessageListeners;
- std::unordered_map<std::string, MessageListener> _onCommandListeners;
- std::vector<MessageListener> _onUnknownCommandListeners;
- std::vector<MessageListener> _onNonCommandMessageListeners;
- std::vector<InlineQueryListener> _onInlineQueryListeners;
- std::vector<ChosenInlineResultListener> _onChosenInlineResultListeners;
- std::vector<CallbackQueryListener> _onCallbackQueryListeners;
+ template<typename ListenerType, typename ObjectType>
+ inline void broadcast(const std::vector<ListenerType>& listeners, const ObjectType object) const {
+ if (!object)
+ return;
+
+ for (const ListenerType& item : listeners) {
+ item(object);
+ }
+ }
+
+ inline void broadcastAnyMessage(const Message::Ptr message) const {
+ broadcast<MessageListener, Message::Ptr>(_onAnyMessageListeners, message);
+ }
+
+ inline bool broadcastCommand(const std::string command, const Message::Ptr message) const {
+ std::unordered_map<std::string, MessageListener>::const_iterator iter = _onCommandListeners.find(command);
+ if (iter == _onCommandListeners.end()) {
+ return false;
+ }
+ iter->second(message);
+ return true;
+ }
+
+ inline void broadcastUnknownCommand(const Message::Ptr message) const {
+ broadcast<MessageListener, Message::Ptr>(_onUnknownCommandListeners, message);
+ }
+
+ inline void broadcastNonCommandMessage(const Message::Ptr message) const {
+ broadcast<MessageListener, Message::Ptr>(_onNonCommandMessageListeners, message);
+ }
+
+ inline void broadcastInlineQuery(const InlineQuery::Ptr query) const {
+ broadcast<InlineQueryListener, InlineQuery::Ptr>(_onInlineQueryListeners, query);
+ }
+
+ inline void broadcastChosenInlineResult(const ChosenInlineResult::Ptr result) const {
+ broadcast<ChosenInlineResultListener, ChosenInlineResult::Ptr>(_onChosenInlineResultListeners, result);
+ }
+
+ inline void broadcastCallbackQuery(const CallbackQuery::Ptr result) const {
+ broadcast<CallbackQueryListener, CallbackQuery::Ptr>(_onCallbackQueryListeners, result);
+ }
+
+ std::vector<MessageListener> _onAnyMessageListeners;
+ std::unordered_map<std::string, MessageListener> _onCommandListeners;
+ std::vector<MessageListener> _onUnknownCommandListeners;
+ std::vector<MessageListener> _onNonCommandMessageListeners;
+ std::vector<InlineQueryListener> _onInlineQueryListeners;
+ std::vector<ChosenInlineResultListener> _onChosenInlineResultListeners;
+ std::vector<CallbackQueryListener> _onCallbackQueryListeners;
};
}
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-01 14:14:32 +0000