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

Move AnswerCustomQueryQuery to BotQueries.cpp.

Browse Source
This commit is contained in:
levlam 2024-08-15 19:11:55 +03:00
parent 7182ccfa67
commit c8116a59a2
3 changed files with 37 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
td/telegram/BotQueries.cpp
View File

@ -43,9 +43,43 @@ class SendCustomRequestQuery final : public Td::ResultHandler {
} }
}; };
class AnswerCustomQueryQuery final : public Td::ResultHandler {
Promise<Unit> promise_;
public:
explicit AnswerCustomQueryQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
}
void send(int64 custom_query_id, const string &data) {
send_query(G()->net_query_creator().create(telegram_api::bots_answerWebhookJSONQuery(
custom_query_id, telegram_api::make_object<telegram_api::dataJSON>(data))));
}
void on_result(BufferSlice packet) final {
auto result_ptr = fetch_result<telegram_api::bots_answerWebhookJSONQuery>(packet);
if (result_ptr.is_error()) {
return on_error(result_ptr.move_as_error());
}
bool result = result_ptr.ok();
if (!result) {
LOG(INFO) << "Sending answer to a custom query has failed";
}
promise_.set_value(Unit());
}
void on_error(Status status) final {
promise_.set_error(std::move(status));
}
};
void send_bot_custom_query(Td *td, const string &method, const string &parameters, void send_bot_custom_query(Td *td, const string &method, const string &parameters,
Promise<td_api::object_ptr<td_api::customRequestResult>> &&promise) { Promise<td_api::object_ptr<td_api::customRequestResult>> &&promise) {
td->create_handler<SendCustomRequestQuery>(std::move(promise))->send(method, parameters); td->create_handler<SendCustomRequestQuery>(std::move(promise))->send(method, parameters);
} }
void answer_bot_custom_query(Td *td, int64 custom_query_id, const string &data, Promise<Unit> &&promise) {
td->create_handler<AnswerCustomQueryQuery>(std::move(promise))->send(custom_query_id, data);
}
} // namespace td } // namespace td

2
td/telegram/BotQueries.h
View File

@ -18,4 +18,6 @@ class Td;
void send_bot_custom_query(Td *td, const string &method, const string &parameters, void send_bot_custom_query(Td *td, const string &method, const string &parameters,
Promise<td_api::object_ptr<td_api::customRequestResult>> &&promise); Promise<td_api::object_ptr<td_api::customRequestResult>> &&promise);
void answer_bot_custom_query(Td *td, int64 custom_query_id, const string &data, Promise<Unit> &&promise);
} // namespace td } // namespace td

32
td/telegram/Requests.cpp
View File

@ -276,36 +276,6 @@ class GetRecentMeUrlsQuery final : public Td::ResultHandler {
} }
}; };
class AnswerCustomQueryQuery final : public Td::ResultHandler {
Promise<Unit> promise_;
public:
explicit AnswerCustomQueryQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
}
void send(int64 custom_query_id, const string &data) {
send_query(G()->net_query_creator().create(telegram_api::bots_answerWebhookJSONQuery(
custom_query_id, telegram_api::make_object<telegram_api::dataJSON>(data))));
}
void on_result(BufferSlice packet) final {
auto result_ptr = fetch_result<telegram_api::bots_answerWebhookJSONQuery>(packet);
if (result_ptr.is_error()) {
return on_error(result_ptr.move_as_error());
}
bool result = result_ptr.ok();
if (!result) {
LOG(INFO) << "Sending answer to a custom query has failed";
}
promise_.set_value(Unit());
}
void on_error(Status status) final {
promise_.set_error(std::move(status));
}
};
class SetBotUpdatesStatusQuery final : public Td::ResultHandler { class SetBotUpdatesStatusQuery final : public Td::ResultHandler {
public: public:
void send(int32 pending_update_count, const string &error_message) { void send(int32 pending_update_count, const string &error_message) {
@ -7674,7 +7644,7 @@ void Requests::on_request(uint64 id, td_api::answerCustomQuery &request) {
CHECK_IS_BOT(); CHECK_IS_BOT();
CLEAN_INPUT_STRING(request.data_); CLEAN_INPUT_STRING(request.data_);
CREATE_OK_REQUEST_PROMISE(); CREATE_OK_REQUEST_PROMISE();
td_->create_handler<AnswerCustomQueryQuery>(std::move(promise))->send(request.custom_query_id_, request.data_); answer_bot_custom_query(td_, request.custom_query_id_, request.data_, std::move(promise));
} }
void Requests::on_request(uint64 id, const td_api::setAlarm &request) { void Requests::on_request(uint64 id, const td_api::setAlarm &request) {