tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Process sent business messages.

Browse Source
This commit is contained in:
levlam 2024-03-18 15:16:11 +03:00
parent 444d47d440
commit 79967ca006
2 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
td/telegram/BusinessConnectionManager.cpp
View File

@ -178,7 +178,7 @@ class BusinessConnectionManager::SendBusinessMessageQuery final : public Td::Res
auto ptr = result_ptr.move_as_ok(); auto ptr = result_ptr.move_as_ok();
LOG(INFO) << "Receive result for SendBusinessMessageQuery: " << to_string(ptr); LOG(INFO) << "Receive result for SendBusinessMessageQuery: " << to_string(ptr);
promise_.set_value(nullptr); // TODO td_->business_connection_manager_->process_sent_business_message(std::move(ptr), std::move(promise_));
} }
void on_error(Status status) final { void on_error(Status status) final {
@ -249,7 +249,7 @@ class BusinessConnectionManager::SendBusinessMediaQuery final : public Td::Resul
auto ptr = result_ptr.move_as_ok(); auto ptr = result_ptr.move_as_ok();
LOG(INFO) << "Receive result for SendBusinessMediaQuery: " << to_string(ptr); LOG(INFO) << "Receive result for SendBusinessMediaQuery: " << to_string(ptr);
promise_.set_value(nullptr); // TODO td_->business_connection_manager_->process_sent_business_message(std::move(ptr), std::move(promise_));
} }
void on_error(Status status) final { void on_error(Status status) final {
@ -744,6 +744,28 @@ void BusinessConnectionManager::do_send_message(unique_ptr<PendingMessage> &&mes
})); }));
} }
void BusinessConnectionManager::process_sent_business_message(
telegram_api::object_ptr<telegram_api::Updates> &&updates_ptr,
Promise<td_api::object_ptr<td_api::businessMessage>> &&promise) {
if (updates_ptr->get_id() != telegram_api::updates::ID) {
LOG(ERROR) << "Receive " << to_string(updates_ptr);
return promise.set_error(Status::Error(500, "Receive invalid business connection messages"));
}
auto updates = telegram_api::move_object_as<telegram_api::updates>(updates_ptr);
if (updates->updates_.size() != 1 ||
updates->updates_[0]->get_id() != telegram_api::updateBotNewBusinessMessage::ID) {
LOG(ERROR) << "Receive " << to_string(updates);
return promise.set_error(Status::Error(500, "Receive invalid business connection messages"));
}
auto update = telegram_api::move_object_as<telegram_api::updateBotNewBusinessMessage>(updates->updates_[0]);
td_->contacts_manager_->on_get_users(std::move(updates->users_), "SendBusinessMediaQuery");
td_->contacts_manager_->on_get_chats(std::move(updates->chats_), "SendBusinessMediaQuery");
promise.set_value(td_->messages_manager_->get_business_message_object(std::move(update->message_),
std::move(update->reply_to_message_)));
}
FileId BusinessConnectionManager::get_message_file_id(const unique_ptr<PendingMessage> &message) { FileId BusinessConnectionManager::get_message_file_id(const unique_ptr<PendingMessage> &message) {
CHECK(message != nullptr); CHECK(message != nullptr);
return get_message_content_any_file_id( return get_message_content_any_file_id(

3
td/telegram/BusinessConnectionManager.h
View File

@ -120,6 +120,9 @@ class BusinessConnectionManager final : public Actor {
void do_send_message(unique_ptr<PendingMessage> &&message, void do_send_message(unique_ptr<PendingMessage> &&message,
Promise<td_api::object_ptr<td_api::businessMessage>> &&promise); Promise<td_api::object_ptr<td_api::businessMessage>> &&promise);
void process_sent_business_message(telegram_api::object_ptr<telegram_api::Updates> &&updates_ptr,
Promise<td_api::object_ptr<td_api::businessMessage>> &&promise);
static FileId get_message_file_id(const unique_ptr<PendingMessage> &message); static FileId get_message_file_id(const unique_ptr<PendingMessage> &message);
FileId get_message_thumbnail_file_id(const unique_ptr<PendingMessage> &message, FileId file_id) const; FileId get_message_thumbnail_file_id(const unique_ptr<PendingMessage> &message, FileId file_id) const;