#include "tgbot/Api.h" #include #include namespace TgBot { Api::Api(std::string token, const HttpClient& httpClient, const std::string& url) : _token(std::move(token)), _httpClient(httpClient), _tgTypeParser(), _url(url) { } std::vector Api::getUpdates(std::int32_t offset, std::int32_t limit, std::int32_t timeout, const StringArrayPtr& allowedUpdates) const { std::vector args; args.reserve(4); if (offset != 0) { args.emplace_back("offset", offset); } if (limit != 100) { args.emplace_back("limit", std::max(1, std::min(100, limit))); } if (timeout != 0) { args.emplace_back("timeout", timeout); } if (allowedUpdates != nullptr) { std::string allowedUpdatesJson = _tgTypeParser.parseArray( [] (const std::string& s)->std::string { return s; }, *allowedUpdates); args.emplace_back("allowed_updates", allowedUpdatesJson); } return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetUpdate, sendRequest("getUpdates", args)); } bool Api::setWebhook(const std::string& url, InputFile::Ptr certificate, std::int32_t maxConnections, const StringArrayPtr& allowedUpdates, const std::string& ipAddress, bool dropPendingUpdates, const std::string& secretToken) const { std::vector args; args.reserve(7); args.emplace_back("url", url); if (certificate != nullptr) { args.emplace_back("certificate", certificate->data, true, certificate->mimeType, certificate->fileName); } if (!ipAddress.empty()) { args.emplace_back("ip_address", ipAddress); } if (maxConnections != 40) { args.emplace_back("max_connections", std::max(1, std::min(100, maxConnections))); } if (allowedUpdates != nullptr) { auto allowedUpdatesJson = _tgTypeParser.parseArray( [] (const std::string& s)->std::string { return s; }, *allowedUpdates); args.emplace_back("allowed_updates", allowedUpdatesJson); } if (dropPendingUpdates) { args.emplace_back("drop_pending_updates", dropPendingUpdates); } if (!secretToken.empty()) { args.emplace_back("secret_token", secretToken); } return sendRequest("setWebhook", args).get("", false); } bool Api::deleteWebhook(bool dropPendingUpdates) const { std::vector args; args.reserve(1); if (dropPendingUpdates) { args.emplace_back("drop_pending_updates", dropPendingUpdates); } return sendRequest("deleteWebhook", args).get("", false); } WebhookInfo::Ptr Api::getWebhookInfo() const { boost::property_tree::ptree p = sendRequest("getWebhookInfo"); if (!p.get_child_optional("url")) { return nullptr; } if (p.get("url", "") != std::string("")) { return _tgTypeParser.parseJsonAndGetWebhookInfo(p); } else { return nullptr; } } User::Ptr Api::getMe() const { return _tgTypeParser.parseJsonAndGetUser(sendRequest("getMe")); } bool Api::logOut() const { return sendRequest("logOut").get("", false); } bool Api::close() const { return sendRequest("close").get("", false); } Message::Ptr Api::sendMessage(boost::variant chatId, const std::string& text, bool disableWebPagePreview, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& entities, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(11); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("text", text); if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!entities.empty()) { args.emplace_back("entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, entities)); } if (disableWebPagePreview) { args.emplace_back("disable_web_page_preview", disableWebPagePreview); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendMessage", args)); } Message::Ptr Api::forwardMessage(boost::variant chatId, boost::variant fromChatId, std::int32_t messageId, bool disableNotification, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(6); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("from_chat_id", fromChatId); if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } args.emplace_back("message_id", messageId); return _tgTypeParser.parseJsonAndGetMessage(sendRequest("forwardMessage", args)); } MessageId::Ptr Api::copyMessage(boost::variant chatId, boost::variant fromChatId, std::int32_t messageId, const std::string& caption, const std::string& parseMode, const std::vector& captionEntities, bool disableNotification, std::int32_t replyToMessageId, bool allowSendingWithoutReply, GenericReply::Ptr replyMarkup, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(12); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("from_chat_id", fromChatId); args.emplace_back("message_id", messageId); if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessageId(sendRequest("copyMessage", args)); } Message::Ptr Api::sendPhoto(boost::variant chatId, boost::variant photo, const std::string& caption, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& captionEntities, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId, bool hasSpoiler) const { std::vector args; args.reserve(12); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (photo.which() == 0) { // InputFile::Ptr auto file = boost::get(photo); args.emplace_back("photo", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("photo", boost::get(photo)); } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (hasSpoiler) { args.emplace_back("has_spoiler", hasSpoiler); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup != nullptr) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendPhoto", args)); } Message::Ptr Api::sendAudio(boost::variant chatId, boost::variant audio, const std::string& caption, std::int32_t duration, const std::string& performer, const std::string& title, boost::variant thumb, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& captionEntities, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(15); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (audio.which() == 0) { // InputFile::Ptr auto file = boost::get(audio); args.emplace_back("audio", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("audio", boost::get(audio)); } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (duration) { args.emplace_back("duration", duration); } if (!performer.empty()) { args.emplace_back("performer", performer); } if (!title.empty()) { args.emplace_back("title", title); } if (thumb.which() == 0) { // InputFile::Ptr auto file = boost::get(thumb); args.emplace_back("thumb", file->data, true, file->mimeType, file->fileName); } else { // std::string auto thumbStr = boost::get(thumb); if (!thumbStr.empty()) { args.emplace_back("thumb", thumbStr); } } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendAudio", args)); } Message::Ptr Api::sendDocument(boost::variant chatId, boost::variant document, boost::variant thumb, const std::string& caption, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& captionEntities, bool disableContentTypeDetection, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(13); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (document.which() == 0) { // InputFile::Ptr auto file = boost::get(document); args.emplace_back("document", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("document", boost::get(document)); } if (thumb.which() == 0) { // InputFile::Ptr auto file = boost::get(thumb); args.emplace_back("thumb", file->data, true, file->mimeType, file->fileName); } else { // std::string auto thumbStr = boost::get(thumb); if (!thumbStr.empty()) { args.emplace_back("thumb", thumbStr); } } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (disableContentTypeDetection) { args.emplace_back("disable_content_type_detection", disableContentTypeDetection); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendDocument", args)); } Message::Ptr Api::sendVideo(boost::variant chatId, boost::variant video, bool supportsStreaming, std::int32_t duration, std::int32_t width, std::int32_t height, boost::variant thumb, const std::string& caption , std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& captionEntities, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId, bool hasSpoiler) const { std::vector args; args.reserve(17); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (video.which() == 0) { // InputFile::Ptr auto file = boost::get(video); args.emplace_back("video", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("video", boost::get(video)); } if (duration != 0) { args.emplace_back("duration", duration); } if (width != 0) { args.emplace_back("width", width); } if (height != 0) { args.emplace_back("height", height); } if (thumb.which() == 0) { // InputFile::Ptr auto file = boost::get(thumb); args.emplace_back("thumb", file->data, true, file->mimeType, file->fileName); } else { // std::string auto thumbStr = boost::get(thumb); if (!thumbStr.empty()) { args.emplace_back("thumb", thumbStr); } } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (hasSpoiler) { args.emplace_back("has_spoiler", hasSpoiler); } if (supportsStreaming) { args.emplace_back("supports_streaming", supportsStreaming); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup != nullptr) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendVideo", args)); } Message::Ptr Api::sendAnimation(boost::variant chatId, boost::variant animation, std::int32_t duration, std::int32_t width, std::int32_t height, boost::variant thumb, const std::string& caption, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& captionEntities, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId, bool hasSpoiler ) const { std::vector args; args.reserve(16); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (animation.which() == 0) { // InputFile::Ptr auto file = boost::get(animation); args.emplace_back("animation", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("animation", boost::get(animation)); } if (duration != 0) { args.emplace_back("duration", duration); } if (width != 0) { args.emplace_back("width", width); } if (height != 0) { args.emplace_back("height", height); } if (thumb.which() == 0) { // InputFile::Ptr auto file = boost::get(thumb); args.emplace_back("thumb", file->data, true, file->mimeType, file->fileName); } else { // std::string auto thumbStr = boost::get(thumb); if (!thumbStr.empty()) { args.emplace_back("thumb", thumbStr); } } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (hasSpoiler) { args.emplace_back("has_spoiler", hasSpoiler); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup != nullptr) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendAnimation", args)); } Message::Ptr Api::sendVoice(boost::variant chatId, boost::variant voice, const std::string& caption, std::int32_t duration, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, bool disableNotification, const std::vector& captionEntities, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(12); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (voice.which() == 0) { // InputFile::Ptr auto file = boost::get(voice); args.emplace_back("voice", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("voice", boost::get(voice)); } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (duration) { args.emplace_back("duration", duration); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendVoice", args)); } Message::Ptr Api::sendVideoNote(boost::variant chatId, boost::variant videoNote, std::int64_t replyToMessageId, bool disableNotification, std::int32_t duration, std::int32_t length, boost::variant thumb, GenericReply::Ptr replyMarkup, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(11); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (videoNote.which() == 0) { // InputFile::Ptr auto file = boost::get(videoNote); args.emplace_back("video_note", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("video_note", boost::get(videoNote)); } if (duration) { args.emplace_back("duration", duration); } if (length) { args.emplace_back("length", length); } if (thumb.which() == 0) { // InputFile::Ptr auto file = boost::get(thumb); args.emplace_back("thumb", file->data, true, file->mimeType, file->fileName); } else { // std::string auto thumbStr = boost::get(thumb); if (!thumbStr.empty()) { args.emplace_back("thumb", thumbStr); } } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendVideoNote", args)); } std::vector Api::sendMediaGroup(boost::variant chatId, const std::vector& media, bool disableNotification, std::int32_t replyToMessageId, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(7); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("media", _tgTypeParser.parseArray(&TgTypeParser::parseInputMedia, media)); if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetMessage, sendRequest("sendMediaGroup", args)); } Message::Ptr Api::sendLocation(boost::variant chatId, float latitude, float longitude, std::int32_t livePeriod, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, bool disableNotification, float horizontalAccuracy, std::int32_t heading, std::int32_t proximityAlertRadius, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(13); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("latitude", latitude); args.emplace_back("longitude", longitude); if (horizontalAccuracy) { args.emplace_back("horizontal_accuracy", horizontalAccuracy); } if (livePeriod) { args.emplace_back("live_period", std::max(60, std::min(86400, livePeriod))); } if (heading) { args.emplace_back("heading", std::max(1, std::min(360, heading))); } if (proximityAlertRadius) { args.emplace_back("proximity_alert_radius", std::max(1, std::min(100000, proximityAlertRadius))); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendLocation", args)); } Message::Ptr Api::editMessageLiveLocation(float latitude, float longitude, boost::variant chatId, std::int32_t messageId, const std::string& inlineMessageId, InlineKeyboardMarkup::Ptr replyMarkup, float horizontalAccuracy, std::int32_t heading, std::int32_t proximityAlertRadius) const { std::vector args; args.reserve(9); if ((boost::get(chatId) != 0) || (boost::get(chatId) != "")) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } args.emplace_back("latitude", latitude); args.emplace_back("longitude", longitude); if (horizontalAccuracy) { args.emplace_back("horizontal_accuracy", horizontalAccuracy); } if (heading) { args.emplace_back("heading", heading); } if (proximityAlertRadius) { args.emplace_back("proximity_alert_radius", proximityAlertRadius); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseInlineKeyboardMarkup(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("editMessageLiveLocation", args)); } Message::Ptr Api::stopMessageLiveLocation(boost::variant chatId, std::int32_t messageId, const std::string& inlineMessageId, InlineKeyboardMarkup::Ptr replyMarkup) const { std::vector args; args.reserve(4); if ((boost::get(chatId) != 0) || (boost::get(chatId) != "")) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseInlineKeyboardMarkup(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("stopMessageLiveLocation", args)); } Message::Ptr Api::sendVenue(boost::variant chatId, float latitude, float longitude, const std::string& title, const std::string& address, const std::string& foursquareId, const std::string& foursquareType, bool disableNotification, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& googlePlaceId, const std::string& googlePlaceType, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(15); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("latitude", latitude); args.emplace_back("longitude", longitude); args.emplace_back("title", title); args.emplace_back("address", address); if (!foursquareId.empty()) { args.emplace_back("foursquare_id", foursquareId); } if (!foursquareType.empty()) { args.emplace_back("foursquare_type", foursquareType); } if (!googlePlaceId.empty()) { args.emplace_back("google_place_id", googlePlaceId); } if (!googlePlaceType.empty()) { args.emplace_back("google_place_type", googlePlaceType); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendVenue", args)); } Message::Ptr Api::sendContact(boost::variant chatId, const std::string& phoneNumber, const std::string& firstName, const std::string& lastName , const std::string& vcard, bool disableNotification, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(11); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("phone_number", phoneNumber); args.emplace_back("first_name", firstName); if (!lastName.empty()) { args.emplace_back("last_name", lastName); } if (!vcard.empty()) { args.emplace_back("vcard", vcard); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendContact", args)); } Message::Ptr Api::sendPoll(boost::variant chatId, const std::string& question, const std::vector& options, bool disableNotification, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, bool isAnonymous, const std::string& type, bool allowsMultipleAnswers, std::int32_t correctOptionId, const std::string& explanation, const std::string& explanationParseMode, const std::vector& explanationEntities, std::int32_t openPeriod, std::int32_t closeDate, bool isClosed, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(19); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("question", question); args.emplace_back("options", _tgTypeParser.parseArray( [](const std::string& option)->std::string { return "\"" + StringTools::escapeJsonString(option) + "\""; }, options)); if (!isAnonymous) { args.emplace_back("is_anonymous", isAnonymous); } if (!type.empty()) { args.emplace_back("type", type); } if (allowsMultipleAnswers) { args.emplace_back("allows_multiple_answers", allowsMultipleAnswers); } if (correctOptionId != -1) { args.emplace_back("correct_option_id", correctOptionId); } if (!explanation.empty()) { args.emplace_back("explanation", explanation); } if (!explanationParseMode.empty()) { args.emplace_back("explanation_parse_mode", explanationParseMode); } if (!explanationEntities.empty()) { args.emplace_back("explanation_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, explanationEntities)); } if (openPeriod != 0) { args.emplace_back("open_period", openPeriod); } if (closeDate != 0) { args.emplace_back("close_date", closeDate); } if (isClosed) { args.emplace_back("is_closed", isClosed); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendPoll", args)); } Message::Ptr Api::sendDice(boost::variant chatId, bool disableNotification, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, const std::string& emoji, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(8); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (!emoji.empty()) { args.emplace_back("emoji", emoji); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId != 0) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendDice", args)); } bool Api::sendChatAction(std::int64_t chatId, const std::string& action, std::int32_t messageThreadId) const { std::vector args; args.reserve(3); args.emplace_back("chat_id", chatId); args.emplace_back("action", action); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } return sendRequest("sendChatAction", args).get("", false); } UserProfilePhotos::Ptr Api::getUserProfilePhotos(std::int64_t userId, std::int32_t offset, std::int32_t limit) const { std::vector args; args.reserve(3); args.emplace_back("user_id", userId); if (offset) { args.emplace_back("offset", offset); } if (limit != 100) { args.emplace_back("limit", std::max(1, std::min(100, limit))); } return _tgTypeParser.parseJsonAndGetUserProfilePhotos(sendRequest("getUserProfilePhotos", args)); } File::Ptr Api::getFile(const std::string& fileId) const { std::vector args; args.reserve(1); args.emplace_back("file_id", fileId); return _tgTypeParser.parseJsonAndGetFile(sendRequest("getFile", args)); } bool Api::banChatMember(boost::variant chatId, std::int64_t userId, std::int32_t untilDate, bool revokeMessages) const { std::vector args; args.reserve(4); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); if (untilDate != 0) { args.emplace_back("until_date", untilDate); } if (revokeMessages) { args.emplace_back("revoke_messages", revokeMessages); } return sendRequest("banChatMember", args).get("", false); } bool Api::unbanChatMember(boost::variant chatId, std::int64_t userId, bool onlyIfBanned) const { std::vector args; args.reserve(3); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); if (onlyIfBanned) { args.emplace_back("only_if_banned", onlyIfBanned); } return sendRequest("unbanChatMember", args).get("", false); } bool Api::restrictChatMember(boost::variant chatId, std::int64_t userId, TgBot::ChatPermissions::Ptr permissions, std::int64_t untilDate) const { std::vector args; args.reserve(4); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); args.emplace_back("permissions", _tgTypeParser.parseChatPermissions(permissions)); if (untilDate) { args.emplace_back("until_date", untilDate); } return sendRequest("restrictChatMember", args).get("", false); } bool Api::promoteChatMember(boost::variant chatId, std::int64_t userId, bool canChangeInfo, bool canPostMessages, bool canEditMessages, bool canDeleteMessages, bool canInviteUsers, bool canPinMessages, bool canPromoteMembers, bool isAnonymous, bool canManageChat, bool canManageVideoChats, bool canRestrictMembers, bool canManageTopics) const { std::vector args; args.reserve(14); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); if (isAnonymous) { args.emplace_back("is_anonymous", isAnonymous); } if (canManageChat) { args.emplace_back("can_manage_chat", canManageChat); } if (canPostMessages) { args.emplace_back("can_post_messages", canPostMessages); } if (canEditMessages) { args.emplace_back("can_edit_messages", canEditMessages); } if (canDeleteMessages) { args.emplace_back("can_delete_messages", canDeleteMessages); } if (canManageVideoChats) { args.emplace_back("can_manage_video_chats", canManageVideoChats); } if (canRestrictMembers) { args.emplace_back("can_restrict_members", canRestrictMembers); } if (canPromoteMembers) { args.emplace_back("can_promote_members", canPromoteMembers); } if (canChangeInfo) { args.emplace_back("can_change_info", canChangeInfo); } if (canInviteUsers) { args.emplace_back("can_invite_users", canInviteUsers); } if (canPinMessages) { args.emplace_back("can_pin_messages", canPinMessages); } if (canManageTopics) { args.emplace_back("can_manage_topics", canManageTopics); } return sendRequest("promoteChatMember", args).get("", false); } bool Api::setChatAdministratorCustomTitle(boost::variant chatId, std::int64_t userId, const std::string& customTitle) const { std::vector args; args.reserve(3); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); args.emplace_back("custom_title", customTitle); return sendRequest("setChatAdministratorCustomTitle", args).get("", false); } bool Api::banChatSenderChat(boost::variant chatId, std::int64_t senderChatId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("sender_chat_id", senderChatId); return sendRequest("banChatSenderChat", args).get("", false); } bool Api::unbanChatSenderChat(boost::variant chatId, std::int64_t senderChatId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("sender_chat_id", senderChatId); return sendRequest("unbanChatSenderChat", args).get("", false); } bool Api::setChatPermissions(boost::variant chatId, ChatPermissions::Ptr permissions) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("permissions", _tgTypeParser.parseChatPermissions(permissions)); return sendRequest("setChatPermissions", args).get("", false); } std::string Api::exportChatInviteLink(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("exportChatInviteLink", args).get("", ""); } ChatInviteLink::Ptr Api::createChatInviteLink(boost::variant chatId, std::int32_t expireDate, std::int32_t memberLimit, const std::string& name, bool createsJoinRequest) const { std::vector args; args.reserve(5); args.emplace_back("chat_id", chatId); if (!name.empty()) { args.emplace_back("name", name); } if (expireDate != 0) { args.emplace_back("expire_date", expireDate); } if (memberLimit != 0) { args.emplace_back("member_limit", memberLimit); } if (createsJoinRequest) { args.emplace_back("createsJoinRequest", createsJoinRequest); } return _tgTypeParser.parseJsonAndGetChatInviteLink(sendRequest("createChatInviteLink", args)); } ChatInviteLink::Ptr Api::editChatInviteLink(boost::variant chatId, const std::string& inviteLink, std::int32_t expireDate, std::int32_t memberLimit, const std::string& name, bool createsJoinRequest) const { std::vector args; args.reserve(6); args.emplace_back("chat_id", chatId); args.emplace_back("invite_link", inviteLink); if (!name.empty()) { args.emplace_back("name", name); } if (expireDate != 0) { args.emplace_back("expire_date", expireDate); } if (memberLimit != 0) { args.emplace_back("member_limit", memberLimit); } if (createsJoinRequest) { args.emplace_back("createsJoinRequest", createsJoinRequest); } return _tgTypeParser.parseJsonAndGetChatInviteLink(sendRequest("editChatInviteLink", args)); } ChatInviteLink::Ptr Api::revokeChatInviteLink(boost::variant chatId, const std::string& inviteLink) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("invite_link", inviteLink); return _tgTypeParser.parseJsonAndGetChatInviteLink(sendRequest("revokeChatInviteLink", args)); } bool Api::approveChatJoinRequest(boost::variant chatId, std::int64_t userId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); return sendRequest("approveChatJoinRequest", args).get("", false); } bool Api::declineChatJoinRequest(boost::variant chatId, std::int64_t userId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); return sendRequest("declineChatJoinRequest", args).get("", false); } bool Api::setChatPhoto(boost::variant chatId, const InputFile::Ptr photo) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("photo", photo->data, true, photo->mimeType, photo->fileName); return sendRequest("setChatPhoto", args).get("", false); } bool Api::deleteChatPhoto(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("deleteChatPhoto", args).get("", false); } bool Api::setChatTitle(boost::variant chatId, const std::string& title) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("title", title); return sendRequest("setChatTitle", args).get("", false); } bool Api::setChatDescription(boost::variant chatId, const std::string& description) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); if (!description.empty()) { args.emplace_back("description", description); } return sendRequest("setChatDescription", args).get("", false); } bool Api::pinChatMessage(boost::variant chatId, std::int32_t messageId, bool disableNotification) const { std::vector args; args.reserve(3); args.emplace_back("chat_id", chatId); args.emplace_back("message_id", messageId); if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } return sendRequest("pinChatMessage", args).get("", false); } bool Api::unpinChatMessage(boost::variant chatId, std::int32_t messageId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); if (messageId != 0) { args.emplace_back("message_id", messageId); } return sendRequest("unpinChatMessage", args).get("", false); } bool Api::unpinAllChatMessages(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("unpinAllChatMessages", args).get("", false); } bool Api::leaveChat(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("leaveChat", args).get("", false); } Chat::Ptr Api::getChat(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return _tgTypeParser.parseJsonAndGetChat(sendRequest("getChat", args)); } std::vector Api::getChatAdministrators(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetChatMember, sendRequest("getChatAdministrators", args)); } int32_t Api::getChatMemberCount(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("getChatMemberCount", args).get("", 0); } ChatMember::Ptr Api::getChatMember(boost::variant chatId, std::int64_t userId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("user_id", userId); return _tgTypeParser.parseJsonAndGetChatMember(sendRequest("getChatMember", args)); } bool Api::setChatStickerSet(boost::variant chatId, const std::string& stickerSetName) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("sticker_set_name ", stickerSetName); return sendRequest("setChatStickerSet", args).get("", false); } bool Api::deleteChatStickerSet(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("deleteChatStickerSet", args).get("", false); } std::vector Api::getForumTopicIconStickers() const { return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetSticker, sendRequest("getForumTopicIconStickers")); } ForumTopic::Ptr Api::createForumTopic(boost::variant chatId, const std::string& name, std::int32_t iconColor, const std::string& iconCustomEmojiId) const { std::vector args; args.reserve(4); args.emplace_back("chat_id", chatId); args.emplace_back("name", name); if (iconColor != 0) { args.emplace_back("icon_color", iconColor); } if (!iconCustomEmojiId.empty()) { args.emplace_back("icon_custom_emoji_id", iconCustomEmojiId); } return _tgTypeParser.parseJsonAndGetForumTopic(sendRequest("createForumTopic", args)); } bool Api::editForumTopic(boost::variant chatId, std::int32_t messageThreadId, const std::string& name, boost::variant iconCustomEmojiId) const { std::vector args; args.reserve(4); args.emplace_back("chat_id", chatId); args.emplace_back("message_thread_id", messageThreadId); if (!name.empty()) { args.emplace_back("name", name); } if (iconCustomEmojiId.which() == 1) { // std::string args.emplace_back("icon_custom_emoji_id", boost::get(iconCustomEmojiId)); } return sendRequest("editForumTopic", args).get("", false); } bool Api::closeForumTopic(boost::variant chatId, std::int32_t messageThreadId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("message_thread_id", messageThreadId); return sendRequest("closeForumTopic", args).get("", false); } bool Api::reopenForumTopic(boost::variant chatId, std::int32_t messageThreadId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("message_thread_id", messageThreadId); return sendRequest("reopenForumTopic", args).get("", false); } bool Api::deleteForumTopic(boost::variant chatId, std::int32_t messageThreadId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("message_thread_id", messageThreadId); return sendRequest("deleteForumTopic", args).get("", false); } bool Api::unpinAllForumTopicMessages(boost::variant chatId, std::int32_t messageThreadId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("message_thread_id", messageThreadId); return sendRequest("unpinAllForumTopicMessages", args).get("", false); } bool Api::editGeneralForumTopic(boost::variant chatId, std::string name) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("name", name); return sendRequest("editGeneralForumTopic", args).get("", false); } bool Api::closeGeneralForumTopic(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("closeGeneralForumTopic", args).get("", false); } bool Api::reopenGeneralForumTopic(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("reopenGeneralForumTopic", args).get("", false); } bool Api::hideGeneralForumTopic(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("hideGeneralForumTopic", args).get("", false); } bool Api::unhideGeneralForumTopic(boost::variant chatId) const { std::vector args; args.reserve(1); args.emplace_back("chat_id", chatId); return sendRequest("unhideGeneralForumTopic", args).get("", false); } bool Api::answerCallbackQuery(const std::string& callbackQueryId, const std::string& text, bool showAlert, const std::string& url, std::int32_t cacheTime) const { std::vector args; args.reserve(5); args.emplace_back("callback_query_id", callbackQueryId); if (!text.empty()) { args.emplace_back("text", text); } if (showAlert) { args.emplace_back("show_alert", showAlert); } if (!url.empty()) { args.emplace_back("url", url); } if (cacheTime) { args.emplace_back("cache_time", cacheTime); } return sendRequest("answerCallbackQuery", args).get("", false); } bool Api::setMyCommands(const std::vector& commands, BotCommandScope::Ptr scope, const std::string& languageCode) const { std::vector args; args.reserve(3); args.emplace_back("commands", _tgTypeParser.parseArray(&TgTypeParser::parseBotCommand, commands)); if (scope != nullptr) { args.emplace_back("scope", _tgTypeParser.parseBotCommandScope(scope)); } if (!languageCode.empty()) { args.emplace_back("language_code", languageCode); } return sendRequest("setMyCommands", args).get("", false); } bool Api::deleteMyCommands(BotCommandScope::Ptr scope, const std::string& languageCode) const { std::vector args; args.reserve(2); if (scope != nullptr) { args.emplace_back("scope", _tgTypeParser.parseBotCommandScope(scope)); } if (!languageCode.empty()) { args.emplace_back("language_code", languageCode); } return sendRequest("deleteMyCommands", args).get("", false); } std::vector Api::getMyCommands(BotCommandScope::Ptr scope, const std::string& languageCode) const { std::vector args; args.reserve(2); ; if (scope != nullptr) { args.emplace_back("scope", _tgTypeParser.parseBotCommandScope(scope)); } if (!languageCode.empty()) { args.emplace_back("language_code", languageCode); } return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetBotCommand, sendRequest("getMyCommands", args)); } bool Api::setChatMenuButton(std::int64_t chatId, MenuButton::Ptr menuButton) const { std::vector args; args.reserve(2); if (chatId != 0) { args.emplace_back("chat_id", chatId); } if (menuButton != nullptr) { args.emplace_back("menu_button", _tgTypeParser.parseMenuButton(menuButton)); } return sendRequest("setChatMenuButton", args).get("", false); } MenuButton::Ptr Api::getChatMenuButton(std::int64_t chatId) const { std::vector args; args.reserve(1); if (chatId != 0) { args.emplace_back("chat_id", chatId); } return _tgTypeParser.parseJsonAndGetMenuButton(sendRequest("getChatMenuButton", args)); } bool Api::setMyDefaultAdministratorRights(ChatAdministratorRights::Ptr rights, bool forChannels) const { std::vector args; args.reserve(2); if (rights != nullptr) { args.emplace_back("rights", _tgTypeParser.parseChatAdministratorRights(rights)); } if (forChannels) { args.emplace_back("for_channels", forChannels); } return sendRequest("setMyDefaultAdministratorRights", args).get("", false); } ChatAdministratorRights::Ptr Api::getMyDefaultAdministratorRights(bool forChannels) const { std::vector args; args.reserve(1); if (forChannels) { args.emplace_back("for_channels", forChannels); } return _tgTypeParser.parseJsonAndGetChatAdministratorRights(sendRequest("getMyDefaultAdministratorRights", args)); } Message::Ptr Api::editMessageText(const std::string& text, boost::variant chatId, std::int32_t messageId, const std::string& inlineMessageId, const std::string& parseMode, bool disableWebPagePreview, GenericReply::Ptr replyMarkup, const std::vector& entities) const { std::vector args; args.reserve(8); if ((boost::get(chatId) != 0) || (boost::get(chatId) != "")) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } args.emplace_back("text", text); if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!entities.empty()) { args.emplace_back("entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, entities)); } if (disableWebPagePreview) { args.emplace_back("disable_web_page_preview", disableWebPagePreview); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } boost::property_tree::ptree p = sendRequest("editMessageText", args); if (p.get_child_optional("message_id")) { return _tgTypeParser.parseJsonAndGetMessage(p); } else { return nullptr; } } Message::Ptr Api::editMessageCaption(boost::variant chatId, std::int32_t messageId, const std::string& caption, const std::string& inlineMessageId, GenericReply::Ptr replyMarkup, const std::string& parseMode, const std::vector& captionEntities) const { std::vector args; args.reserve(7); if ((boost::get(chatId) != 0) || (boost::get(chatId) != "")) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } if (!caption.empty()) { args.emplace_back("caption", caption); } if (!parseMode.empty()) { args.emplace_back("parse_mode", parseMode); } if (!captionEntities.empty()) { args.emplace_back("caption_entities", _tgTypeParser.parseArray(&TgTypeParser::parseMessageEntity, captionEntities)); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } boost::property_tree::ptree p = sendRequest("editMessageCaption", args); if (p.get_child_optional("message_id")) { return _tgTypeParser.parseJsonAndGetMessage(p); } else { return nullptr; } } Message::Ptr Api::editMessageMedia(InputMedia::Ptr media, boost::variant chatId, std::int32_t messageId, const std::string& inlineMessageId, GenericReply::Ptr replyMarkup) const { std::vector args; args.reserve(5); args.emplace_back("media", _tgTypeParser.parseInputMedia(media)); if ((boost::get(chatId) != 0) || (boost::get(chatId) != "")) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } boost::property_tree::ptree p = sendRequest("editMessageMedia", args); if (p.get_child_optional("message_id")) { return _tgTypeParser.parseJsonAndGetMessage(p); } else { return nullptr; } } Message::Ptr Api::editMessageReplyMarkup(boost::variant chatId, std::int32_t messageId, const std::string& inlineMessageId, const GenericReply::Ptr replyMarkup) const { std::vector args; args.reserve(4); if ((boost::get(chatId) != 0) || (boost::get(chatId) != "")) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } boost::property_tree::ptree p = sendRequest("editMessageReplyMarkup", args); if (p.get_child_optional("message_id")) { return _tgTypeParser.parseJsonAndGetMessage(p); } else { return nullptr; } } Poll::Ptr Api::stopPoll(boost::variant chatId, std::int64_t messageId, const InlineKeyboardMarkup::Ptr replyMarkup) const { std::vector args; args.reserve(3); args.emplace_back("chat_id", chatId); args.emplace_back("message_id", messageId); if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetPoll(sendRequest("stopPoll", args)); } bool Api::deleteMessage(boost::variant chatId, std::int32_t messageId) const { std::vector args; args.reserve(2); args.emplace_back("chat_id", chatId); args.emplace_back("message_id", messageId); return sendRequest("deleteMessage", args).get("", false); } Message::Ptr Api::sendSticker(boost::variant chatId, boost::variant sticker, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, bool disableNotification, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(8); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } if (sticker.which() == 0) { // InputFile::Ptr auto file = boost::get(sticker); args.emplace_back("sticker", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("sticker", boost::get(sticker)); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendSticker", args)); } StickerSet::Ptr Api::getStickerSet(const std::string& name) const { std::vector args; args.reserve(1); args.emplace_back("name", name); return _tgTypeParser.parseJsonAndGetStickerSet(sendRequest("getStickerSet", args)); } std::vector Api::getCustomEmojiStickers(const std::vector& customEmojiIds) const { std::vector args; args.reserve(1); args.emplace_back("custom_emoji_ids", _tgTypeParser.parseArray([] (const std::string& customEmojiId) -> std::string { return "\"" + StringTools::escapeJsonString(customEmojiId) + "\""; }, customEmojiIds)); return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetSticker, sendRequest("getCustomEmojiStickers", args)); } File::Ptr Api::uploadStickerFile(std::int64_t userId, const InputFile::Ptr pngSticker) const { std::vector args; args.reserve(2); args.emplace_back("user_id", userId); args.emplace_back("png_sticker", pngSticker->data, true, pngSticker->mimeType, pngSticker->fileName); return _tgTypeParser.parseJsonAndGetFile(sendRequest("uploadStickerFile", args)); } bool Api::createNewStickerSet(std::int64_t userId, const std::string& name, const std::string& title, const std::string& emojis, MaskPosition::Ptr maskPosition, boost::variant pngSticker, InputFile::Ptr tgsSticker, InputFile::Ptr webmSticker, const std::string& stickerType) const { std::vector args; args.reserve(10); args.emplace_back("user_id", userId); args.emplace_back("name", name); args.emplace_back("title", title); if (pngSticker.which() == 0) { // InputFile::Ptr auto file = boost::get(pngSticker); args.emplace_back("png_sticker", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("png_sticker", boost::get(pngSticker)); } if (tgsSticker != nullptr) { args.emplace_back("tgs_sticker", tgsSticker->data, true, tgsSticker->mimeType, tgsSticker->fileName); } if (webmSticker != nullptr) { args.emplace_back("webm_sticker", webmSticker->data, true, webmSticker->mimeType, webmSticker->fileName); } if (!stickerType.empty()) { args.emplace_back("sticker_type", stickerType); } args.emplace_back("emojis", emojis); if (maskPosition != nullptr) { args.emplace_back("mask_position", _tgTypeParser.parseMaskPosition(maskPosition)); } return sendRequest("createNewStickerSet", args).get("", false); } bool Api::addStickerToSet(std::int64_t userId, const std::string& name, const std::string& emojis, MaskPosition::Ptr maskPosition, boost::variant pngSticker, InputFile::Ptr tgsSticker, InputFile::Ptr webmSticker) const { std::vector args; args.reserve(7); args.emplace_back("user_id", userId); args.emplace_back("name", name); if (pngSticker.which() == 0) { // InputFile::Ptr auto file = boost::get(pngSticker); args.emplace_back("png_sticker", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("png_sticker", boost::get(pngSticker)); } if (tgsSticker != nullptr) { args.emplace_back("tgs_sticker", tgsSticker->data, true, tgsSticker->mimeType, tgsSticker->fileName); } if (webmSticker != nullptr) { args.emplace_back("webm_sticker", webmSticker->data, true, webmSticker->mimeType, webmSticker->fileName); } args.emplace_back("emojis", emojis); if (maskPosition != nullptr) { args.emplace_back("mask_position", _tgTypeParser.parseMaskPosition(maskPosition)); } return sendRequest("addStickerToSet", args).get("", false); } bool Api::setStickerPositionInSet(const std::string& sticker, std::int32_t position) const { std::vector args; args.reserve(2); args.emplace_back("sticker", sticker); args.emplace_back("position", position); return sendRequest("setStickerPositionInSet", args).get("", false); } bool Api::deleteStickerFromSet(const std::string& sticker) const { std::vector args; args.reserve(1); args.emplace_back("sticker", sticker); return sendRequest("deleteStickerFromSet", args).get("", false); } bool Api::setStickerSetThumb(const std::string& name, std::int64_t userId, boost::variant thumb) const { std::vector args; args.reserve(3); args.emplace_back("name", name); args.emplace_back("user_id", userId); if (thumb.which() == 0) { // InputFile::Ptr auto file = boost::get(thumb); args.emplace_back("thumb", file->data, true, file->mimeType, file->fileName); } else { // std::string args.emplace_back("thumb", boost::get(thumb)); } return sendRequest("setStickerSetThumb", args).get("", false); } bool Api::answerInlineQuery(const std::string& inlineQueryId, const std::vector& results, std::int32_t cacheTime, bool isPersonal, const std::string& nextOffset, const std::string& switchPmText, const std::string& switchPmParameter) const { std::vector args; args.reserve(7); args.emplace_back("inline_query_id", inlineQueryId); args.emplace_back("results", _tgTypeParser.parseArray(&TgTypeParser::parseInlineQueryResult, results)); if (cacheTime) { args.emplace_back("cache_time", cacheTime); } if (isPersonal) { args.emplace_back("is_personal", isPersonal); } if (!nextOffset.empty()) { args.emplace_back("next_offset", nextOffset); } if (!switchPmText.empty()) { args.emplace_back("switch_pm_text", switchPmText); } if (!switchPmParameter.empty()) { args.emplace_back("switch_pm_parameter", switchPmParameter); } return sendRequest("answerInlineQuery", args).get("", false); } SentWebAppMessage::Ptr Api::answerWebAppQuery(const std::string& webAppQueryId, InlineQueryResult::Ptr result) const { std::vector args; args.reserve(2); args.emplace_back("web_app_query_id", webAppQueryId); args.emplace_back("result", _tgTypeParser.parseInlineQueryResult(result)); return _tgTypeParser.parseJsonAndGetSentWebAppMessage(sendRequest("answerWebAppQuery", args)); } Message::Ptr Api::sendInvoice(boost::variant chatId, const std::string& title, const std::string& description, const std::string& payload, const std::string& providerToken, const std::string& currency, const std::vector& prices, const std::string& providerData, const std::string& photoUrl, std::int32_t photoSize, std::int32_t photoWidth, std::int32_t photoHeight, bool needName, bool needPhoneNumber, bool needEmail, bool needShippingAddress, bool sendPhoneNumberToProvider, bool sendEmailToProvider, bool isFlexible, std::int32_t replyToMessageId, GenericReply::Ptr replyMarkup, bool disableNotification, bool allowSendingWithoutReply, std::int32_t maxTipAmount, const std::vector& suggestedTipAmounts, const std::string& startParameter, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(28); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("title", title); args.emplace_back("description", description); args.emplace_back("payload", payload); args.emplace_back("provider_token", providerToken); args.emplace_back("currency", currency); args.emplace_back("prices", _tgTypeParser.parseArray(&TgTypeParser::parseLabeledPrice, prices)); args.emplace_back("max_tip_amount", maxTipAmount); if (!suggestedTipAmounts.empty()) { args.emplace_back("suggested_tip_amounts", _tgTypeParser.parseArray([] (const std::int32_t& option) -> std::int32_t { return option; }, suggestedTipAmounts)); } if (!startParameter.empty()) { args.emplace_back("start_parameter", startParameter); } if (!providerData.empty()) { args.emplace_back("provider_data", providerData); } if (!photoUrl.empty()) { args.emplace_back("photo_url", photoUrl); } if (photoSize) { args.emplace_back("photo_size", photoSize); } if (photoWidth) { args.emplace_back("photo_width", photoWidth); } if (photoHeight) { args.emplace_back("photo_height", photoHeight); } if (needName) { args.emplace_back("need_name", needName); } if (needPhoneNumber) { args.emplace_back("need_phone_number", needPhoneNumber); } if (needEmail) { args.emplace_back("need_email", needEmail); } if (needShippingAddress) { args.emplace_back("need_shipping_address", needShippingAddress); } if (sendPhoneNumberToProvider) { args.emplace_back("send_phone_number_to_provider", sendPhoneNumberToProvider); } if (sendEmailToProvider) { args.emplace_back("send_email_to_provider", sendEmailToProvider); } if (isFlexible) { args.emplace_back("is_flexible", isFlexible); } if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendInvoice", args)); } std::string Api::createInvoiceLink(const std::string& title, const std::string& description, const std::string& payload, const std::string& providerToken, const std::string& currency, const std::vector& prices, std::int32_t maxTipAmount, const std::vector& suggestedTipAmounts, const std::string& providerData, const std::string& photoUrl, std::int32_t photoSize, std::int32_t photoWidth, std::int32_t photoHeight, bool needName, bool needPhoneNumber, bool needEmail, bool needShippingAddress, bool sendPhoneNumberToProvider, bool sendEmailToProvider, bool isFlexible) const { std::vector args; args.reserve(20); args.emplace_back("title", title); args.emplace_back("description", description); args.emplace_back("payload", payload); args.emplace_back("provider_token", providerToken); args.emplace_back("currency", currency); args.emplace_back("prices", _tgTypeParser.parseArray(&TgTypeParser::parseLabeledPrice, prices)); args.emplace_back("max_tip_amount", maxTipAmount); if (!suggestedTipAmounts.empty()) { args.emplace_back("suggested_tip_amounts", _tgTypeParser.parseArray([] (const std::int32_t& option) -> std::int32_t { return option; }, suggestedTipAmounts)); } if (!providerData.empty()) { args.emplace_back("provider_data", providerData); } if (!photoUrl.empty()) { args.emplace_back("photo_url", photoUrl); } if (photoSize) { args.emplace_back("photo_size", photoSize); } if (photoWidth) { args.emplace_back("photo_width", photoWidth); } if (photoHeight) { args.emplace_back("photo_height", photoHeight); } if (needName) { args.emplace_back("need_name", needName); } if (needPhoneNumber) { args.emplace_back("need_phone_number", needPhoneNumber); } if (needEmail) { args.emplace_back("need_email", needEmail); } if (needShippingAddress) { args.emplace_back("need_shipping_address", needShippingAddress); } if (sendPhoneNumberToProvider) { args.emplace_back("send_phone_number_to_provider", sendPhoneNumberToProvider); } if (sendEmailToProvider) { args.emplace_back("send_email_to_provider", sendEmailToProvider); } if (isFlexible) { args.emplace_back("is_flexible", isFlexible); } return sendRequest("createInvoiceLink", args).get("", ""); } bool Api::answerShippingQuery(const std::string& shippingQueryId, bool ok, const std::vector& shippingOptions, const std::string& errorMessage) const { std::vector args; args.reserve(4); args.emplace_back("shipping_query_id", shippingQueryId); args.emplace_back("ok", ok); if (!shippingOptions.empty()) { args.emplace_back("shipping_options", _tgTypeParser.parseArray(&TgTypeParser::parseShippingOption, shippingOptions)); } if (!errorMessage.empty()) { args.emplace_back("error_message", errorMessage); } return sendRequest("answerShippingQuery", args).get("", false); } bool Api::answerPreCheckoutQuery(const std::string& preCheckoutQueryId, bool ok, const std::string& errorMessage) const { std::vector args; args.reserve(3); args.emplace_back("pre_checkout_query_id", preCheckoutQueryId); args.emplace_back("ok", ok); if (!errorMessage.empty()) { args.emplace_back("error_message", errorMessage); } return sendRequest("answerPreCheckoutQuery", args).get("", false); } bool Api::setPassportDataErrors(std::int64_t userId, const std::vector& errors) const { std::vector args; args.reserve(2); args.emplace_back("user_id", userId); args.emplace_back("errors", _tgTypeParser.parseArray(&TgTypeParser::parsePassportElementError, errors)); return sendRequest("setPassportDataErrors", args).get("", false); } Message::Ptr Api::sendGame(std::int64_t chatId, const std::string& gameShortName, std::int32_t replyToMessageId, InlineKeyboardMarkup::Ptr replyMarkup, bool disableNotification, bool allowSendingWithoutReply, bool protectContent, std::int32_t messageThreadId) const { std::vector args; args.reserve(8); args.emplace_back("chat_id", chatId); if (messageThreadId != 0) { args.emplace_back("message_thread_id", messageThreadId); } args.emplace_back("game_short_name", gameShortName); if (disableNotification) { args.emplace_back("disable_notification", disableNotification); } if (protectContent) { args.emplace_back("protect_content", protectContent); } if (replyToMessageId) { args.emplace_back("reply_to_message_id", replyToMessageId); } if (allowSendingWithoutReply) { args.emplace_back("allow_sending_without_reply", allowSendingWithoutReply); } if (replyMarkup) { args.emplace_back("reply_markup", _tgTypeParser.parseGenericReply(replyMarkup)); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("sendGame", args)); } Message::Ptr Api::setGameScore(std::int64_t userId, std::int32_t score, bool force, bool disableEditMessage, std::int64_t chatId, std::int32_t messageId, const std::string& inlineMessageId) const { std::vector args; args.reserve(7); args.emplace_back("user_id", userId); args.emplace_back("score", score); if (force) { args.emplace_back("force", force); } if (disableEditMessage) { args.emplace_back("disable_edit_message", disableEditMessage); } if (chatId) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } return _tgTypeParser.parseJsonAndGetMessage(sendRequest("setGameScore", args)); } std::vector Api::getGameHighScores(std::int64_t userId, std::int64_t chatId, std::int32_t messageId, const std::string& inlineMessageId) const { std::vector args; args.reserve(4); args.emplace_back("user_id", userId); if (chatId) { args.emplace_back("chat_id", chatId); } if (messageId) { args.emplace_back("message_id", messageId); } if (!inlineMessageId.empty()) { args.emplace_back("inline_message_id", inlineMessageId); } return _tgTypeParser.parseJsonAndGetArray(&TgTypeParser::parseJsonAndGetGameHighScore, sendRequest("getGameHighScores", args)); } std::string Api::downloadFile(const std::string& filePath, const std::vector& args) const { std::string url(_url); url += "/file/bot"; url += _token; url += "/"; url += filePath; return _httpClient.makeRequest(url, args); } bool Api::blockedByUser(std::int64_t chatId) const { bool isBotBlocked = false; try { sendChatAction(chatId, "typing"); } catch (std::exception& e) { std::string error = e.what(); if (error.compare("Forbidden: bot was blocked by the user") == 0) { isBotBlocked = true; } } return isBotBlocked; } boost::property_tree::ptree Api::sendRequest(const std::string& method, const std::vector& args) const { std::string url(_url); url += "/bot"; url += _token; url += "/"; url += method; int requestRetryBackoff = _httpClient.getRequestBackoff(); int retries = 0; while (1) { std::string serverResponse = _httpClient.makeRequest(url, args); if (!serverResponse.compare(0, 6, "")) { throw TgException("tgbot-cpp library have got html page instead of json response. Maybe you entered wrong bot token."); } boost::property_tree::ptree result = _tgTypeParser.parseJson(serverResponse); try { if (result.get("ok", false)) { return result.get_child("result"); } else { if (retries == _httpClient.getRequestMaxRetries()) { throw TgException(result.get("description", "")); } else { std::this_thread::sleep_for(std::chrono::seconds(requestRetryBackoff)); retries++; continue; } } } catch (boost::property_tree::ptree_error& e) { throw TgException("tgbot-cpp library can't parse json response. " + std::string(e.what())); } } } }