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
|
/*
Copyright (C) 2023-2024 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"
bool SignalBackup::findRecipient(long long int id) const
{
for (auto const &dbl : s_databaselinks)
{
if (dbl.table != "recipient")
continue;
if (!d_database.containsTable(dbl.table)) [[unlikely]]
continue;
for (auto const &c : dbl.connections)
{
if (d_database.containsTable(c.table) && d_database.tableContainsColumn(c.table, c.column))
{
SqliteDB::QueryResults res;
if (!d_database.exec("SELECT COUNT(*) AS 'count' FROM " + c.table + " WHERE " + c.column + " IS ?",
id, &res) ||
res.rows() != 1)
return false;
long long int count = res.getValueAs<long long int>(0, "count");
if (count)
Logger::message("Found recipient ", id, " referenced in '", c.table, ".", c.column, "' (", count, " times)");
}
}
}
// get phone and uuid
std::string uuid;
std::string phone;
SqliteDB::QueryResults res;
if (!d_database.exec("SELECT " + d_recipient_e164 + ", " + d_recipient_aci + " FROM recipient WHERE _id = ?", id, &res) ||
res.rows() != 1)
return false;
uuid = res(d_recipient_aci);
phone = res(d_recipient_e164);
// check in identities
if (d_database.containsTable("identities") &&
d_database.exec("SELECT COUNT(*) AS 'count' FROM identities WHERE address = ? OR address = ?", {uuid, phone}, &res) &&
res.rows() == 1)
Logger::message("Found recipient ", id, " referenced in 'identities.address' (by uuid/phone, ",
res.getValueAs<long long int>(0, "count"), " times)");
// check in quote mentions
if (!uuid.empty())
{
int count = 0;
if (d_database.exec("SELECT DISTINCT quote_mentions FROM " + d_mms_table + " WHERE quote_mentions IS NOT NULL", &res))
{
for (unsigned int i = 0; i < res.rows(); ++i)
{
auto brdata = res.getValueAs<std::pair<std::shared_ptr<unsigned char []>, size_t>>(i, "quote_mentions");
BodyRanges brsproto(brdata);
auto brs = brsproto.getField<1>();
for (auto const &br : brs)
{
std::string mentionuuid = br.getField<3>().value_or(std::string());
if (mentionuuid == uuid)
++count;
}
}
}
if (count)
Logger::message("Found recipient ", id, " referenced in '", d_mms_table,
".quote_mentions' (by uuid, ", count, " times)");
}
// check in group updates
std::vector<long long int> mentioned_in_group_updates(getGroupUpdateRecipients());
if (bepaald::contains(mentioned_in_group_updates, id))
Logger::message("Found recipient ", id, " referenced in group updates");
// check former gv1 members
std::set<long long int> gv1migrationrec;
getGroupV1MigrationRecipients(&gv1migrationrec);
if (bepaald::contains(gv1migrationrec, id))
Logger::message("Found recipient ", id, " referenced in GV1 migration message");
// check old style? group members
SqliteDB::QueryResults results;
std::set<long long int> oldstylegroupmembers;
for (auto const &members : {"members"s, d_groups_v1_members})
{
if (!d_database.tableContainsColumn("groups", members))
continue;
d_database.exec("SELECT "s + members + " FROM groups WHERE " + members + " IS NOT NULL", &results);
for (unsigned int i = 0; i < results.rows(); ++i)
{
std::string membersstr = results.getValueAs<std::string>(i, members);
std::stringstream ss(membersstr);
while (ss.good())
{
std::string substr;
std::getline(ss, substr, ',');
//Logger::message("ADDING ", members, " MEMBER: ", substr);
oldstylegroupmembers.insert(bepaald::toNumber<int>(substr));
}
}
}
if (bepaald::contains(oldstylegroupmembers, id))
Logger::message("Found recipient ", id, " referenced as group member (old style)");
return true;
}
|
