data/ContactPlaceLookup.cpp
| Line | Branch | Exec | Source |
|---|---|---|---|
| 1 | #include "ContactPlaceLookup.h" | ||
| 2 | |||
| 3 | #include "ContactPlaceIndexer.h" | ||
| 4 | |||
| 5 | #include <QDateTime> | ||
| 6 | #include <QLoggingCategory> | ||
| 7 | #include <QSet> | ||
| 8 | #include <QSqlError> | ||
| 9 | #include <QSqlQuery> | ||
| 10 | #include <QVariant> | ||
| 11 | |||
| 12 | Q_DECLARE_LOGGING_CATEGORY(lcContactPeople) | ||
| 13 | |||
| 14 | namespace ContactPlaceLookup { | ||
| 15 | |||
| 16 | namespace { | ||
| 17 | |||
| 18 | const char *const kAddressKinds = "('home', 'work', 'other')"; | ||
| 19 | |||
| 20 | 16 | Address addressOf(const QSqlQuery &q) { | |
| 21 | 16 | Address address; | |
| 22 |
2/2✓ Branch 2 → 3 taken 16 times.
✓ Branch 3 → 4 taken 16 times.
|
16 | address.street = q.value(0).toString(); |
| 23 |
2/2✓ Branch 7 → 8 taken 16 times.
✓ Branch 8 → 9 taken 16 times.
|
16 | address.postalCode = q.value(1).toString(); |
| 24 |
2/2✓ Branch 12 → 13 taken 16 times.
✓ Branch 13 → 14 taken 16 times.
|
16 | address.locality = q.value(2).toString(); |
| 25 |
2/2✓ Branch 17 → 18 taken 16 times.
✓ Branch 18 → 19 taken 16 times.
|
16 | address.region = q.value(3).toString(); |
| 26 |
2/2✓ Branch 22 → 23 taken 16 times.
✓ Branch 23 → 24 taken 16 times.
|
16 | address.country = q.value(4).toString(); |
| 27 |
1/1✓ Branch 31 → 32 taken 16 times.
|
32 | address.cacheKey = ContactPlaceIndexer::cacheKey(QStringLiteral("home"), {}, address.street, address.postalCode, |
| 28 | 32 | address.locality, address.region, address.country); | |
| 29 | 16 | return address; | |
| 30 | ✗ | } | |
| 31 | |||
| 32 | 12 | QString cacheSource(QSqlDatabase &db, const QString &key) { | |
| 33 |
1/1✓ Branch 2 → 3 taken 12 times.
|
12 | QSqlQuery q(db); |
| 34 |
1/1✓ Branch 6 → 7 taken 12 times.
|
12 | q.prepare(QStringLiteral("SELECT source FROM place_cache WHERE address_hash = ?")); |
| 35 |
1/1✓ Branch 11 → 12 taken 12 times.
|
12 | q.addBindValue(key); |
| 36 |
7/12✓ Branch 13 → 14 taken 12 times.
✓ Branch 14 → 15 taken 12 times.
✗ Branch 14 → 20 not taken.
✓ Branch 15 → 16 taken 12 times.
✓ Branch 16 → 17 taken 12 times.
✗ Branch 16 → 20 not taken.
✓ Branch 17 → 18 taken 12 times.
✓ Branch 18 → 19 taken 12 times.
✓ Branch 22 → 23 taken 12 times.
✗ Branch 22 → 24 not taken.
✗ Branch 37 → 38 not taken.
✗ Branch 37 → 39 not taken.
|
36 | return q.exec() && q.next() ? q.value(0).toString() : QString(); |
| 37 | 12 | } | |
| 38 | |||
| 39 | } // namespace | ||
| 40 | |||
| 41 | 7 | QList<Address> pending(QSqlDatabase &db, int limit, const QSet<QString> &skip) { | |
| 42 | 7 | QList<Address> out; | |
| 43 |
1/1✓ Branch 2 → 3 taken 7 times.
|
7 | QSqlQuery q(db); |
| 44 |
1/1✓ Branch 3 → 4 taken 7 times.
|
7 | q.setForwardOnly(true); |
| 45 |
1/1✓ Branch 10 → 11 taken 7 times.
|
21 | if (!q.exec(QStringLiteral("SELECT DISTINCT street, postal_code, locality, region, country FROM card_places" |
| 46 | " WHERE kind IN %1 AND street <> '' AND source IN ('gazetteer', 'cache', 'none')") | ||
| 47 |
2/3✓ Branch 9 → 10 taken 7 times.
✗ Branch 14 → 15 not taken.
✓ Branch 14 → 31 taken 7 times.
|
21 | .arg(QLatin1String(kAddressKinds)))) { |
| 48 | ✗ | qCWarning(lcContactPeople) << "Addresses to look up could not be read:" << q.lastError().text(); | |
| 49 | ✗ | return out; | |
| 50 | } | ||
| 51 | 7 | QList<Address> candidates; | |
| 52 |
3/3✓ Branch 36 → 37 taken 19 times.
✓ Branch 37 → 32 taken 12 times.
✓ Branch 37 → 38 taken 7 times.
|
19 | while (q.next()) |
| 53 |
2/2✓ Branch 32 → 33 taken 12 times.
✓ Branch 33 → 34 taken 12 times.
|
12 | candidates.append(addressOf(q)); |
| 54 |
1/1✓ Branch 38 → 39 taken 7 times.
|
7 | q.finish(); |
| 55 | 7 | QSet<QString> seen; | |
| 56 |
2/2✓ Branch 71 → 43 taken 12 times.
✓ Branch 71 → 72 taken 7 times.
|
19 | for (const Address &address : std::as_const(candidates)) { |
| 57 |
1/2✗ Branch 45 → 46 not taken.
✓ Branch 45 → 47 taken 12 times.
|
12 | if (out.size() >= limit) |
| 58 | ✗ | break; | |
| 59 |
3/6✓ Branch 48 → 49 taken 12 times.
✗ Branch 48 → 51 not taken.
✗ Branch 50 → 51 not taken.
✓ Branch 50 → 52 taken 12 times.
✗ Branch 53 → 54 not taken.
✓ Branch 53 → 55 taken 12 times.
|
12 | if (seen.contains(address.cacheKey) || skip.contains(address.cacheKey)) |
| 60 | ✗ | continue; | |
| 61 |
1/1✓ Branch 55 → 56 taken 12 times.
|
12 | seen.insert(address.cacheKey); |
| 62 |
1/1✓ Branch 56 → 57 taken 12 times.
|
12 | const QString source = cacheSource(db, address.cacheKey); |
| 63 |
5/6✓ Branch 59 → 60 taken 12 times.
✗ Branch 59 → 64 not taken.
✓ Branch 62 → 63 taken 9 times.
✓ Branch 62 → 64 taken 3 times.
✓ Branch 65 → 66 taken 9 times.
✓ Branch 65 → 67 taken 3 times.
|
12 | if (source != QLatin1String("online") && source != QLatin1String("online-miss")) |
| 64 |
1/1✓ Branch 66 → 67 taken 9 times.
|
9 | out.append(address); |
| 65 | 12 | } | |
| 66 | 7 | return out; | |
| 67 | 7 | } | |
| 68 | |||
| 69 | 5 | Address forCard(QSqlDatabase &db, qint64 cardId, int position) { | |
| 70 |
1/1✓ Branch 2 → 3 taken 5 times.
|
5 | QSqlQuery q(db); |
| 71 |
1/1✓ Branch 9 → 10 taken 5 times.
|
15 | q.prepare(QStringLiteral("SELECT street, postal_code, locality, region, country FROM card_places" |
| 72 | " WHERE card_id = ? AND position = ? AND kind IN %1 LIMIT 1") | ||
| 73 |
1/1✓ Branch 8 → 9 taken 5 times.
|
15 | .arg(QLatin1String(kAddressKinds))); |
| 74 |
1/1✓ Branch 15 → 16 taken 5 times.
|
5 | q.addBindValue(cardId); |
| 75 |
1/1✓ Branch 19 → 20 taken 5 times.
|
5 | q.addBindValue(position); |
| 76 |
7/8✓ Branch 21 → 22 taken 5 times.
✓ Branch 22 → 23 taken 5 times.
✗ Branch 22 → 25 not taken.
✓ Branch 23 → 24 taken 5 times.
✓ Branch 24 → 25 taken 1 time.
✓ Branch 24 → 26 taken 4 times.
✓ Branch 27 → 28 taken 1 time.
✓ Branch 27 → 29 taken 4 times.
|
5 | if (!q.exec() || !q.next()) |
| 77 | 1 | return {}; | |
| 78 |
1/1✓ Branch 29 → 30 taken 4 times.
|
4 | const Address address = addressOf(q); |
| 79 |
1/6✗ Branch 31 → 32 not taken.
✓ Branch 31 → 37 taken 4 times.
✗ Branch 33 → 34 not taken.
✗ Branch 33 → 37 not taken.
✗ Branch 35 → 36 not taken.
✗ Branch 35 → 37 not taken.
|
4 | return address.street.isEmpty() && address.locality.isEmpty() && address.postalCode.isEmpty() ? Address{} : address; |
| 80 | 5 | } | |
| 81 | |||
| 82 | 6 | int store(QSqlDatabase &db, const Address &address, const Answer &answer) { | |
| 83 |
1/1✓ Branch 2 → 3 taken 6 times.
|
6 | db.transaction(); |
| 84 |
1/1✓ Branch 3 → 4 taken 6 times.
|
6 | QSqlQuery cache(db); |
| 85 |
2/2✓ Branch 4 → 5 taken 3 times.
✓ Branch 4 → 48 taken 3 times.
|
6 | if (answer.found) { |
| 86 |
1/1✓ Branch 8 → 9 taken 3 times.
|
3 | cache.prepare(QStringLiteral("INSERT OR REPLACE INTO place_cache (address_hash, lat, lon, precision, source, tz," |
| 87 | " looked_up, place_name, country) VALUES (?, ?, ?, ?, 'online'," | ||
| 88 | " COALESCE((SELECT tz FROM place_cache WHERE address_hash = ?), ''), ?, ?," | ||
| 89 | " COALESCE((SELECT country FROM place_cache WHERE address_hash = ?), ''))")); | ||
| 90 |
1/1✓ Branch 13 → 14 taken 3 times.
|
3 | cache.addBindValue(address.cacheKey); |
| 91 |
1/1✓ Branch 17 → 18 taken 3 times.
|
3 | cache.addBindValue(answer.latitude); |
| 92 |
1/1✓ Branch 21 → 22 taken 3 times.
|
3 | cache.addBindValue(answer.longitude); |
| 93 |
1/1✓ Branch 25 → 26 taken 3 times.
|
3 | cache.addBindValue(answer.precision); |
| 94 |
1/1✓ Branch 29 → 30 taken 3 times.
|
3 | cache.addBindValue(address.cacheKey); |
| 95 |
3/3✓ Branch 32 → 33 taken 3 times.
✓ Branch 33 → 34 taken 3 times.
✓ Branch 35 → 36 taken 3 times.
|
3 | cache.addBindValue(QDateTime::currentDateTimeUtc().toString(Qt::ISODate)); |
| 96 |
1/1✓ Branch 41 → 42 taken 3 times.
|
3 | cache.addBindValue(answer.placeName); |
| 97 |
1/1✓ Branch 45 → 46 taken 3 times.
|
3 | cache.addBindValue(address.cacheKey); |
| 98 | } else { | ||
| 99 | // Asked and not found: the offline position stays, it is not asked again. | ||
| 100 |
1/1✓ Branch 51 → 52 taken 3 times.
|
3 | cache.prepare(QStringLiteral("INSERT INTO place_cache (address_hash, source, looked_up) VALUES (?, 'online-miss', ?)" |
| 101 | " ON CONFLICT(address_hash) DO UPDATE SET source = 'online-miss'," | ||
| 102 | " looked_up = excluded.looked_up")); | ||
| 103 |
1/1✓ Branch 56 → 57 taken 3 times.
|
3 | cache.addBindValue(address.cacheKey); |
| 104 |
3/3✓ Branch 59 → 60 taken 3 times.
✓ Branch 60 → 61 taken 3 times.
✓ Branch 62 → 63 taken 3 times.
|
3 | cache.addBindValue(QDateTime::currentDateTimeUtc().toString(Qt::ISODate)); |
| 105 | } | ||
| 106 |
1/1✓ Branch 67 → 68 taken 6 times.
|
6 | cache.exec(); |
| 107 | 6 | int changed = 0; | |
| 108 |
2/2✓ Branch 68 → 69 taken 3 times.
✓ Branch 68 → 159 taken 3 times.
|
6 | if (answer.found) { |
| 109 | // S106-178: the rows are matched by the same folded identity the cache | ||
| 110 | // uses (cacheKey) — an exact text match left every other spelling of | ||
| 111 | // the address on its offline position, never asked again. | ||
| 112 |
1/1✓ Branch 69 → 70 taken 3 times.
|
3 | QSqlQuery rows(db); |
| 113 |
1/1✓ Branch 76 → 77 taken 3 times.
|
9 | rows.prepare(QStringLiteral("SELECT rowid, street, postal_code, locality, region, country FROM card_places" |
| 114 | " WHERE kind IN %1 AND source NOT IN ('pinned', 'card')") | ||
| 115 |
1/1✓ Branch 75 → 76 taken 3 times.
|
6 | .arg(QLatin1String(kAddressKinds))); |
| 116 | 3 | QList<qint64> matching; | |
| 117 |
2/3✓ Branch 80 → 81 taken 3 times.
✓ Branch 81 → 82 taken 3 times.
✗ Branch 81 → 121 not taken.
|
3 | if (rows.exec()) |
| 118 |
3/3✓ Branch 119 → 120 taken 13 times.
✓ Branch 120 → 83 taken 10 times.
✓ Branch 120 → 121 taken 3 times.
|
13 | while (rows.next()) |
| 119 |
3/3✓ Branch 91 → 92 taken 10 times.
✓ Branch 92 → 93 taken 10 times.
✓ Branch 97 → 98 taken 10 times.
|
30 | if (ContactPlaceIndexer::cacheKey(QStringLiteral("home"), {}, rows.value(1).toString(), |
| 120 |
4/4✓ Branch 87 → 88 taken 10 times.
✓ Branch 88 → 89 taken 10 times.
✓ Branch 89 → 90 taken 10 times.
✓ Branch 90 → 91 taken 10 times.
|
20 | rows.value(2).toString(), rows.value(3).toString(), |
| 121 |
6/6✓ Branch 83 → 84 taken 10 times.
✓ Branch 84 → 85 taken 10 times.
✓ Branch 85 → 86 taken 10 times.
✓ Branch 86 → 87 taken 10 times.
✓ Branch 113 → 114 taken 4 times.
✓ Branch 113 → 119 taken 6 times.
|
30 | rows.value(4).toString(), rows.value(5).toString()) == address.cacheKey) |
| 122 |
3/3✓ Branch 114 → 115 taken 4 times.
✓ Branch 115 → 116 taken 4 times.
✓ Branch 116 → 117 taken 4 times.
|
4 | matching.append(rows.value(0).toLongLong()); |
| 123 |
1/1✓ Branch 121 → 122 taken 3 times.
|
3 | QSqlQuery update(db); |
| 124 |
1/1✓ Branch 125 → 126 taken 3 times.
|
3 | update.prepare(QStringLiteral("UPDATE card_places SET lat = ?, lon = ?, precision = ?, source = 'online'" |
| 125 | " WHERE rowid = ?")); | ||
| 126 |
2/2✓ Branch 154 → 131 taken 4 times.
✓ Branch 154 → 155 taken 3 times.
|
7 | for (const qint64 row : std::as_const(matching)) { |
| 127 |
1/1✓ Branch 134 → 135 taken 4 times.
|
4 | update.addBindValue(answer.latitude); |
| 128 |
1/1✓ Branch 138 → 139 taken 4 times.
|
4 | update.addBindValue(answer.longitude); |
| 129 |
1/1✓ Branch 142 → 143 taken 4 times.
|
4 | update.addBindValue(answer.precision); |
| 130 |
1/1✓ Branch 146 → 147 taken 4 times.
|
4 | update.addBindValue(row); |
| 131 |
2/3✓ Branch 148 → 149 taken 4 times.
✓ Branch 149 → 150 taken 4 times.
✗ Branch 149 → 152 not taken.
|
4 | if (update.exec()) |
| 132 |
1/1✓ Branch 150 → 151 taken 4 times.
|
4 | changed += update.numRowsAffected(); |
| 133 | } | ||
| 134 | 3 | } | |
| 135 |
1/1✓ Branch 159 → 160 taken 6 times.
|
6 | db.commit(); |
| 136 |
10/10✓ Branch 160 → 161 taken 6 times.
✓ Branch 164 → 165 taken 6 times.
✓ Branch 165 → 166 taken 6 times.
✓ Branch 166 → 167 taken 3 times.
✓ Branch 166 → 168 taken 3 times.
✓ Branch 169 → 170 taken 6 times.
✓ Branch 170 → 171 taken 6 times.
✓ Branch 171 → 172 taken 6 times.
✓ Branch 175 → 162 taken 6 times.
✓ Branch 175 → 176 taken 6 times.
|
12 | qCDebug(lcContactPeople) << "Online lookup stored:" << (answer.found ? "found" : "not found") << changed << "rows"; |
| 137 | 6 | return changed; | |
| 138 | 6 | } | |
| 139 | |||
| 140 | } // namespace ContactPlaceLookup | ||
| 141 |