Add toggleGroupCallMemberIsMuted method.

This commit is contained in:
levlam 2020-11-27 17:40:29 +03:00
parent 1aa5822bf8
commit 3e95f8d9cc
7 changed files with 73 additions and 0 deletions

View File

@ -4324,6 +4324,10 @@ toggleGroupCallMuteNewMembers group_call_id:string mute_new_members:Bool = Ok;
//@group_call_id Group call identifier @user_id User identifier
inviteGroupCallMember group_call_id:string user_id:int32 = Ok;
//@description Toggles whether a group call member is muted. Requires can_manage_calls rights to mute other group call members
//@group_call_id Group call identifier @user_id User identifier @is_muted Pass true if the user must be muted and false otherwise
toggleGroupCallMemberIsMuted group_call_id:string user_id:int32 is_muted:Bool = Ok;
//@description Checks group call source for validness. If the method returns an error with a message "GROUP_CALL_JOIN_MISSING", the call needs to be rejoined @group_call_id Group call identifier @source Caller source identifier
checkGroupCallSource group_call_id:string source:int32 = Ok;

Binary file not shown.

View File

@ -168,6 +168,45 @@ class InviteToGroupCallQuery : public Td::ResultHandler {
}
};
class EditGroupCallMemberQuery : public Td::ResultHandler {
Promise<Unit> promise_;
public:
explicit EditGroupCallMemberQuery(Promise<Unit> &&promise) : promise_(std::move(promise)) {
}
void send(InputGroupCallId group_call_id, UserId user_id, bool is_muted) {
auto input_user = td->contacts_manager_->get_input_user(user_id);
CHECK(input_user != nullptr);
int32 flags = 0;
if (is_muted) {
flags |= telegram_api::phone_editGroupCallMember::MUTED_MASK;
}
send_query(G()->net_query_creator().create(telegram_api::phone_editGroupCallMember(
flags, false /*ignored*/, group_call_id.get_input_group_call(), std::move(input_user))));
}
void on_result(uint64 id, BufferSlice packet) override {
auto result_ptr = fetch_result<telegram_api::phone_editGroupCallMember>(packet);
if (result_ptr.is_error()) {
return on_error(id, result_ptr.move_as_error());
}
auto ptr = result_ptr.move_as_ok();
LOG(INFO) << "Receive result for EditGroupCallMemberQuery: " << to_string(ptr);
td->updates_manager_->on_get_updates(std::move(ptr));
// TODO set promise after updates are processed
promise_.set_value(Unit());
}
void on_error(uint64 id, Status status) override {
promise_.set_error(std::move(status));
}
};
class CheckGroupCallQuery : public Td::ResultHandler {
Promise<Unit> promise_;
@ -480,6 +519,14 @@ void GroupCallManager::invite_group_call_member(InputGroupCallId group_call_id,
td_->create_handler<InviteToGroupCallQuery>(std::move(promise))->send(group_call_id, user_id);
}
void GroupCallManager::toggle_group_call_member_is_muted(InputGroupCallId group_call_id, UserId user_id,
bool is_muted, Promise<Unit> &&promise) {
if (!td_->contacts_manager_->have_input_user(user_id)) {
return promise.set_error(Status::Error(400, "Have no access to the user"));
}
td_->create_handler<EditGroupCallMemberQuery>(std::move(promise))->send(group_call_id, user_id, is_muted);
}
void GroupCallManager::check_group_call_source(InputGroupCallId group_call_id, int32 source, Promise<Unit> &&promise) {
td_->create_handler<CheckGroupCallQuery>(std::move(promise))->send(group_call_id, source);
}

View File

@ -41,6 +41,9 @@ class GroupCallManager : public Actor {
void invite_group_call_member(InputGroupCallId group_call_id, UserId user_id, Promise<Unit> &&promise);
void toggle_group_call_member_is_muted(InputGroupCallId group_call_id, UserId user_id, bool is_muted,
Promise<Unit> &&promise);
void check_group_call_source(InputGroupCallId group_call_id, int32 source, Promise<Unit> &&promise);
void leave_group_call(InputGroupCallId group_call_id, int32 source, Promise<Unit> &&promise);

View File

@ -6066,6 +6066,15 @@ void Td::on_request(uint64 id, const td_api::inviteGroupCallMember &request) {
group_call_manager_->invite_group_call_member(group_call_id, UserId(request.user_id_), std::move(promise));
}
void Td::on_request(uint64 id, const td_api::toggleGroupCallMemberIsMuted &request) {
CHECK_IS_USER();
CREATE_OK_REQUEST_PROMISE();
TRY_RESULT_PROMISE(promise, group_call_id, InputGroupCallId::from_group_call_id(request.group_call_id_));
group_call_manager_->toggle_group_call_member_is_muted(group_call_id, UserId(request.user_id_), request.is_muted_,
std::move(promise));
}
void Td::on_request(uint64 id, const td_api::checkGroupCallSource &request) {
CHECK_IS_USER();
CREATE_OK_REQUEST_PROMISE();

View File

@ -700,6 +700,8 @@ class Td final : public NetQueryCallback {
void on_request(uint64 id, const td_api::inviteGroupCallMember &request);
void on_request(uint64 id, const td_api::toggleGroupCallMemberIsMuted &request);
void on_request(uint64 id, const td_api::checkGroupCallSource &request);
void on_request(uint64 id, const td_api::leaveGroupCall &request);

View File

@ -2857,6 +2857,14 @@ class CliClient final : public Actor {
std::tie(group_call_id, user_id) = split(args);
send_request(
td_api::make_object<td_api::inviteGroupCallMember>(as_group_call_id(group_call_id), as_user_id(user_id)));
} else if (op == "tgcmim") {
string group_call_id;
string user_id;
string is_muted;
std::tie(group_call_id, args) = split(args);
std::tie(user_id, is_muted) = split(args);
send_request(td_api::make_object<td_api::toggleGroupCallMemberIsMuted>(as_group_call_id(group_call_id),
as_user_id(user_id), as_bool(is_muted)));
} else if (op == "cgcs") {
send_request(td_api::make_object<td_api::checkGroupCallSource>(as_group_call_id(args), 123));
} else if (op == "lgc") {