Method requestReactions

Telegram/SourceFiles/api/api_unread_things.cpp:152–187

}

void UnreadThings::requestReactions(
		not_null<Data::Thread*> thread,
		int loaded) {
	if (_reactionsRequests.contains(thread)) {
		return;
	}
	const auto offsetId = loaded
		? std::max(thread->unreadReactions().maxLoaded(), MsgId(1))
		: MsgId(1);
	const auto limit = loaded ? kNextRequestLimit : kFirstRequestLimit;
	const auto addOffset = loaded ? -(limit + 1) : -limit;
	const auto maxId = 0;
	const auto minId = 0;
	const auto history = thread->owningHistory();
	const auto sublist = thread->asSublist();
	const auto topic = thread->asTopic();
	using Flag = MTPmessages_GetUnreadReactions::Flag;
	const auto requestId = _api->request(MTPmessages_GetUnreadReactions(
		MTP_flags((topic ? Flag::f_top_msg_id : Flag())
			| (sublist ? Flag::f_saved_peer_id : Flag())),
		history->peer->input(),
		MTP_int(topic ? topic->rootId() : 0),
		(sublist ? sublist->sublistPeer()->input() : MTPInputPeer()),
		MTP_int(offsetId),
		MTP_int(addOffset),
		MTP_int(limit),
		MTP_int(maxId),
		MTP_int(minId)
	)).done([=](const MTPmessages_Messages &result) {
		_reactionsRequests.remove(thread);
		thread->unreadReactions().addSlice(result, loaded);
	}).fail([=] {
		_reactionsRequests.remove(thread);
	}).send();
	_reactionsRequests.emplace(thread, requestId);
}

void UnreadThings::requestPollVotes(
		not_null<Data::Thread*> thread,