1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
//
// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2024
//
// 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/MessageReactor.h"
#include "td/telegram/Dependencies.h"
#include "td/telegram/MessageSender.h"
#include "td/utils/logging.h"
#include <algorithm>
namespace td {
MessageReactor::MessageReactor(telegram_api::object_ptr<telegram_api::messageReactor> &&reactor)
: dialog_id_(reactor->peer_id_ == nullptr ? DialogId() : DialogId(reactor->peer_id_))
, count_(reactor->count_)
, is_top_(reactor->top_)
, is_me_(reactor->my_)
, is_anonymous_(reactor->anonymous_) {
}
td_api::object_ptr<td_api::paidReactor> MessageReactor::get_paid_reactor_object(Td *td) const {
return td_api::make_object<td_api::paidReactor>(
dialog_id_ == DialogId() ? nullptr : get_message_sender_object(td, dialog_id_, "paidReactor"), count_, is_top_,
is_me_, is_anonymous_);
}
void MessageReactor::add_dependencies(Dependencies &dependencies) const {
dependencies.add_message_sender_dependencies(dialog_id_);
}
bool MessageReactor::fix_is_me(DialogId my_dialog_id) {
if (dialog_id_ == my_dialog_id) {
is_me_ = true;
return true;
}
return false;
}
void MessageReactor::fix_message_reactors(vector<MessageReactor> &reactors, bool need_warning) {
size_t TOP_REACTOR_COUNT = 3u;
if (reactors.size() > TOP_REACTOR_COUNT + 1) {
LOG(ERROR) << "Have too many " << reactors;
reactors.resize(TOP_REACTOR_COUNT + 1);
}
if (reactors.size() > TOP_REACTOR_COUNT && !reactors[TOP_REACTOR_COUNT].is_me()) {
LOG(ERROR) << "Receive unexpected " << reactors;
reactors.resize(TOP_REACTOR_COUNT);
}
if (need_warning) {
for (size_t i = 0; i < reactors.size(); i++) {
if (reactors[i].is_top_ != (i < TOP_REACTOR_COUNT)) {
LOG(ERROR) << "Receive incorrect top " << reactors;
break;
}
}
for (size_t i = 0; i + 1 < reactors.size(); i++) {
if (reactors[i].count_ < reactors[i + 1].count_) {
LOG(ERROR) << "Receive unordered " << reactors;
break;
}
}
}
bool was_me = false;
for (const auto &reactor : reactors) {
CHECK(reactor.is_valid());
if (reactor.is_me()) {
CHECK(!was_me);
was_me = true;
}
}
std::sort(reactors.begin(), reactors.end());
if (reactors.size() > TOP_REACTOR_COUNT && !reactors[TOP_REACTOR_COUNT].is_me()) {
reactors.resize(TOP_REACTOR_COUNT);
}
for (size_t i = 0; i < reactors.size(); i++) {
reactors[i].is_top_ = (i < TOP_REACTOR_COUNT);
}
}
bool operator<(const MessageReactor &lhs, const MessageReactor &rhs) {
if (lhs.count_ != rhs.count_) {
return lhs.count_ > rhs.count_;
}
return lhs.dialog_id_.get() < rhs.dialog_id_.get();
}
bool operator==(const MessageReactor &lhs, const MessageReactor &rhs) {
return lhs.dialog_id_ == rhs.dialog_id_ && lhs.count_ == rhs.count_ && lhs.is_top_ == rhs.is_top_ &&
lhs.is_me_ == rhs.is_me_ && lhs.is_anonymous_ == rhs.is_anonymous_;
}
StringBuilder &operator<<(StringBuilder &string_builder, const MessageReactor &reactor) {
return string_builder << "PaidReactor[" << reactor.dialog_id_ << " - " << reactor.count_
<< (reactor.is_me_ ? " by me" : "") << ']';
}
} // namespace td
|
