Add td_api::getMessageReadDate.

This commit is contained in:
levlam 2024-01-09 13:37:29 +03:00
parent 0e032795b6
commit 5fb64e7ccd
6 changed files with 127 additions and 3 deletions

View File

@ -1154,6 +1154,9 @@ chatMessageSender sender:MessageSender needs_premium:Bool = ChatMessageSender;
chatMessageSenders senders:vector<chatMessageSender> = ChatMessageSenders; chatMessageSenders senders:vector<chatMessageSender> = ChatMessageSenders;
//@description Contains read date of a recent outgoing message in a private chat @read_date Point in time (Unix timestamp) when the message was read by the other user
messageReadDate read_date:int32 = MessageReadDate;
//@description Represents a viewer of a message @user_id User identifier of the viewer @view_date Approximate point in time (Unix timestamp) when the message was viewed //@description Represents a viewer of a message @user_id User identifier of the viewer @view_date Approximate point in time (Unix timestamp) when the message was viewed
messageViewer user_id:int53 view_date:int32 = MessageViewer; messageViewer user_id:int53 view_date:int32 = MessageViewer;
@ -7088,6 +7091,11 @@ getMessages chat_id:int53 message_ids:vector<int53> = Messages;
//@description Returns information about a message thread. Can be used only if message.can_get_message_thread == true @chat_id Chat identifier @message_id Identifier of the message //@description Returns information about a message thread. Can be used only if message.can_get_message_thread == true @chat_id Chat identifier @message_id Identifier of the message
getMessageThread chat_id:int53 message_id:int53 = MessageThreadInfo; getMessageThread chat_id:int53 message_id:int53 = MessageThreadInfo;
//@description Returns read date of a recent outgoing message in a private chat. The method can be called if message.can_get_read_date == true
//@chat_id Chat identifier
//@message_id Identifier of the message
getMessageReadDate chat_id:int53 message_id:int53 = MessageReadDate;
//@description Returns viewers of a recent outgoing message in a basic group or a supergroup chat. For video notes and voice notes only users, opened content of the message, are returned. The method can be called if message.can_get_viewers == true //@description Returns viewers of a recent outgoing message in a basic group or a supergroup chat. For video notes and voice notes only users, opened content of the message, are returned. The method can be called if message.can_get_viewers == true
//@chat_id Chat identifier //@chat_id Chat identifier
//@message_id Identifier of the message //@message_id Identifier of the message

View File

@ -717,6 +717,41 @@ class UnpinAllMessagesQuery final : public Td::ResultHandler {
} }
}; };
class GetOutboxReadDateQuery final : public Td::ResultHandler {
Promise<td_api::object_ptr<td_api::messageReadDate>> promise_;
DialogId dialog_id_;
MessageId message_id_;
public:
explicit GetOutboxReadDateQuery(Promise<td_api::object_ptr<td_api::messageReadDate>> &&promise)
: promise_(std::move(promise)) {
}
void send(DialogId dialog_id, MessageId message_id) {
dialog_id_ = dialog_id;
message_id_ = message_id;
auto input_peer = td_->dialog_manager_->get_input_peer(dialog_id, AccessRights::Read);
CHECK(input_peer != nullptr);
send_query(G()->net_query_creator().create(
telegram_api::messages_getOutboxReadDate(std::move(input_peer), message_id.get_server_message_id().get())));
}
void on_result(BufferSlice packet) final {
auto result_ptr = fetch_result<telegram_api::messages_getOutboxReadDate>(packet);
if (result_ptr.is_error()) {
return on_error(result_ptr.move_as_error());
}
auto ptr = result_ptr.move_as_ok();
promise_.set_value(td_api::make_object<td_api::messageReadDate>(ptr->date_));
}
void on_error(Status status) final {
td_->messages_manager_->on_get_message_error(dialog_id_, message_id_, status, "GetOutboxReadDateQuery");
promise_.set_error(std::move(status));
}
};
class GetMessageReadParticipantsQuery final : public Td::ResultHandler { class GetMessageReadParticipantsQuery final : public Td::ResultHandler {
Promise<MessageViewers> promise_; Promise<MessageViewers> promise_;
DialogId dialog_id_; DialogId dialog_id_;
@ -17107,14 +17142,74 @@ td_api::object_ptr<td_api::messageThreadInfo> MessagesManager::get_message_threa
info.unread_message_count, std::move(messages), std::move(draft_message)); info.unread_message_count, std::move(messages), std::move(draft_message));
} }
Status MessagesManager::can_get_message_viewers(MessageFullId message_full_id) { Status MessagesManager::can_get_message_read_date(MessageFullId message_full_id) {
auto dialog_id = message_full_id.get_dialog_id(); auto dialog_id = message_full_id.get_dialog_id();
Dialog *d = get_dialog_force(dialog_id, "get_message_viewers"); Dialog *d = get_dialog_force(dialog_id, "can_get_message_read_date");
if (d == nullptr) { if (d == nullptr) {
return Status::Error(400, "Chat not found"); return Status::Error(400, "Chat not found");
} }
auto m = get_message_force(d, message_full_id.get_message_id(), "get_message_viewers"); auto m = get_message_force(d, message_full_id.get_message_id(), "can_get_message_read_date");
if (m == nullptr) {
return Status::Error(400, "Message not found");
}
return can_get_message_read_date(dialog_id, m);
}
Status MessagesManager::can_get_message_read_date(DialogId dialog_id, const Message *m) const {
if (td_->auth_manager_->is_bot()) {
return Status::Error(400, "User is bot");
}
CHECK(m != nullptr);
if (!m->is_outgoing) {
return Status::Error(400, "Can't get read date of incoming messages");
}
if (dialog_id.get_type() != DialogType::User) {
return Status::Error(400, "Read date can be received only in private chats");
}
if (!td_->dialog_manager_->have_input_peer(dialog_id, AccessRights::Read)) {
return Status::Error(400, "Can't access the chat");
}
auto user_id = dialog_id.get_user_id();
if (td_->contacts_manager_->is_user_bot(user_id)) {
return Status::Error(400, "The user is a bot");
}
if (td_->contacts_manager_->is_user_support(user_id)) {
return Status::Error(400, "The user is a Telegram support account");
}
if (m->message_id.is_scheduled()) {
return Status::Error(400, "Scheduled messages can't be read");
}
if (m->message_id.is_yet_unsent()) {
return Status::Error(400, "Yet unsent messages can't be read");
}
if (m->message_id.is_local()) {
return Status::Error(400, "Local messages can't be read");
}
CHECK(m->message_id.is_server());
return Status::OK();
}
void MessagesManager::get_message_read_date(MessageFullId message_full_id,
Promise<td_api::object_ptr<td_api::messageReadDate>> &&promise) {
TRY_STATUS_PROMISE(promise, can_get_message_read_date(message_full_id));
td_->create_handler<GetOutboxReadDateQuery>(std::move(promise))
->send(message_full_id.get_dialog_id(), message_full_id.get_message_id());
}
Status MessagesManager::can_get_message_viewers(MessageFullId message_full_id) {
auto dialog_id = message_full_id.get_dialog_id();
Dialog *d = get_dialog_force(dialog_id, "can_get_message_viewers");
if (d == nullptr) {
return Status::Error(400, "Chat not found");
}
auto m = get_message_force(d, message_full_id.get_message_id(), "can_get_message_viewers");
if (m == nullptr) { if (m == nullptr) {
return Status::Error(400, "Message not found"); return Status::Error(400, "Message not found");
} }

View File

@ -606,6 +606,9 @@ class MessagesManager final : public Actor {
DialogId dialog_id, MessageId message_id, DialogId expected_dialog_id, DialogId dialog_id, MessageId message_id, DialogId expected_dialog_id,
MessageId expected_message_id, Promise<MessageThreadInfo> promise); MessageId expected_message_id, Promise<MessageThreadInfo> promise);
void get_message_read_date(MessageFullId message_full_id,
Promise<td_api::object_ptr<td_api::messageReadDate>> &&promise);
void get_message_viewers(MessageFullId message_full_id, void get_message_viewers(MessageFullId message_full_id,
Promise<td_api::object_ptr<td_api::messageViewers>> &&promise); Promise<td_api::object_ptr<td_api::messageViewers>> &&promise);
@ -1705,6 +1708,10 @@ class MessagesManager final : public Actor {
bool can_report_message_reactions(DialogId dialog_id, const Message *m) const; bool can_report_message_reactions(DialogId dialog_id, const Message *m) const;
Status can_get_message_read_date(MessageFullId message_full_id) TD_WARN_UNUSED_RESULT;
Status can_get_message_read_date(DialogId dialog_id, const Message *m) const TD_WARN_UNUSED_RESULT;
Status can_get_message_viewers(MessageFullId message_full_id) TD_WARN_UNUSED_RESULT; Status can_get_message_viewers(MessageFullId message_full_id) TD_WARN_UNUSED_RESULT;
Status can_get_message_viewers(DialogId dialog_id, const Message *m) const TD_WARN_UNUSED_RESULT; Status can_get_message_viewers(DialogId dialog_id, const Message *m) const TD_WARN_UNUSED_RESULT;

View File

@ -4704,6 +4704,13 @@ void Td::on_request(uint64 id, const td_api::getMessageThread &request) {
CREATE_REQUEST(GetMessageThreadRequest, request.chat_id_, request.message_id_); CREATE_REQUEST(GetMessageThreadRequest, request.chat_id_, request.message_id_);
} }
void Td::on_request(uint64 id, const td_api::getMessageReadDate &request) {
CHECK_IS_USER();
CREATE_REQUEST_PROMISE();
messages_manager_->get_message_read_date({DialogId(request.chat_id_), MessageId(request.message_id_)},
std::move(promise));
}
void Td::on_request(uint64 id, const td_api::getMessageViewers &request) { void Td::on_request(uint64 id, const td_api::getMessageViewers &request) {
CHECK_IS_USER(); CHECK_IS_USER();
CREATE_REQUEST_PROMISE(); CREATE_REQUEST_PROMISE();

View File

@ -605,6 +605,8 @@ class Td final : public Actor {
void on_request(uint64 id, const td_api::getMessageThread &request); void on_request(uint64 id, const td_api::getMessageThread &request);
void on_request(uint64 id, const td_api::getMessageReadDate &request);
void on_request(uint64 id, const td_api::getMessageViewers &request); void on_request(uint64 id, const td_api::getMessageViewers &request);
void on_request(uint64 id, const td_api::getMessages &request); void on_request(uint64 id, const td_api::getMessages &request);

View File

@ -3652,6 +3652,11 @@ class CliClient final : public Actor {
MessageId message_id; MessageId message_id;
get_args(args, chat_id, message_id); get_args(args, chat_id, message_id);
send_request(td_api::make_object<td_api::getMessageThread>(chat_id, message_id)); send_request(td_api::make_object<td_api::getMessageThread>(chat_id, message_id));
} else if (op == "gmrd") {
ChatId chat_id;
MessageId message_id;
get_args(args, chat_id, message_id);
send_request(td_api::make_object<td_api::getMessageReadDate>(chat_id, message_id));
} else if (op == "gmv") { } else if (op == "gmv") {
ChatId chat_id; ChatId chat_id;
MessageId message_id; MessageId message_id;