tdesktop/Telegram/SourceFiles/info/statistics/info_statistics_inner_widge...

718 lines
20 KiB
C++

/*
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 "info/statistics/info_statistics_inner_widget.h"
#include "api/api_statistics.h"
#include "apiwrap.h"
#include "data/data_peer.h"
#include "data/data_session.h"
#include "history/history_item.h"
#include "info/info_controller.h"
#include "info/info_memento.h"
#include "info/statistics/info_statistics_list_controllers.h"
#include "info/statistics/info_statistics_recent_message.h"
#include "info/statistics/info_statistics_widget.h"
#include "lang/lang_keys.h"
#include "lottie/lottie_icon.h"
#include "main/main_session.h"
#include "settings/settings_common.h"
#include "statistics/chart_widget.h"
#include "statistics/statistics_common.h"
#include "statistics/widgets/chart_header_widget.h"
#include "ui/layers/generic_box.h"
#include "ui/rect.h"
#include "ui/toast/toast.h"
#include "ui/widgets/buttons.h"
#include "ui/widgets/scroll_area.h"
#include "ui/wrap/slide_wrap.h"
#include "styles/style_boxes.h"
#include "styles/style_settings.h"
#include "styles/style_statistics.h"
namespace Info::Statistics {
namespace {
struct Descriptor final {
not_null<PeerData*> peer;
not_null<Api::Statistics*> api;
not_null<QWidget*> toastParent;
};
void ProcessZoom(
const Descriptor &d,
not_null<Statistic::ChartWidget*> widget,
const QString &zoomToken,
Statistic::ChartViewType type) {
if (zoomToken.isEmpty()) {
return;
}
widget->zoomRequests(
) | rpl::start_with_next([=](float64 x) {
d.api->requestZoom(
d.peer,
zoomToken,
x
) | rpl::start_with_next_error_done([=](
const Data::StatisticalGraph &graph) {
if (graph.chart) {
widget->setZoomedChartData(graph.chart, x, type);
} else if (!graph.error.isEmpty()) {
Ui::Toast::Show(d.toastParent, graph.error);
}
}, [=](const QString &error) {
}, [=] {
}, widget->lifetime());
}, widget->lifetime());
}
void FillStatistic(
not_null<Ui::VerticalLayout*> content,
const Descriptor &descriptor,
Data::AnyStatistics &stats) {
using Type = Statistic::ChartViewType;
const auto &padding = st::statisticsChartEntryPadding;
const auto &m = st::statisticsLayerMargins;
const auto addSkip = [&](not_null<Ui::VerticalLayout*> c) {
::Settings::AddSkip(c, padding.bottom());
::Settings::AddDivider(c);
::Settings::AddSkip(c, padding.top());
};
const auto addChart = [&](
Data::StatisticalGraph &graphData,
rpl::producer<QString> &&title,
Statistic::ChartViewType type) {
if (graphData.chart) {
const auto widget = content->add(
object_ptr<Statistic::ChartWidget>(content),
m);
widget->setChartData(graphData.chart, type);
ProcessZoom(descriptor, widget, graphData.zoomToken, type);
widget->setTitle(std::move(title));
addSkip(content);
} else if (!graphData.zoomToken.isEmpty()) {
const auto wrap = content->add(
object_ptr<Ui::SlideWrap<Ui::VerticalLayout>>(
content,
object_ptr<Ui::VerticalLayout>(content)));
wrap->toggle(false, anim::type::instant);
const auto widget = wrap->entity()->add(
object_ptr<Statistic::ChartWidget>(content),
m);
descriptor.api->requestZoom(
descriptor.peer,
graphData.zoomToken,
0
) | rpl::start_with_next_error_done([=, graphPtr = &graphData](
const Data::StatisticalGraph &graph) mutable {
{
// Save the loaded async data to cache.
// Guarded by content->lifetime().
*graphPtr = graph;
}
if (graph.chart) {
widget->setChartData(graph.chart, type);
wrap->toggle(true, anim::type::normal);
ProcessZoom(descriptor, widget, graph.zoomToken, type);
widget->setTitle(rpl::duplicate(title));
} else if (!graph.error.isEmpty()) {
Ui::Toast::Show(descriptor.toastParent, graph.error);
}
}, [=](const QString &error) {
}, [=] {
}, content->lifetime());
addSkip(wrap->entity());
}
};
addSkip(content);
if (stats.channel) {
addChart(
stats.channel.memberCountGraph,
tr::lng_chart_title_member_count(),
Type::Linear);
addChart(
stats.channel.joinGraph,
tr::lng_chart_title_join(),
Type::Linear);
addChart(
stats.channel.muteGraph,
tr::lng_chart_title_mute(),
Type::Linear);
addChart(
stats.channel.viewCountByHourGraph,
tr::lng_chart_title_view_count_by_hour(),
Type::Linear);
addChart(
stats.channel.viewCountBySourceGraph,
tr::lng_chart_title_view_count_by_source(),
Type::Stack);
addChart(
stats.channel.joinBySourceGraph,
tr::lng_chart_title_join_by_source(),
Type::Stack);
addChart(
stats.channel.languageGraph,
tr::lng_chart_title_language(),
Type::StackLinear);
addChart(
stats.channel.messageInteractionGraph,
tr::lng_chart_title_message_interaction(),
Type::DoubleLinear);
addChart(
stats.channel.instantViewInteractionGraph,
tr::lng_chart_title_instant_view_interaction(),
Type::DoubleLinear);
} else if (stats.supergroup) {
addChart(
stats.supergroup.memberCountGraph,
tr::lng_chart_title_member_count(),
Type::Linear);
addChart(
stats.supergroup.joinGraph,
tr::lng_chart_title_group_join(),
Type::Linear);
addChart(
stats.supergroup.joinBySourceGraph,
tr::lng_chart_title_group_join_by_source(),
Type::Stack);
addChart(
stats.supergroup.languageGraph,
tr::lng_chart_title_group_language(),
Type::StackLinear);
addChart(
stats.supergroup.messageContentGraph,
tr::lng_chart_title_group_message_content(),
Type::Stack);
addChart(
stats.supergroup.actionGraph,
tr::lng_chart_title_group_action(),
Type::DoubleLinear);
addChart(
stats.supergroup.dayGraph,
tr::lng_chart_title_group_day(),
Type::Linear);
addChart(
stats.supergroup.weekGraph,
tr::lng_chart_title_group_week(),
Type::StackLinear);
} else if (stats.message) {
addChart(
stats.message.messageInteractionGraph,
tr::lng_chart_title_message_interaction(),
Type::DoubleLinear);
}
}
void FillLoading(
not_null<Ui::VerticalLayout*> container,
rpl::producer<bool> toggleOn,
rpl::producer<> showFinished) {
const auto emptyWrap = container->add(
object_ptr<Ui::SlideWrap<Ui::VerticalLayout>>(
container,
object_ptr<Ui::VerticalLayout>(container)));
emptyWrap->toggleOn(std::move(toggleOn), anim::type::instant);
const auto content = emptyWrap->entity();
auto icon = ::Settings::CreateLottieIcon(
content,
{ .name = u"stats"_q, .sizeOverride = Size(st::changePhoneIconSize) },
st::settingsBlockedListIconPadding);
(
std::move(showFinished) | rpl::take(1)
) | rpl::start_with_next([animate = std::move(icon.animate)] {
animate(anim::repeat::loop);
}, icon.widget->lifetime());
content->add(std::move(icon.widget));
content->add(
object_ptr<Ui::CenterWrap<>>(
content,
object_ptr<Ui::FlatLabel>(
content,
tr::lng_stats_loading(),
st::changePhoneTitle)),
st::changePhoneTitlePadding + st::boxRowPadding);
content->add(
object_ptr<Ui::CenterWrap<>>(
content,
object_ptr<Ui::FlatLabel>(
content,
tr::lng_stats_loading_subtext(),
st::statisticsLoadingSubtext)),
st::changePhoneDescriptionPadding + st::boxRowPadding);
::Settings::AddSkip(content, st::settingsBlockedListIconPadding.top());
}
void AddHeader(
not_null<Ui::VerticalLayout*> content,
tr::phrase<> text,
const Data::AnyStatistics &stats) {
const auto startDate = stats.channel
? stats.channel.startDate
: stats.supergroup.startDate;
const auto endDate = stats.channel
? stats.channel.endDate
: stats.supergroup.endDate;
const auto header = content->add(
object_ptr<Statistic::Header>(content),
st::statisticsLayerMargins + st::statisticsChartHeaderPadding);
header->resizeToWidth(header->width());
header->setTitle(text(tr::now));
if (!endDate || !startDate) {
header->setSubTitle({});
return;
}
const auto formatter = u"d MMM yyyy"_q;
const auto from = QDateTime::fromSecsSinceEpoch(startDate);
const auto to = QDateTime::fromSecsSinceEpoch(endDate);
header->setSubTitle(QLocale().toString(from.date(), formatter)
+ ' '
+ QChar(8212)
+ ' '
+ QLocale().toString(to.date(), formatter));
}
void FillOverview(
not_null<Ui::VerticalLayout*> content,
const Data::AnyStatistics &stats) {
using Value = Data::StatisticalValue;
const auto &channel = stats.channel;
const auto &supergroup = stats.supergroup;
::Settings::AddSkip(content, st::statisticsLayerOverviewMargins.top());
AddHeader(content, tr::lng_stats_overview_title, stats);
::Settings::AddSkip(content);
struct Second final {
QColor color;
QString text;
};
const auto parseSecond = [&](const Value &v) -> Second {
const auto diff = v.value - v.previousValue;
if (!diff) {
return {};
}
constexpr auto kTooMuchDiff = int(1'000'000);
const auto diffAbs = std::abs(diff);
const auto diffText = diffAbs > kTooMuchDiff
? Lang::FormatCountToShort(std::abs(diff)).string
: QString::number(diffAbs);
return {
(diff < 0 ? st::menuIconAttentionColor : st::settingsIconBg2)->c,
QString("%1%2 (%3%)")
.arg((diff < 0) ? QChar(0x2212) : QChar(0x002B))
.arg(diffText)
.arg(std::abs(std::round(v.growthRatePercentage * 10.) / 10.))
};
};
const auto diffBetweenHeaders = 0
+ st::statisticsOverviewValue.style.font->height
- st::statisticsHeaderTitleTextStyle.font->height;
const auto container = content->add(
object_ptr<Ui::RpWidget>(content),
st::statisticsLayerMargins);
const auto addPrimary = [&](const Value &v) {
return Ui::CreateChild<Ui::FlatLabel>(
container,
(v.value >= 0)
? Lang::FormatCountToShort(v.value).string
: QString(),
st::statisticsOverviewValue);
};
const auto addSub = [&](
not_null<Ui::RpWidget*> primary,
const Value &v,
tr::phrase<> text) {
const auto data = parseSecond(v);
const auto second = Ui::CreateChild<Ui::FlatLabel>(
container,
data.text,
st::statisticsOverviewSecondValue);
second->setTextColorOverride(data.color);
const auto sub = Ui::CreateChild<Ui::FlatLabel>(
container,
text(),
st::statisticsOverviewSubtext);
sub->setTextColorOverride(st::windowSubTextFg->c);
primary->geometryValue(
) | rpl::start_with_next([=](const QRect &g) {
const auto &padding = st::statisticsOverviewSecondValuePadding;
second->moveToLeft(
rect::right(g) + padding.left(),
g.y() + padding.top());
sub->moveToLeft(
g.x(),
st::statisticsChartHeaderHeight
- st::statisticsOverviewSubtext.style.font->height
+ g.y()
+ diffBetweenHeaders);
}, primary->lifetime());
};
const auto isChannel = (!!channel);
const auto isMessage = (!!stats.message);
const auto topLeftLabel = isChannel
? addPrimary(channel.memberCount)
: isMessage
? addPrimary({ .value = float64(stats.message.views) })
: addPrimary(supergroup.memberCount);
const auto topRightLabel = isChannel
? Ui::CreateChild<Ui::FlatLabel>(
container,
QString("%1%").arg(0.01
* std::round(channel.enabledNotificationsPercentage * 100.)),
st::statisticsOverviewValue)
: isMessage
? addPrimary({ .value = float64(stats.message.publicForwards) })
: addPrimary(supergroup.messageCount);
const auto bottomLeftLabel = isChannel
? addPrimary(channel.meanViewCount)
: isMessage
? addPrimary({ .value = float64(stats.message.privateForwards) })
: addPrimary(supergroup.viewerCount);
const auto bottomRightLabel = isChannel
? addPrimary(channel.meanShareCount)
: isMessage
? addPrimary({ .value = -1. })
: addPrimary(supergroup.senderCount);
if (const auto &s = channel) {
addSub(
topLeftLabel,
s.memberCount,
tr::lng_stats_overview_member_count);
addSub(
topRightLabel,
{},
tr::lng_stats_overview_enabled_notifications);
addSub(
bottomLeftLabel,
s.meanViewCount,
tr::lng_stats_overview_mean_view_count);
addSub(
bottomRightLabel,
s.meanShareCount,
tr::lng_stats_overview_mean_share_count);
} else if (const auto &s = supergroup) {
addSub(
topLeftLabel,
s.memberCount,
tr::lng_manage_peer_members);
addSub(
topRightLabel,
s.messageCount,
tr::lng_stats_overview_messages);
addSub(
bottomLeftLabel,
s.viewerCount,
tr::lng_stats_overview_group_mean_view_count);
addSub(
bottomRightLabel,
s.senderCount,
tr::lng_stats_overview_group_mean_post_count);
} else if (const auto &s = stats.message) {
if (s.views >= 0) {
addSub(
topLeftLabel,
{},
tr::lng_stats_overview_message_views);
}
if (s.publicForwards >= 0) {
addSub(
topRightLabel,
{},
tr::lng_stats_overview_message_public_shares);
}
if (s.privateForwards >= 0) {
addSub(
bottomLeftLabel,
{},
tr::lng_stats_overview_message_private_shares);
}
}
container->showChildren();
container->resize(container->width(), topLeftLabel->height() * 5);
container->sizeValue(
) | rpl::start_with_next([=](const QSize &s) {
const auto halfWidth = s.width() / 2;
{
const auto &p = st::statisticsOverviewValuePadding;
topLeftLabel->moveToLeft(p.left(), p.top());
}
topRightLabel->moveToLeft(
topLeftLabel->x() + halfWidth + st::statisticsOverviewRightSkip,
topLeftLabel->y());
bottomLeftLabel->moveToLeft(
topLeftLabel->x(),
topLeftLabel->y() + st::statisticsOverviewMidSkip);
bottomRightLabel->moveToLeft(
topRightLabel->x(),
bottomLeftLabel->y());
}, container->lifetime());
::Settings::AddSkip(content, st::statisticsLayerOverviewMargins.bottom());
}
} // namespace
InnerWidget::InnerWidget(
QWidget *parent,
not_null<Controller*> controller,
not_null<PeerData*> peer,
FullMsgId contextId)
: VerticalLayout(parent)
, _controller(controller)
, _peer(peer)
, _contextId(contextId) {
}
void InnerWidget::load() {
const auto inner = this;
const auto descriptor = Descriptor{
_peer,
lifetime().make_state<Api::Statistics>(&_peer->session().api()),
_controller->uiShow()->toastParent(),
};
FillLoading(
inner,
_loaded.events_starting_with(false) | rpl::map(!rpl::mappers::_1),
_showFinished.events());
const auto finishLoading = [=] {
_loaded.fire(true);
inner->resizeToWidth(width());
inner->showChildren();
};
_showFinished.events(
) | rpl::take(1) | rpl::start_with_next([=] {
if (!_contextId) {
descriptor.api->request(
descriptor.peer
) | rpl::start_with_done([=] {
_state.stats = Data::AnyStatistics{
descriptor.api->channelStats(),
descriptor.api->supergroupStats(),
};
fill();
finishLoading();
}, lifetime());
} else {
const auto lifetimeApi = lifetime().make_state<rpl::lifetime>();
const auto api = lifetimeApi->make_state<Api::MessageStatistics>(
descriptor.peer->asChannel(),
_contextId);
api->request([=](const Data::MessageStatistics &data) {
_state.stats = Data::AnyStatistics{ .message = data };
_state.publicForwardsFirstSlice = api->firstSlice();
fill();
finishLoading();
lifetimeApi->destroy();
});
}
}, lifetime());
}
void InnerWidget::fill() {
const auto inner = this;
const auto descriptor = Descriptor{
_peer,
lifetime().make_state<Api::Statistics>(&_peer->session().api()),
_controller->uiShow()->toastParent(),
};
FillOverview(inner, _state.stats);
FillStatistic(inner, descriptor, _state.stats);
const auto &channel = _state.stats.channel;
const auto &supergroup = _state.stats.supergroup;
const auto &message = _state.stats.message;
if (channel) {
fillRecentPosts();
} else if (supergroup) {
const auto showPeerInfo = [=](not_null<PeerData*> peer) {
_showRequests.fire({ .info = peer->id });
};
const auto addSkip = [&](
not_null<Ui::VerticalLayout*> c) {
::Settings::AddSkip(c);
::Settings::AddDivider(c);
::Settings::AddSkip(c);
::Settings::AddSkip(c);
};
if (!supergroup.topSenders.empty()) {
AddMembersList(
{ .topSenders = supergroup.topSenders },
inner,
showPeerInfo,
descriptor.peer,
tr::lng_stats_members_title());
}
if (!supergroup.topAdministrators.empty()) {
addSkip(inner);
AddMembersList(
{ .topAdministrators
= supergroup.topAdministrators },
inner,
showPeerInfo,
descriptor.peer,
tr::lng_stats_admins_title());
}
if (!supergroup.topInviters.empty()) {
addSkip(inner);
AddMembersList(
{ .topInviters = supergroup.topInviters },
inner,
showPeerInfo,
descriptor.peer,
tr::lng_stats_inviters_title());
}
} else if (message) {
AddPublicForwards(
_state.publicForwardsFirstSlice,
inner,
[=](FullMsgId id) { _showRequests.fire({ .history = id }); },
descriptor.peer,
_contextId);
}
}
void InnerWidget::fillRecentPosts() {
const auto &stats = _state.stats.channel;
if (!stats || stats.recentMessageInteractions.empty()) {
return;
}
_messagePreviews.reserve(stats.recentMessageInteractions.size());
const auto container = this;
const auto wrap = container->add(
object_ptr<Ui::SlideWrap<Ui::VerticalLayout>>(
container,
object_ptr<Ui::VerticalLayout>(container)));
const auto content = wrap->entity();
AddHeader(content, tr::lng_stats_recent_messages_title, { stats, {} });
::Settings::AddSkip(content);
const auto addMessage = [=](
not_null<Ui::VerticalLayout*> messageWrap,
not_null<HistoryItem*> item,
const Data::StatisticsMessageInteractionInfo &info) {
const auto button = messageWrap->add(
object_ptr<Ui::SettingsButton>(
messageWrap,
rpl::never<QString>(),
st::statisticsRecentPostButton));
auto it = _state.recentPostPreviews.find(item->fullId().msg);
auto cachedPreview = (it != end(_state.recentPostPreviews))
? base::take(it->second)
: QImage();
const auto raw = Ui::CreateChild<MessagePreview>(
button,
item,
info.viewsCount,
info.forwardsCount,
std::move(cachedPreview));
_messagePreviews.push_back(raw);
raw->show();
button->sizeValue(
) | rpl::start_with_next([=](const QSize &s) {
if (!s.isNull()) {
raw->setGeometry(Rect(s)
- st::statisticsRecentPostButton.padding);
}
}, raw->lifetime());
button->setClickedCallback([=, fullId = item->fullId()] {
_showRequests.fire({ .messageStatistic = fullId });
});
::Settings::AddSkip(messageWrap);
if (!wrap->toggled()) {
wrap->toggle(true, anim::type::normal);
}
};
auto foundLoaded = false;
for (const auto &recent : stats.recentMessageInteractions) {
const auto messageWrap = content->add(
object_ptr<Ui::VerticalLayout>(content));
const auto msgId = recent.messageId;
if (const auto item = _peer->owner().message(_peer, msgId)) {
addMessage(messageWrap, item, recent);
foundLoaded = true;
continue;
}
const auto callback = crl::guard(content, [=] {
if (const auto item = _peer->owner().message(_peer, msgId)) {
addMessage(messageWrap, item, recent);
content->resizeToWidth(content->width());
}
});
_peer->session().api().requestMessageData(_peer, msgId, callback);
}
if (!foundLoaded) {
wrap->toggle(false, anim::type::instant);
}
}
void InnerWidget::saveState(not_null<Memento*> memento) {
for (const auto &message : _messagePreviews) {
message->saveState(_state);
}
memento->setState(base::take(_state));
}
void InnerWidget::restoreState(not_null<Memento*> memento) {
_state = memento->state();
if (_state.stats.channel
|| _state.stats.supergroup
|| _state.stats.message) {
fill();
} else {
load();
}
Ui::RpWidget::resizeToWidth(width());
}
rpl::producer<Ui::ScrollToRequest> InnerWidget::scrollToRequests() const {
return _scrollToRequests.events();
}
auto InnerWidget::showRequests() const -> rpl::producer<ShowRequest> {
return _showRequests.events();
}
void InnerWidget::showFinished() {
_showFinished.fire({});
}
not_null<PeerData*> InnerWidget::peer() const {
return _peer;
}
FullMsgId InnerWidget::contextId() const {
return _contextId;
}
} // namespace Info::Statistics