Update TDLib to 1.8.15 and support votes by chats in polls.

This commit is contained in:
levlam 2023-07-20 17:06:32 +03:00
parent 1fa5c2c31a
commit 736411c113
4 changed files with 71 additions and 22 deletions

2
td

@ -1 +1 @@
Subproject commit 328b8649d859c5ed4088a875cbb059db6029dc0d Subproject commit 53888437cf11aca258aae7e76552a38c1750d6e7

View File

@ -1408,7 +1408,21 @@ class Client::JsonPollAnswer final : public td::Jsonable {
void store(td::JsonValueScope *scope) const { void store(td::JsonValueScope *scope) const {
auto object = scope->enter_object(); auto object = scope->enter_object();
object("poll_id", td::to_string(poll_answer_->poll_id_)); object("poll_id", td::to_string(poll_answer_->poll_id_));
object("user", JsonUser(poll_answer_->user_id_, client_)); switch (poll_answer_->voter_id_->get_id()) {
case td_api::messageSenderUser::ID: {
auto user_id = static_cast<const td_api::messageSenderUser *>(poll_answer_->voter_id_.get())->user_id_;
object("user", JsonUser(user_id, client_));
break;
}
case td_api::messageSenderChat::ID: {
auto voter_chat_id = static_cast<const td_api::messageSenderChat *>(poll_answer_->voter_id_.get())->chat_id_;
object("user", JsonUser(client_->channel_bot_user_id_, client_));
object("voter_chat", JsonChat(voter_chat_id, false, client_));
break;
}
default:
UNREACHABLE();
}
object("option_ids", td::json_array(poll_answer_->option_ids_, [](int32 option_id) { return option_id; })); object("option_ids", td::json_array(poll_answer_->option_ids_, [](int32 option_id) { return option_id; }));
} }
@ -2287,6 +2301,8 @@ void Client::JsonMessage::store(td::JsonValueScope *scope) const {
} }
case td_api::messageChatSetBackground::ID: case td_api::messageChatSetBackground::ID:
break; break;
case td_api::messageStory::ID:
break;
default: default:
UNREACHABLE(); UNREACHABLE();
} }
@ -5494,6 +5510,13 @@ bool Client::to_bool(td::MutableSlice value) {
return value == "true" || value == "yes" || value == "1"; return value == "true" || value == "yes" || value == "1";
} }
td_api::object_ptr<td_api::MessageReplyTo> Client::get_message_reply_to(int64 reply_to_message_id) {
if (reply_to_message_id > 0) {
return make_object<td_api::messageReplyToMessage>(0, reply_to_message_id);
}
return nullptr;
}
td::Result<td_api::object_ptr<td_api::keyboardButton>> Client::get_keyboard_button(td::JsonValue &button) { td::Result<td_api::object_ptr<td_api::keyboardButton>> Client::get_keyboard_button(td::JsonValue &button) {
if (button.type() == td::JsonValue::Type::Object) { if (button.type() == td::JsonValue::Type::Object) {
auto &object = button.get_object(); auto &object = button.get_object();
@ -5730,7 +5753,7 @@ td::Result<td_api::object_ptr<td_api::ReplyMarkup>> Client::get_reply_markup(td:
if (value.type() != td::JsonValue::Type::Object) { if (value.type() != td::JsonValue::Type::Object) {
return td::Status::Error(400, "Object expected as reply markup"); return td::Status::Error(400, "Object expected as reply markup");
} }
for (auto &field_value : value.get_object()) { for (auto &field_value : value.get_object().field_values_) {
if (field_value.first == "keyboard") { if (field_value.first == "keyboard") {
auto keyboard = std::move(field_value.second); auto keyboard = std::move(field_value.second);
if (keyboard.type() != td::JsonValue::Type::Array) { if (keyboard.type() != td::JsonValue::Type::Array) {
@ -8327,11 +8350,11 @@ td::Status Client::process_send_media_group_query(PromisedQueryPtr &query) {
auto message_count = input_message_contents.size(); auto message_count = input_message_contents.size();
count += static_cast<int32>(message_count); count += static_cast<int32>(message_count);
send_request( send_request(make_object<td_api::sendMessageAlbum>(
make_object<td_api::sendMessageAlbum>(chat_id, message_thread_id, reply_to_message_id, chat_id, message_thread_id, get_message_reply_to(reply_to_message_id),
get_message_send_options(disable_notification, protect_content), get_message_send_options(disable_notification, protect_content),
std::move(input_message_contents), false), std::move(input_message_contents), false),
td::make_unique<TdOnSendMessageAlbumCallback>(this, chat_id, message_count, std::move(query))); td::make_unique<TdOnSendMessageAlbumCallback>(this, chat_id, message_count, std::move(query)));
}; };
check_message_thread(chat_id, message_thread_id, reply_to_message_id, std::move(query), check_message_thread(chat_id, message_thread_id, reply_to_message_id, std::move(query),
std::move(on_message_thread_checked)); std::move(on_message_thread_checked));
@ -10098,11 +10121,11 @@ void Client::do_send_message(object_ptr<td_api::InputMessageContent> input_messa
} }
count++; count++;
send_request( send_request(make_object<td_api::sendMessage>(
make_object<td_api::sendMessage>(chat_id, message_thread_id, reply_to_message_id, chat_id, message_thread_id, get_message_reply_to(reply_to_message_id),
get_message_send_options(disable_notification, protect_content), get_message_send_options(disable_notification, protect_content),
std::move(reply_markup), std::move(input_message_content)), std::move(reply_markup), std::move(input_message_content)),
td::make_unique<TdOnSendMessageCallback>(this, chat_id, std::move(query))); td::make_unique<TdOnSendMessageCallback>(this, chat_id, std::move(query)));
}; };
check_message_thread(chat_id, message_thread_id, reply_to_message_id, std::move(query), check_message_thread(chat_id, message_thread_id, reply_to_message_id, std::move(query),
std::move(on_message_thread_checked)); std::move(on_message_thread_checked));
@ -11172,6 +11195,8 @@ bool Client::need_skip_update_message(int64 chat_id, const object_ptr<td_api::me
return true; return true;
case td_api::messageChatSetBackground::ID: case td_api::messageChatSetBackground::ID:
return true; return true;
case td_api::messageStory::ID:
return true;
default: default:
break; break;
} }
@ -11188,18 +11213,35 @@ bool Client::need_skip_update_message(int64 chat_id, const object_ptr<td_api::me
td::int64 Client::get_reply_to_message_id(const object_ptr<td_api::message> &message) { td::int64 Client::get_reply_to_message_id(const object_ptr<td_api::message> &message) {
if (message->content_->get_id() == td_api::messagePinMessage::ID) { if (message->content_->get_id() == td_api::messagePinMessage::ID) {
CHECK(message->reply_to_message_id_ == 0); CHECK(message->reply_to_ == nullptr);
return static_cast<const td_api::messagePinMessage *>(message->content_.get())->message_id_; return static_cast<const td_api::messagePinMessage *>(message->content_.get())->message_id_;
} }
return message->reply_to_message_id_; if (message->reply_to_ != nullptr) {
switch (message->reply_to_->get_id()) {
case td_api::messageReplyToMessage::ID: {
auto reply_to = static_cast<const td_api::messageReplyToMessage *>(message->reply_to_.get());
CHECK(reply_to->message_id_ > 0);
CHECK(reply_to->chat_id_ == message->chat_id_);
return reply_to->message_id_;
}
case td_api::messageReplyToStory::ID:
break;
default:
UNREACHABLE();
break;
}
}
return 0;
} }
void Client::drop_reply_to_message_in_another_chat(object_ptr<td_api::message> &message) { void Client::drop_reply_to_message_in_another_chat(object_ptr<td_api::message> &message) {
if (message->reply_in_chat_id_ != message->chat_id_ && message->reply_to_message_id_ != 0) { if (message->reply_to_ != nullptr && message->reply_to_->get_id() == td_api::messageReplyToMessage::ID) {
LOG(ERROR) << "Drop reply to message " << message->id_ << " in chat " << message->chat_id_ << " from another chat " auto reply_in_chat_id = static_cast<td_api::messageReplyToMessage *>(message->reply_to_.get())->chat_id_;
<< message->reply_in_chat_id_; if (reply_in_chat_id != message->chat_id_) {
message->reply_in_chat_id_ = 0; LOG(ERROR) << "Drop reply to message " << message->id_ << " in chat " << message->chat_id_
message->reply_to_message_id_ = 0; << " from another chat " << reply_in_chat_id;
message->reply_to_ = nullptr;
}
} }
} }
@ -11595,7 +11637,12 @@ Client::FullMessageId Client::add_message(object_ptr<td_api::message> &&message,
drop_reply_to_message_in_another_chat(message); drop_reply_to_message_in_another_chat(message);
message_info->reply_to_message_id = message->reply_to_message_id_; if (message->reply_to_ != nullptr && message->reply_to_->get_id() == td_api::messageReplyToMessage::ID) {
message_info->reply_to_message_id =
static_cast<td_api::messageReplyToMessage *>(message->reply_to_.get())->message_id_;
} else {
message_info->reply_to_message_id = 0;
}
if (message_info->content == nullptr || force_update_content) { if (message_info->content == nullptr || force_update_content) {
message_info->content = std::move(message->content_); message_info->content = std::move(message->content_);

View File

@ -331,6 +331,8 @@ class Client final : public WebhookActor::Callback {
static bool to_bool(td::MutableSlice value); static bool to_bool(td::MutableSlice value);
static object_ptr<td_api::MessageReplyTo> get_message_reply_to(int64 reply_to_message_id);
static td::Result<object_ptr<td_api::keyboardButton>> get_keyboard_button(td::JsonValue &button); static td::Result<object_ptr<td_api::keyboardButton>> get_keyboard_button(td::JsonValue &button);
static td::Result<object_ptr<td_api::inlineKeyboardButton>> get_inline_keyboard_button(td::JsonValue &button, static td::Result<object_ptr<td_api::inlineKeyboardButton>> get_inline_keyboard_button(td::JsonValue &button,

View File

@ -73,7 +73,7 @@ WebhookActor::WebhookActor(td::ActorShared<Callback> callback, td::int64 tqueue_
WebhookActor::~WebhookActor() { WebhookActor::~WebhookActor() {
td::Scheduler::instance()->destroy_on_scheduler(SharedData::get_file_gc_scheduler_id(), update_map_, queue_updates_, td::Scheduler::instance()->destroy_on_scheduler(SharedData::get_file_gc_scheduler_id(), update_map_, queue_updates_,
queues_); queues_, ssl_ctx_);
} }
void WebhookActor::relax_wakeup_at(double wakeup_at, const char *source) { void WebhookActor::relax_wakeup_at(double wakeup_at, const char *source) {