/* This file is part of Telegram Desktop, the official desktop version of Telegram messaging app, see https://telegram.org Telegram Desktop is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. It is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. In addition, as a special exception, the copyright holders give permission to link the code of portions of this program with the OpenSSL library. Full license: https://github.com/telegramdesktop/tdesktop/blob/master/LICENSE Copyright (c) 2014-2017 John Preston, https://desktop.telegram.org */ #pragma once #include "base/timer.h" #include "core/single_timer.h" #include "mtproto/sender.h" class AuthSession; namespace Api { inline const MTPVector *getChatsFromMessagesChats(const MTPmessages_Chats &chats) { switch (chats.type()) { case mtpc_messages_chats: return &chats.c_messages_chats().vchats; case mtpc_messages_chatsSlice: return &chats.c_messages_chatsSlice().vchats; } return nullptr; } } // namespace Api class ApiWrap : private MTP::Sender, private base::Subscriber { public: ApiWrap(gsl::not_null session); void start(); void applyUpdates(const MTPUpdates &updates, uint64 sentMessageRandomId = 0); using RequestMessageDataCallback = base::lambda; void requestMessageData(ChannelData *channel, MsgId msgId, RequestMessageDataCallback callback); void requestFullPeer(PeerData *peer); void requestPeer(PeerData *peer); void requestPeers(const QList &peers); void requestLastParticipants(ChannelData *channel, bool fromStart = true); void requestBots(ChannelData *channel); void requestParticipantsCountDelayed(ChannelData *channel); void processFullPeer(PeerData *peer, const MTPmessages_ChatFull &result); void processFullPeer(UserData *user, const MTPUserFull &result); void requestSelfParticipant(ChannelData *channel); void kickParticipant(PeerData *peer, UserData *user); void unblockParticipant(PeerData *peer, UserData *user); void requestWebPageDelayed(WebPageData *page); void clearWebPageRequest(WebPageData *page); void clearWebPageRequests(); void scheduleStickerSetRequest(uint64 setId, uint64 access); void requestStickerSets(); void saveStickerSets(const Stickers::Order &localOrder, const Stickers::Order &localRemoved); void joinChannel(ChannelData *channel); void leaveChannel(ChannelData *channel); void blockUser(UserData *user); void unblockUser(UserData *user); void exportInviteLink(PeerData *peer); void requestNotifySetting(PeerData *peer); void saveDraftToCloudDelayed(History *history); void savePrivacy(const MTPInputPrivacyKey &key, QVector &&rules); void handlePrivacyChange(mtpTypeId keyTypeId, const MTPVector &rules); int onlineTillFromStatus(const MTPUserStatus &status, int currentOnlineTill); base::Observable &fullPeerUpdated() { return _fullPeerUpdated; } bool isQuitPrevent(); ~ApiWrap(); private: struct MessageDataRequest { using Callbacks = QList; mtpRequestId requestId = 0; Callbacks callbacks; }; using MessageDataRequests = QMap; void requestAppChangelogs(); void addLocalAlphaChangelogs(int oldAppVersion); void updatesReceived(const MTPUpdates &updates); void checkQuitPreventFinished(); void saveDraftsToCloud(); void resolveMessageDatas(); void gotMessageDatas(ChannelData *channel, const MTPmessages_Messages &result, mtpRequestId requestId); QVector collectMessageIds(const MessageDataRequests &requests); MessageDataRequests *messageDataRequests(ChannelData *channel, bool onlyExisting = false); void gotChatFull(PeerData *peer, const MTPmessages_ChatFull &result, mtpRequestId req); void gotUserFull(UserData *user, const MTPUserFull &result, mtpRequestId req); void lastParticipantsDone(ChannelData *peer, const MTPchannels_ChannelParticipants &result, mtpRequestId req); void resolveWebPages(); void gotWebPages(ChannelData *channel, const MTPmessages_Messages &result, mtpRequestId req); void gotStickerSet(uint64 setId, const MTPmessages_StickerSet &result); PeerData *notifySettingReceived(MTPInputNotifyPeer peer, const MTPPeerNotifySettings &settings); void stickerSetDisenabled(mtpRequestId requestId); void stickersSaveOrder(); gsl::not_null _session; mtpRequestId _changelogSubscription = 0; MessageDataRequests _messageDataRequests; QMap _channelMessageDataRequests; SingleQueuedInvokation _messageDataResolveDelayed; using PeerRequests = QMap; PeerRequests _fullPeerRequests; PeerRequests _peerRequests; PeerRequests _participantsRequests; PeerRequests _botsRequests; base::DelayedCallTimer _participantsCountRequestTimer; typedef QPair KickRequest; typedef QMap KickRequests; KickRequests _kickRequests; QMap _selfParticipantRequests; QMap _webPagesPending; base::Timer _webPagesTimer; QMap > _stickerSetRequests; QMap _channelAmInRequests; QMap _blockRequests; QMap _exportInviteRequests; QMap _notifySettingRequests; QMap _draftsSaveRequestIds; base::Timer _draftsSaveTimer; OrderedSet _stickerSetDisenableRequests; Stickers::Order _stickersOrder; mtpRequestId _stickersReorderRequestId = 0; mtpRequestId _stickersClearRecentRequestId = 0; QMap _privacySaveRequests; mtpRequestId _contactsStatusesRequestId = 0; base::Observable _fullPeerUpdated; };