Function PreparedContextAt

Telegram/SourceFiles/api/api_who_reacted.cpp:189–250

}

[[nodiscard]] not_null<Context*> PreparedContextAt(
		not_null<QWidget*> key,
		not_null<Main::Session*> session) {
	const auto context = ContextAt(key);
	if (context->subscriptions.contains(session)) {
		return context;
	}
	session->changes().messageUpdates(
		Data::MessageUpdate::Flag::Destroyed
	) | rpl::on_next([=](const Data::MessageUpdate &update) {
		const auto i = context->cachedRead.find(update.item);
		if (i != end(context->cachedRead)) {
			session->api().request(i->second.requestId).cancel();
			context->cachedRead.erase(i);
		}
		const auto j = context->cachedReacted.find(update.item);
		if (j != end(context->cachedReacted)) {
			for (auto &[reaction, entry] : j->second) {
				session->api().request(entry.requestId).cancel();
			}
			context->cachedReacted.erase(j);
		}
	}, context->subscriptions[session]);
	session->data().reactionsRemoved(
	) | rpl::on_next([=](const Data::ReactionsRemoved &update) {
		for (auto &[item, map] : context->cachedReacted) {
			if (item->history()->peer->id != update.peer->id) {
				continue;
			} else if (update.msgId && item->id != update.msgId) {
				continue;
			}
			for (auto &entry : map) {
				auto data = entry.second.data.current();
				if (ApplyReactionsRemovedToCachedData(data, update)) {
					entry.second.data = std::move(data);
				}
			}
		}
	}, context->subscriptions[session]);
	Data::AmPremiumValue(
		session
	) | rpl::skip(1) | rpl::filter(
		rpl::mappers::_1
	) | rpl::on_next([=] {
		for (auto &[item, cache] : context->cachedRead) {
			if (cache.data.current().state == Ui::WhoReadState::MyHidden) {
				cache.data = Peers{ .state = Ui::WhoReadState::Unknown };
			}
		}
	}, context->subscriptions[session]);
	session->api().globalPrivacy().hideReadTime(
	) | rpl::skip(1) | rpl::filter(
		!rpl::mappers::_1
	) | rpl::on_next([=] {
		for (auto &[item, cache] : context->cachedRead) {
			if (cache.data.current().state == Ui::WhoReadState::MyHidden) {
				cache.data = Peers{ .state = Ui::WhoReadState::Unknown };
			}