| 2834 | } |
| 2835 | |
| 2836 | void Session::processExistingMessages( |
| 2837 | ChannelData *channel, |
| 2838 | const MTPmessages_Messages &data) { |
| 2839 | data.match([&](const MTPDmessages_messagesNotModified&) { |
| 2840 | LOG(("API Error: received messages.messagesNotModified!")); |
| 2841 | }, [&](const auto &data) { |
| 2842 | processUsers(data.vusers()); |
| 2843 | processChats(data.vchats()); |
| 2844 | processMessages(data.vmessages(), NewMessageType::Existing); |
| 2845 | }); |
| 2846 | data.match([&](const MTPDmessages_channelMessages &data) { |
| 2847 | if (channel) { |
| 2848 | channel->ptsReceived(data.vpts().v); |
| 2849 | } else { |
| 2850 | LOG(("App Error: received messages.channelMessages!")); |
| 2851 | } |
| 2852 | }, [](const auto &) {}); |
| 2853 | data.match([&](const MTPDmessages_messagesNotModified&) { |
| 2854 | }, [&](const auto &data) { |
| 2855 | if (channel) { |
| 2856 | channel->processTopics(data.vtopics()); |
| 2857 | } |
| 2858 | }); |
| 2859 | } |
| 2860 | |
| 2861 | const Session::Messages *Session::messagesList(PeerId peerId) const { |
| 2862 | const auto i = _messages.find(peerId); |
no test coverage detected