/*
This file is part of Telegram Desktop,
the official desktop application for the Telegram messaging service.

For license and copyright information please follow this link:
https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
*/
#include "api/api_read_metrics.h"

#include "apiwrap.h"
#include "data/data_peer.h"

namespace Api {
namespace {

constexpr auto kSendTimeout = crl::time(5000);

} // namespace

ReadMetrics::ReadMetrics(not_null<ApiWrap*> api)
: _api(&api->instance())
, _timer([=] { send(); }) {
}

void ReadMetrics::add(
		not_null<PeerData*> peer,
		FinalizedReadMetric metric) {
	_pending[peer].push_back(metric);
	if (!_timer.isActive()) {
		_timer.callOnce(kSendTimeout);
	}
}

void ReadMetrics::send() {
	for (auto i = _pending.begin(); i != _pending.end();) {
		if (_requests.contains(i->first)) {
			++i;
			continue;
		}

		auto metrics = QVector<MTPInputMessageReadMetric>();
		metrics.reserve(i->second.size());
		for (const auto &m : i->second) {
			metrics.push_back(MTP_inputMessageReadMetric(
				MTP_int(m.msgId.bare),
				MTP_long(m.viewId),
				MTP_int(m.timeInViewMs),
				MTP_int(m.activeTimeInViewMs),
				MTP_int(m.heightToViewportRatioPermille),
				MTP_int(m.seenRangeRatioPermille)));
		}
		const auto peer = i->first;
		const auto finish = [=] {
			_requests.erase(peer);
			if (!_pending.empty() && !_timer.isActive()) {
				_timer.callOnce(kSendTimeout);
			}
		};
		const auto requestId = _api.request(MTPmessages_ReportReadMetrics(
			peer->input(),
			MTP_vector<MTPInputMessageReadMetric>(std::move(metrics))
		)).done([=](const MTPBool &) {
			finish();
		}).fail([=](const MTP::Error &) {
			finish();
		}).send();

		_requests.emplace(peer, requestId);
		i = _pending.erase(i);
	}
}

} // namespace Api