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

Process sent business message albums.

Browse Source
This commit is contained in:
levlam 2024-03-18 16:51:16 +03:00
parent 79967ca006
commit 7a4f77cc30
2 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
td/telegram/BusinessConnectionManager.cpp
View File

@ -309,7 +309,7 @@ class BusinessConnectionManager::SendBusinessMultiMediaQuery final : public Td::
auto ptr = result_ptr.move_as_ok(); auto ptr = result_ptr.move_as_ok();
LOG(INFO) << "Receive result for SendBusinessMultiMediaQuery: " << to_string(ptr); LOG(INFO) << "Receive result for SendBusinessMultiMediaQuery: " << to_string(ptr);
promise_.set_value(nullptr); // TODO td_->business_connection_manager_->process_sent_business_message_album(std::move(ptr), std::move(promise_));
} }
void on_error(Status status) final { void on_error(Status status) final {
@ -1078,4 +1078,30 @@ void BusinessConnectionManager::on_upload_message_album_media(int64 request_id,
->send(std::move(messages), std::move(input_single_media)); ->send(std::move(messages), std::move(input_single_media));
} }
void BusinessConnectionManager::process_sent_business_message_album(
telegram_api::object_ptr<telegram_api::Updates> &&updates_ptr,
Promise<td_api::object_ptr<td_api::businessMessages>> &&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);
for (auto &update : updates->updates_) {
if (update->get_id() != telegram_api::updateBotNewBusinessMessage::ID) {
LOG(ERROR) << "Receive " << to_string(updates);
return promise.set_error(Status::Error(500, "Receive invalid business connection messages"));
}
}
td_->contacts_manager_->on_get_users(std::move(updates->users_), "SendBusinessMediaQuery");
td_->contacts_manager_->on_get_chats(std::move(updates->chats_), "SendBusinessMediaQuery");
auto messages = td_api::make_object<td_api::businessMessages>();
for (auto &update_ptr : updates->updates_) {
auto update = telegram_api::move_object_as<telegram_api::updateBotNewBusinessMessage>(update_ptr);
messages->messages_.push_back(td_->messages_manager_->get_business_message_object(
std::move(update->message_), std::move(update->reply_to_message_)));
}
promise.set_value(std::move(messages));
}
} // namespace td } // namespace td

3
td/telegram/BusinessConnectionManager.h
View File

@ -152,6 +152,9 @@ class BusinessConnectionManager final : public Actor {
void on_upload_message_album_media(int64 request_id, size_t media_pos, Result<UploadMediaResult> &&result); void on_upload_message_album_media(int64 request_id, size_t media_pos, Result<UploadMediaResult> &&result);
void process_sent_business_message_album(telegram_api::object_ptr<telegram_api::Updates> &&updates_ptr,
Promise<td_api::object_ptr<td_api::businessMessages>> &&promise);
WaitFreeHashMap<BusinessConnectionId, unique_ptr<BusinessConnection>, BusinessConnectionIdHash> business_connections_; WaitFreeHashMap<BusinessConnectionId, unique_ptr<BusinessConnection>, BusinessConnectionIdHash> business_connections_;
FlatHashMap<BusinessConnectionId, vector<Promise<td_api::object_ptr<td_api::businessConnection>>>, FlatHashMap<BusinessConnectionId, vector<Promise<td_api::object_ptr<td_api::businessConnection>>>,