Update API scheme on layer 142.

This commit is contained in:
John Preston 2022-04-15 17:32:34 +04:00
parent 36b8d03b1d
commit a752c4d9f3
10 changed files with 89 additions and 44 deletions

View file

@ -562,6 +562,7 @@ auth.passwordRecovery#137948a5 email_pattern:string = auth.PasswordRecovery;
receivedNotifyMessage#a384b779 id:int flags:int = ReceivedNotifyMessage; receivedNotifyMessage#a384b779 id:int flags:int = ReceivedNotifyMessage;
chatInviteExported#ab4a819 flags:# revoked:flags.0?true permanent:flags.5?true request_needed:flags.6?true link:string admin_id:long date:int start_date:flags.4?int expire_date:flags.1?int usage_limit:flags.2?int usage:flags.3?int requested:flags.7?int title:flags.8?string = ExportedChatInvite; chatInviteExported#ab4a819 flags:# revoked:flags.0?true permanent:flags.5?true request_needed:flags.6?true link:string admin_id:long date:int start_date:flags.4?int expire_date:flags.1?int usage_limit:flags.2?int usage:flags.3?int requested:flags.7?int title:flags.8?string = ExportedChatInvite;
chatInvitePublicJoinRequests#ed107ab7 = ExportedChatInvite;
chatInviteAlready#5a686d7c chat:Chat = ChatInvite; chatInviteAlready#5a686d7c chat:Chat = ChatInvite;
chatInvite#300c44c1 flags:# channel:flags.0?true broadcast:flags.1?true public:flags.2?true megagroup:flags.3?true request_needed:flags.6?true title:string about:flags.5?string photo:Photo participants_count:int participants:flags.4?Vector<User> = ChatInvite; chatInvite#300c44c1 flags:# channel:flags.0?true broadcast:flags.1?true public:flags.2?true megagroup:flags.3?true request_needed:flags.6?true title:string about:flags.5?string photo:Photo participants_count:int participants:flags.4?Vector<User> = ChatInvite;
@ -581,7 +582,7 @@ messages.stickerSetNotModified#d3f924eb = messages.StickerSet;
botCommand#c27ac8c7 command:string description:string = BotCommand; botCommand#c27ac8c7 command:string description:string = BotCommand;
botInfo#e4169b5d user_id:long description:string commands:Vector<BotCommand> menu_button:BotMenuButton = BotInfo; botInfo#cc8ba4d7 flags:# user_id:flags.0?long description:flags.1?string description_photo:flags.4?Photo commands:flags.2?Vector<BotCommand> menu_button:flags.3?BotMenuButton = BotInfo;
keyboardButton#a2fa4880 text:string = KeyboardButton; keyboardButton#a2fa4880 text:string = KeyboardButton;
keyboardButtonUrl#258aff05 text:string url:string = KeyboardButton; keyboardButtonUrl#258aff05 text:string url:string = KeyboardButton;
@ -1750,6 +1751,8 @@ channels.viewSponsoredMessage#beaedb94 channel:InputChannel random_id:bytes = Bo
channels.getSponsoredMessages#ec210fbf channel:InputChannel = messages.SponsoredMessages; channels.getSponsoredMessages#ec210fbf channel:InputChannel = messages.SponsoredMessages;
channels.getSendAs#dc770ee peer:InputPeer = channels.SendAsPeers; channels.getSendAs#dc770ee peer:InputPeer = channels.SendAsPeers;
channels.deleteParticipantHistory#367544db channel:InputChannel participant:InputPeer = messages.AffectedHistory; channels.deleteParticipantHistory#367544db channel:InputChannel participant:InputPeer = messages.AffectedHistory;
channels.toggleJoinToSend#e4cb9580 channel:InputChannel enabled:Bool = Updates;
channels.toggleJoinRequest#4c2985b6 channel:InputChannel enabled:Bool = Updates;
bots.sendCustomRequest#aa2769ed custom_method:string params:DataJSON = DataJSON; bots.sendCustomRequest#aa2769ed custom_method:string params:DataJSON = DataJSON;
bots.answerWebhookJSONQuery#e6213f4d query_id:long data:DataJSON = Bool; bots.answerWebhookJSONQuery#e6213f4d query_id:long data:DataJSON = Bool;

View file

@ -123,9 +123,9 @@ void InviteLinks::performCreate(
)).done([=](const MTPExportedChatInvite &result) { )).done([=](const MTPExportedChatInvite &result) {
const auto callbacks = _createCallbacks.take(peer); const auto callbacks = _createCallbacks.take(peer);
const auto link = prepend(peer, peer->session().user(), result); const auto link = prepend(peer, peer->session().user(), result);
if (callbacks) { if (link && callbacks) {
for (const auto &callback : *callbacks) { for (const auto &callback : *callbacks) {
callback(link); callback(*link);
} }
} }
}).fail([=] { }).fail([=] {
@ -155,15 +155,18 @@ auto InviteLinks::lookupMyPermanent(const Links &links) const -> const Link* {
auto InviteLinks::prepend( auto InviteLinks::prepend(
not_null<PeerData*> peer, not_null<PeerData*> peer,
not_null<UserData*> admin, not_null<UserData*> admin,
const MTPExportedChatInvite &invite) -> Link { const MTPExportedChatInvite &invite) -> std::optional<Link> {
const auto link = parse(peer, invite); const auto link = parse(peer, invite);
if (!link) {
return link;
}
if (admin->isSelf()) { if (admin->isSelf()) {
prependMyToFirstSlice(peer, admin, link); prependMyToFirstSlice(peer, admin, *link);
} }
_updates.fire(Update{ _updates.fire(Update{
.peer = peer, .peer = peer,
.admin = admin, .admin = admin,
.now = link .now = *link
}); });
return link; return link;
} }
@ -281,6 +284,9 @@ void InviteLinks::performEdit(
result.match([&](const auto &data) { result.match([&](const auto &data) {
_api->session().data().processUsers(data.vusers()); _api->session().data().processUsers(data.vusers());
const auto link = parse(peer, data.vinvite()); const auto link = parse(peer, data.vinvite());
if (!link) {
return;
}
auto i = _firstSlices.find(peer); auto i = _firstSlices.find(peer);
if (i != end(_firstSlices)) { if (i != end(_firstSlices)) {
const auto j = ranges::find( const auto j = ranges::find(
@ -288,18 +294,18 @@ void InviteLinks::performEdit(
key.link, key.link,
&Link::link); &Link::link);
if (j != end(i->second.links)) { if (j != end(i->second.links)) {
if (link.revoked && !j->revoked) { if (link->revoked && !j->revoked) {
i->second.links.erase(j); i->second.links.erase(j);
if (i->second.count > 0) { if (i->second.count > 0) {
--i->second.count; --i->second.count;
} }
} else { } else {
*j = link; *j = *link;
} }
} }
} }
for (const auto &callback : *callbacks) { for (const auto &callback : *callbacks) {
callback(link); callback(*link);
} }
_updates.fire(Update{ _updates.fire(Update{
.peer = peer, .peer = peer,
@ -617,7 +623,11 @@ void InviteLinks::setMyPermanent(
not_null<PeerData*> peer, not_null<PeerData*> peer,
const MTPExportedChatInvite &invite) { const MTPExportedChatInvite &invite) {
auto link = parse(peer, invite); auto link = parse(peer, invite);
if (!link.permanent) { if (!link) {
LOG(("API Error: "
"InviteLinks::setPermanent called with non-link."));
return;
} else if (!link->permanent) {
LOG(("API Error: " LOG(("API Error: "
"InviteLinks::setPermanent called with non-permanent link.")); "InviteLinks::setPermanent called with non-permanent link."));
return; return;
@ -632,13 +642,13 @@ void InviteLinks::setMyPermanent(
.admin = peer->session().user(), .admin = peer->session().user(),
}; };
if (const auto permanent = lookupMyPermanent(links)) { if (const auto permanent = lookupMyPermanent(links)) {
if (permanent->link == link.link) { if (permanent->link == link->link) {
if (permanent->usage != link.usage) { if (permanent->usage != link->usage) {
permanent->usage = link.usage; permanent->usage = link->usage;
_updates.fire(Update{ _updates.fire(Update{
.peer = peer, .peer = peer,
.admin = peer->session().user(), .admin = peer->session().user(),
.was = link.link, .was = link->link,
.now = *permanent .now = *permanent
}); });
} }
@ -652,9 +662,9 @@ void InviteLinks::setMyPermanent(
--links.count; --links.count;
} }
} }
links.links.insert(begin(links.links), link); links.links.insert(begin(links.links), *link);
editPermanentLink(peer, link.link); editPermanentLink(peer, link->link);
notify(peer); notify(peer);
if (updateOldPermanent.now) { if (updateOldPermanent.now) {
@ -722,9 +732,10 @@ auto InviteLinks::parseSlice(
peer->session().data().processUsers(data.vusers()); peer->session().data().processUsers(data.vusers());
result.count = data.vcount().v; result.count = data.vcount().v;
for (const auto &invite : data.vinvites().v) { for (const auto &invite : data.vinvites().v) {
const auto link = parse(peer, invite); if (const auto link = parse(peer, invite)) {
if (!permanent || link.link != permanent->link) { if (!permanent || link->link != permanent->link) {
result.links.push_back(link); result.links.push_back(*link);
}
} }
} }
}); });
@ -733,9 +744,9 @@ auto InviteLinks::parseSlice(
auto InviteLinks::parse( auto InviteLinks::parse(
not_null<PeerData*> peer, not_null<PeerData*> peer,
const MTPExportedChatInvite &invite) const -> Link { const MTPExportedChatInvite &invite) const -> std::optional<Link> {
return invite.match([&](const MTPDchatInviteExported &data) { return invite.match([&](const MTPDchatInviteExported &data) {
return Link{ return std::optional<Link>(Link{
.link = qs(data.vlink()), .link = qs(data.vlink()),
.label = qs(data.vtitle().value_or_empty()), .label = qs(data.vtitle().value_or_empty()),
.admin = peer->session().data().user(data.vadmin_id()), .admin = peer->session().data().user(data.vadmin_id()),
@ -748,7 +759,9 @@ auto InviteLinks::parse(
.requestApproval = data.is_request_needed(), .requestApproval = data.is_request_needed(),
.permanent = data.is_permanent(), .permanent = data.is_permanent(),
.revoked = data.is_revoked(), .revoked = data.is_revoked(),
}; });
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return std::optional<Link>();
}); });
} }

View file

@ -157,13 +157,13 @@ private:
[[nodiscard]] Links parseSlice( [[nodiscard]] Links parseSlice(
not_null<PeerData*> peer, not_null<PeerData*> peer,
const MTPmessages_ExportedChatInvites &slice) const; const MTPmessages_ExportedChatInvites &slice) const;
[[nodiscard]] Link parse( [[nodiscard]] std::optional<Link> parse(
not_null<PeerData*> peer, not_null<PeerData*> peer,
const MTPExportedChatInvite &invite) const; const MTPExportedChatInvite &invite) const;
[[nodiscard]] Link *lookupMyPermanent(not_null<PeerData*> peer); [[nodiscard]] Link *lookupMyPermanent(not_null<PeerData*> peer);
[[nodiscard]] Link *lookupMyPermanent(Links &links); [[nodiscard]] Link *lookupMyPermanent(Links &links);
[[nodiscard]] const Link *lookupMyPermanent(const Links &links) const; [[nodiscard]] const Link *lookupMyPermanent(const Links &links) const;
Link prepend( std::optional<Link> prepend(
not_null<PeerData*> peer, not_null<PeerData*> peer,
not_null<UserData*> admin, not_null<UserData*> admin,
const MTPExportedChatInvite &invite); const MTPExportedChatInvite &invite);

View file

@ -1988,7 +1988,7 @@ void Updates::feedUpdate(const MTPUpdate &update) {
const auto botId = UserId(d.vbot_id().v); const auto botId = UserId(d.vbot_id().v);
if (const auto user = peer->asUser()) { if (const auto user = peer->asUser()) {
if (user->isBot() && user->id == peerFromUser(botId)) { if (user->isBot() && user->id == peerFromUser(botId)) {
if (Data::UpdateBotCommands(user->botInfo->commands, d.vcommands())) { if (Data::UpdateBotCommands(user->botInfo->commands, &d.vcommands())) {
session().data().botCommandsChanged(user); session().data().botCommandsChanged(user);
} }
} }
@ -2015,7 +2015,7 @@ void Updates::feedUpdate(const MTPUpdate &update) {
const auto &d = update.c_updateBotMenuButton(); const auto &d = update.c_updateBotMenuButton();
if (const auto bot = session().data().userLoaded(d.vbot_id())) { if (const auto bot = session().data().userLoaded(d.vbot_id())) {
if (const auto info = bot->botInfo.get(); info && info->inited) { if (const auto info = bot->botInfo.get(); info && info->inited) {
if (Data::ApplyBotMenuButton(info, d.vbutton())) { if (Data::ApplyBotMenuButton(info, &d.vbutton())) {
session().data().botCommandsChanged(bot); session().data().botCommandsChanged(bot);
} }
} }

View file

@ -56,7 +56,7 @@ bool MegagroupInfo::updateBotCommands(const MTPVector<MTPBotInfo> &data) {
bool MegagroupInfo::updateBotCommands( bool MegagroupInfo::updateBotCommands(
UserId botId, UserId botId,
const MTPVector<MTPBotCommand> &data) { const MTPVector<MTPBotCommand> &data) {
return Data::UpdateBotCommands(_botCommands, botId, data); return Data::UpdateBotCommands(_botCommands, botId, &data);
} }
ChannelData::ChannelData(not_null<Data::Session*> owner, PeerId id) ChannelData::ChannelData(not_null<Data::Session*> owner, PeerId id)

View file

@ -263,7 +263,7 @@ void ChatData::setBotCommands(const MTPVector<MTPBotInfo> &data) {
void ChatData::setBotCommands( void ChatData::setBotCommands(
UserId botId, UserId botId,
const MTPVector<MTPBotCommand> &data) { const MTPVector<MTPBotCommand> &data) {
if (Data::UpdateBotCommands(_botCommands, botId, data)) { if (Data::UpdateBotCommands(_botCommands, botId, &data)) {
owner().botCommandsChanged(this); owner().botCommandsChanged(this);
} }
} }

View file

@ -90,8 +90,13 @@ PeerId FakePeerIdForJustName(const QString &name) {
bool UpdateBotCommands( bool UpdateBotCommands(
std::vector<BotCommand> &commands, std::vector<BotCommand> &commands,
const MTPVector<MTPBotCommand> &data) { const MTPVector<MTPBotCommand> *data) {
const auto &v = data.v; if (!data) {
const auto changed = !commands.empty();
commands.clear();
return changed;
}
const auto &v = data->v;
commands.reserve(v.size()); commands.reserve(v.size());
auto result = false; auto result = false;
auto index = 0; auto index = 0;
@ -127,8 +132,8 @@ bool UpdateBotCommands(
bool UpdateBotCommands( bool UpdateBotCommands(
base::flat_map<UserId, std::vector<BotCommand>> &commands, base::flat_map<UserId, std::vector<BotCommand>> &commands,
UserId botId, UserId botId,
const MTPVector<MTPBotCommand> &data) { const MTPVector<MTPBotCommand> *data) {
return data.v.isEmpty() return (!data || data->v.isEmpty())
? commands.remove(botId) ? commands.remove(botId)
: UpdateBotCommands(commands[botId], data); : UpdateBotCommands(commands[botId], data);
} }
@ -141,7 +146,11 @@ bool UpdateBotCommands(
filled.reserve(data.v.size()); filled.reserve(data.v.size());
for (const auto &item : data.v) { for (const auto &item : data.v) {
item.match([&](const MTPDbotInfo &data) { item.match([&](const MTPDbotInfo &data) {
const auto id = UserId(data.vuser_id().v); if (!data.vuser_id()) {
LOG(("API Error: BotInfo without UserId for commands map."));
return;
}
const auto id = UserId(*data.vuser_id());
if (!filled.emplace(id).second) { if (!filled.emplace(id).second) {
LOG(("API Error: Two BotInfo for a single bot.")); LOG(("API Error: Two BotInfo for a single bot."));
return; return;
@ -163,14 +172,16 @@ bool UpdateBotCommands(
bool ApplyBotMenuButton( bool ApplyBotMenuButton(
not_null<BotInfo*> info, not_null<BotInfo*> info,
const MTPBotMenuButton &button) { const MTPBotMenuButton *button) {
auto text = QString(); auto text = QString();
auto url = QString(); auto url = QString();
button.match([&](const MTPDbotMenuButton &data) { if (button) {
text = qs(data.vtext()); button->match([&](const MTPDbotMenuButton &data) {
url = qs(data.vurl()); text = qs(data.vtext());
}, [&](const auto &) { url = qs(data.vurl());
}); }, [&](const auto &) {
});
}
const auto changed = (info->botMenuButtonText != text) const auto changed = (info->botMenuButtonText != text)
|| (info->botMenuButtonUrl != url); || (info->botMenuButtonUrl != url);

View file

@ -102,17 +102,17 @@ struct UnavailableReason {
bool UpdateBotCommands( bool UpdateBotCommands(
std::vector<BotCommand> &commands, std::vector<BotCommand> &commands,
const MTPVector<MTPBotCommand> &data); const MTPVector<MTPBotCommand> *data);
bool UpdateBotCommands( bool UpdateBotCommands(
base::flat_map<UserId, std::vector<BotCommand>> &commands, base::flat_map<UserId, std::vector<BotCommand>> &commands,
UserId botId, UserId botId,
const MTPVector<MTPBotCommand> &data); const MTPVector<MTPBotCommand> *data);
bool UpdateBotCommands( bool UpdateBotCommands(
base::flat_map<UserId, std::vector<BotCommand>> &commands, base::flat_map<UserId, std::vector<BotCommand>> &commands,
const MTPVector<MTPBotInfo> &data); const MTPVector<MTPBotInfo> &data);
bool ApplyBotMenuButton( bool ApplyBotMenuButton(
not_null<BotInfo*> info, not_null<BotInfo*> info,
const MTPBotMenuButton &button); const MTPBotMenuButton *button);
} // namespace Data } // namespace Data

View file

@ -121,11 +121,13 @@ void UserData::setBotInfo(const MTPBotInfo &info) {
switch (info.type()) { switch (info.type()) {
case mtpc_botInfo: { case mtpc_botInfo: {
const auto &d = info.c_botInfo(); const auto &d = info.c_botInfo();
if (peerFromUser(d.vuser_id().v) != id || !isBot()) { if (!isBot()) {
return;
} else if (d.vuser_id() && peerFromUser(*d.vuser_id()) != id) {
return; return;
} }
QString desc = qs(d.vdescription()); QString desc = qs(d.vdescription().value_or_empty());
if (botInfo->description != desc) { if (botInfo->description != desc) {
botInfo->description = desc; botInfo->description = desc;
botInfo->text = Ui::Text::String(st::msgMinWidth); botInfo->text = Ui::Text::String(st::msgMinWidth);

View file

@ -302,15 +302,23 @@ TextWithEntities GeneratePermissionsChangeText(
return result; return result;
} }
QString PublicJoinLink() {
return u"(public_join_link)"_q;
}
QString ExtractInviteLink(const MTPExportedChatInvite &data) { QString ExtractInviteLink(const MTPExportedChatInvite &data) {
return data.match([&](const MTPDchatInviteExported &data) { return data.match([&](const MTPDchatInviteExported &data) {
return qs(data.vlink()); return qs(data.vlink());
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return PublicJoinLink();
}); });
} }
QString ExtractInviteLinkLabel(const MTPExportedChatInvite &data) { QString ExtractInviteLinkLabel(const MTPExportedChatInvite &data) {
return data.match([&](const MTPDchatInviteExported &data) { return data.match([&](const MTPDchatInviteExported &data) {
return qs(data.vtitle().value_or_empty()); return qs(data.vtitle().value_or_empty());
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return PublicJoinLink();
}); });
} }
@ -361,21 +369,29 @@ TextWithEntities GenerateInviteLinkChangeText(
const auto label = [](const MTPExportedChatInvite &link) { const auto label = [](const MTPExportedChatInvite &link) {
return link.match([](const MTPDchatInviteExported &data) { return link.match([](const MTPDchatInviteExported &data) {
return qs(data.vtitle().value_or_empty()); return qs(data.vtitle().value_or_empty());
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return PublicJoinLink();
}); });
}; };
const auto expireDate = [](const MTPExportedChatInvite &link) { const auto expireDate = [](const MTPExportedChatInvite &link) {
return link.match([](const MTPDchatInviteExported &data) { return link.match([](const MTPDchatInviteExported &data) {
return data.vexpire_date().value_or_empty(); return data.vexpire_date().value_or_empty();
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return TimeId();
}); });
}; };
const auto usageLimit = [](const MTPExportedChatInvite &link) { const auto usageLimit = [](const MTPExportedChatInvite &link) {
return link.match([](const MTPDchatInviteExported &data) { return link.match([](const MTPDchatInviteExported &data) {
return data.vusage_limit().value_or_empty(); return data.vusage_limit().value_or_empty();
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return 0;
}); });
}; };
const auto requestApproval = [](const MTPExportedChatInvite &link) { const auto requestApproval = [](const MTPExportedChatInvite &link) {
return link.match([](const MTPDchatInviteExported &data) { return link.match([](const MTPDchatInviteExported &data) {
return data.is_request_needed(); return data.is_request_needed();
}, [&](const MTPDchatInvitePublicJoinRequests &data) {
return true;
}); });
}; };
const auto wrapDate = [](TimeId date) { const auto wrapDate = [](TimeId date) {