Method processReceivedRichMessage

Telegram/SourceFiles/iv/iv_instance.cpp:1603–1652

}

auto Instance::processReceivedRichMessage(
	not_null<Main::Session*> session,
	FullMsgId itemId,
	const RichMessageGeneration &generation,
	const MTPmessages_Messages &result)
-> ProcessReceivedRichMessageResult {
	const auto owner = &session->data();
	auto processed = ProcessReceivedRichMessageResult();
	auto page = std::shared_ptr<const RichPage>();
	result.match([&](const MTPDmessages_messagesNotModified &) {
		LOG(("API Error: received messages.messagesNotModified!"));
	}, [&](const auto &data) {
		owner->processUsers(data.vusers());
		owner->processChats(data.vchats());
		for (const auto &message : data.vmessages().v) {
			if (message.type() != mtpc_message) {
				continue;
			}
			const auto &parsed = message.c_message();
			if (MsgId(parsed.vid().v) != itemId.msg) {
				continue;
			}
			const auto richMessage = parsed.vrich_message();
			page = richMessage ? ParseRichPage(session, *richMessage) : nullptr;
			break;
		}
	});
	const auto peer = owner->peer(itemId.peer);
	result.match([&](const MTPDmessages_channelMessages &data) {
		if (const auto channel = peer->asChannel()) {
			channel->ptsReceived(data.vpts().v);
		} else {
			LOG(("App Error: received messages.channelMessages!"));
		}
	}, [](const auto &) {});
	result.match([&](const MTPDmessages_messagesNotModified &) {
	}, [&](const auto &data) {
		peer->processTopics(data.vtopics());
	});
	const auto current = owner->message(itemId);
	if (!current
		|| !MatchesRichMessageGeneration(not_null{ current }, generation)) {
		return processed;
	}
	if (page) {
		current->setFullRichPage(page);
	}
	processed.page = std::move(page);
	return processed;
}

void Instance::finishRichMessageRequest(
		not_null<Main::Session*> session,