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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
|
/*
Copyright (C) 2023-2025 Selwin van Dijk
This file is part of signalbackup-tools.
signalbackup-tools is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
signalbackup-tools is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with signalbackup-tools. If not, see <https://www.gnu.org/licenses/>.
*/
#include "signalbackup.ih"
void SignalBackup::HTMLwriteRevision(long long int msg_id, std::ofstream &filt, HTMLMessageInfo const &parent_info,
std::map<long long int, RecipientInfo> *recipient_info, bool linkify,
std::vector<std::string> const &ignoremediatypes) const
{
SqliteDB::QueryResults revision;
if (!d_database.exec("SELECT " +
d_mms_recipient_id + ", " +
+ (d_database.tableContainsColumn(d_mms_table, "to_recipient_id") ? "to_recipient_id" : "-1") + " AS to_recipient_id, "
"MIN(date_received, " + d_mms_date_sent + ") AS bubble_date, " +
d_mms_date_sent + ", " +
d_mms_type + ", "
"body, quote_missing, quote_author, quote_body, " + d_mms_delivery_receipts + ", " + d_mms_read_receipts + ", "
"json_extract(link_previews, '$[0].url') AS link_preview_url, "
"json_extract(link_previews, '$[0].title') AS link_preview_title, "
"json_extract(link_previews, '$[0].description') AS link_preview_description, " +
(d_database.tableContainsColumn(d_mms_table, "receipt_timestamp") ? "receipt_timestamp, " : "-1 AS receipt_timestamp, ") +
(d_database.tableContainsColumn(d_mms_table, "message_extras") ? "message_extras, " : "") +
"shared_contacts, quote_id, expires_in, " + d_mms_ranges + ", quote_mentions"
" FROM message WHERE _id = ?", msg_id, &revision) ||
revision.rows() != 1)
return;
long long int msg_recipient_id = revision.valueAsInt(0, d_mms_recipient_id);
std::string readable_date =
bepaald::toDateString(revision.getValueAs<long long int>(0, "bubble_date"/*d_mms_date_sent*/) / 1000, "%b %d, %Y %H:%M:%S");
bool incoming = !Types::isOutgoing(revision.getValueAs<long long int>(0, d_mms_type));
std::string body = revision.valueAsString(0, "body");
std::string shared_contacts = revision.valueAsString(0, "shared_contacts");
std::string quote_body = revision.valueAsString(0, "quote_body");
long long int type = revision.getValueAs<long long int>(0, d_mms_type);
long long int expires_in = revision.getValueAs<long long int>(0, "expires_in");
bool hasquote = !revision.isNull(0, "quote_id") && revision.getValueAs<long long int>(0, "quote_id");
bool quote_missing = revision.valueAsInt(0, "quote_missing", 0) != 0;
SqliteDB::QueryResults attachment_results;
d_database.exec("SELECT " +
d_part_table + "._id, " +
(d_database.tableContainsColumn(d_part_table, "unique_id") ? "unique_id"s : "-1 AS unique_id") + ", " +
d_part_ct + ", "
"file_name, "
+ d_part_pending + ", " +
(d_database.tableContainsColumn(d_part_table, "caption") ? "caption, "s : std::string()) +
"sticker_pack_id, " +
d_mms_table + ".date_received AS date_received "
"FROM " + d_part_table + " "
"LEFT JOIN " + d_mms_table + " ON " + d_mms_table + "._id = " + d_part_table + "." + d_part_mid + " "
"WHERE " + d_part_mid + " IS ? "
"AND quote IS ? "
" ORDER BY display_order ASC, " + d_part_table + "._id ASC", {msg_id, 0}, &attachment_results);
// check attachments for long message body -> replace cropped body & remove from attachment results
setLongMessageBody(&body, &attachment_results);
SqliteDB::QueryResults quote_attachment_results;
d_database.exec("SELECT " +
d_part_table + "._id, " +
(d_database.tableContainsColumn(d_part_table, "unique_id") ? "unique_id"s : "-1 AS unique_id") + ", " +
d_part_ct + ", "
"file_name, "
+ d_part_pending + ", " +
(d_database.tableContainsColumn(d_part_table, "caption") ? "caption, "s : std::string()) +
"sticker_pack_id, " +
d_mms_table + ".date_received AS date_received "
"FROM " + d_part_table + " "
"LEFT JOIN " + d_mms_table + " ON " + d_mms_table + "._id = " + d_part_table + "." + d_part_mid + " "
"WHERE " + d_part_mid + " IS ? "
"AND quote IS ? "
" ORDER BY display_order ASC, " + d_part_table + "._id ASC", {msg_id, 1}, "e_attachment_results);
SqliteDB::QueryResults mention_results;
d_database.exec("SELECT recipient_id, range_start, range_length FROM mention WHERE message_id IS ?", msg_id, &mention_results);
SqliteDB::QueryResults reaction_results;
d_database.exec("SELECT emoji, author_id, DATETIME(date_sent / 1000, 'unixepoch', 'localtime') AS 'date_sent', DATETIME(date_received / 1000, 'unixepoch', 'localtime') AS 'date_received'"
" FROM reaction WHERE message_id IS ?", msg_id, &reaction_results);
SqliteDB::QueryResults edit_revisions; // leave empty
bool issticker = (attachment_results.rows() == 1 && !attachment_results.isNull(0, "sticker_pack_id"));
IconType icon = IconType::NONE;
if (Types::isStatusMessage(type))
{
// see note in exporthtml
long long int target_rid = msg_recipient_id;
if ((Types::isIdentityVerified(type) || Types::isIdentityDefault(type)) &&
revision.valueAsInt(0, "to_recipient_id") != -1) [[unlikely]]
target_rid = revision.valueAsInt(0, "to_recipient_id");
if (!body.empty())
body = decodeStatusMessage(body, revision.getValueAs<long long int>(0, "expires_in"), type, getRecipientInfoFromMap(recipient_info, target_rid).display_name, &icon);
else if (d_database.tableContainsColumn(d_mms_table, "message_extras") &&
revision.valueHasType<std::pair<std::shared_ptr<unsigned char []>, size_t>>(0, "message_extras"))
body = decodeStatusMessage(revision.getValueAs<std::pair<std::shared_ptr<unsigned char []>, size_t>>(0, "message_extras"),
revision.getValueAs<long long int>(0, "expires_in"), type, getRecipientInfoFromMap(recipient_info, target_rid).display_name, &icon);
}
// prep body (scan emoji? -> in <span>) and handle mentions...
// if (prepbody)
std::vector<std::tuple<long long int, long long int, long long int>> mentions;
for (unsigned int mi = 0; mi < mention_results.rows(); ++mi)
mentions.emplace_back(std::make_tuple(mention_results.getValueAs<long long int>(mi, "recipient_id"),
mention_results.getValueAs<long long int>(mi, "range_start"),
mention_results.getValueAs<long long int>(mi, "range_length")));
std::pair<std::shared_ptr<unsigned char []>, size_t> brdata(nullptr, 0);
if (!revision.isNull(0, d_mms_ranges))
brdata = revision.getValueAs<std::pair<std::shared_ptr<unsigned char []>, size_t>>(0, d_mms_ranges);
bool only_emoji = HTMLprepMsgBody(&body, mentions, recipient_info, incoming, brdata, linkify, false /*isquote*/);
bool nobackground = false;
if ((only_emoji && !hasquote && !attachment_results.rows()) || // if no quote etc
issticker) // or sticker
nobackground = true;
// same for quote_body!
mentions.clear();
std::pair<std::shared_ptr<unsigned char []>, size_t> quote_mentions{nullptr, 0};
if (!revision.isNull(0, "quote_mentions"))
quote_mentions = revision.getValueAs<std::pair<std::shared_ptr<unsigned char []>, size_t>>(0, "quote_mentions");
HTMLprepMsgBody("e_body, mentions, recipient_info, incoming, quote_mentions, linkify, true /*isquote*/);
HTMLMessageInfo msg_info({only_emoji,
false, //is_deleted,
false, //is_viewonce,
parent_info.isgroup,
incoming,
nobackground,
hasquote,
quote_missing,
parent_info.orig_filename,
parent_info.overwrite, // ?
parent_info.append, // ?
parent_info.story_reply,
type,
expires_in,
msg_id,
msg_recipient_id,
-1, //original_message_id,
0, // messagecount, // idx of current message in &messages
&revision,
"e_attachment_results,
&attachment_results,
&reaction_results,
&edit_revisions,
body,
quote_body,
readable_date,
parent_info.directory,
parent_info.threaddir,
parent_info.filename,
revision(0, "link_preview_url"),
revision(0, "link_preview_title"),
revision(0, "link_preview_description"),
shared_contacts,
icon});
HTMLwriteMessage(filt, msg_info, recipient_info, false /*searchpage*/, false /*writereceipts*/, ignoremediatypes);
}
|
