tdlight/td/telegram/StoryInteractionInfo.cpp

93 lines
3.3 KiB
C++

//
// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2023
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
#include "td/telegram/StoryInteractionInfo.h"
#include "td/telegram/ContactsManager.h"
#include "td/telegram/Dependencies.h"
#include "td/telegram/Td.h"
#include "td/utils/algorithm.h"
#include "td/utils/logging.h"
namespace td {
StoryInteractionInfo::StoryInteractionInfo(Td *td, telegram_api::object_ptr<telegram_api::storyViews> &&story_views) {
if (story_views == nullptr) {
return;
}
for (auto &viewer_id : story_views->recent_viewers_) {
UserId user_id(viewer_id);
if (user_id.is_valid() && td->contacts_manager_->have_min_user(user_id)) {
if (recent_viewer_user_ids_.size() == MAX_RECENT_VIEWERS) {
LOG(ERROR) << "Receive too many recent story viewers: " << story_views->recent_viewers_;
break;
}
recent_viewer_user_ids_.push_back(user_id);
} else {
LOG(ERROR) << "Receive " << user_id << " as recent viewer";
}
}
view_count_ = story_views->views_count_;
if (view_count_ < 0) {
LOG(ERROR) << "Receive " << view_count_ << " story views";
view_count_ = 0;
}
reaction_count_ = story_views->reactions_count_;
if (reaction_count_ < 0) {
LOG(ERROR) << "Receive " << reaction_count_ << " story reactions";
reaction_count_ = 0;
}
has_viewers_ = story_views->has_viewers_;
}
void StoryInteractionInfo::add_dependencies(Dependencies &dependencies) const {
for (auto user_id : recent_viewer_user_ids_) {
dependencies.add(user_id);
}
}
bool StoryInteractionInfo::set_recent_viewer_user_ids(vector<UserId> &&user_ids) {
if (recent_viewer_user_ids_.empty() && view_count_ > 0) {
// don't update recent viewers for stories with expired viewers
return false;
}
if (user_ids.size() > MAX_RECENT_VIEWERS) {
user_ids.resize(MAX_RECENT_VIEWERS);
}
if (recent_viewer_user_ids_ != user_ids) {
recent_viewer_user_ids_ = std::move(user_ids);
return true;
}
return false;
}
bool StoryInteractionInfo::definitely_has_no_user(UserId user_id) const {
return !is_empty() && view_count_ == static_cast<int32>(recent_viewer_user_ids_.size()) &&
!contains(recent_viewer_user_ids_, user_id);
}
td_api::object_ptr<td_api::storyInteractionInfo> StoryInteractionInfo::get_story_interaction_info_object(Td *td) const {
if (is_empty()) {
return nullptr;
}
return td_api::make_object<td_api::storyInteractionInfo>(
view_count_, reaction_count_,
td->contacts_manager_->get_user_ids_object(recent_viewer_user_ids_, "get_story_interaction_info_object"));
}
bool operator==(const StoryInteractionInfo &lhs, const StoryInteractionInfo &rhs) {
return lhs.recent_viewer_user_ids_ == rhs.recent_viewer_user_ids_ && lhs.view_count_ == rhs.view_count_ &&
lhs.reaction_count_ == rhs.reaction_count_ && lhs.has_viewers_ == rhs.has_viewers_;
}
StringBuilder &operator<<(StringBuilder &string_builder, const StoryInteractionInfo &info) {
return string_builder << info.view_count_ << " views with " << info.reaction_count_ << " reactions by "
<< info.recent_viewer_user_ids_;
}
} // namespace td