aboutsummaryrefslogtreecommitdiff
path: root/lib/connection.cpp
diff options
context:
space:
mode:
authorAlexey Rusakov <Kitsune-Ral@users.sf.net>2022-05-26 11:03:16 +0200
committerAlexey Rusakov <Kitsune-Ral@users.sf.net>2022-05-29 08:17:56 +0200
commit841846ea5efad80ce20e0d42b1885def224e58ad (patch)
tree5833bece7a87848234ee4ebc72574eac7308b53c /lib/connection.cpp
parent0b5e72a2c6502f22a752b72b4df5fa25746fdd25 (diff)
downloadlibquotient-841846ea5efad80ce20e0d42b1885def224e58ad.tar.gz
libquotient-841846ea5efad80ce20e0d42b1885def224e58ad.zip
Cleanup and fix Sonar warnings
Diffstat (limited to 'lib/connection.cpp')
-rw-r--r--lib/connection.cpp57
1 files changed, 30 insertions, 27 deletions
diff --git a/lib/connection.cpp b/lib/connection.cpp
index 0994d85a..8fd2d6cf 100644
--- a/lib/connection.cpp
+++ b/lib/connection.cpp
@@ -1322,18 +1322,11 @@ Connection::sendToDevices(const QString& eventType,
{
QHash<QString, QHash<QString, QJsonObject>> json;
json.reserve(int(eventsMap.size()));
- std::for_each(eventsMap.begin(), eventsMap.end(),
- [&json](const auto& userTodevicesToEvents) {
- auto& jsonUser = json[userTodevicesToEvents.first];
- const auto& devicesToEvents = userTodevicesToEvents.second;
- std::for_each(devicesToEvents.begin(),
- devicesToEvents.end(),
- [&jsonUser](const auto& deviceToEvents) {
- jsonUser.insert(
- deviceToEvents.first,
- deviceToEvents.second->contentJson());
- });
- });
+ for (const auto& [userId, devicesToEvents] : eventsMap) {
+ auto& jsonUser = json[userId];
+ for (const auto& [deviceId, event] : devicesToEvents)
+ jsonUser.insert(deviceId, event->contentJson());
+ }
return callApi<SendToDeviceJob>(BackgroundRequest, eventType,
generateTxnId(), json);
}
@@ -2218,20 +2211,23 @@ QStringList Connection::devicesForUser(const QString& userId) const
return d->deviceKeys[userId].keys();
}
-QString Connection::curveKeyForUserDevice(const QString& user, const QString& device) const
+QString Connection::curveKeyForUserDevice(const QString& userId,
+ const QString& device) const
{
- return d->deviceKeys[user][device].keys["curve25519:" % device];
+ return d->deviceKeys[userId][device].keys["curve25519:" % device];
}
-QString Connection::edKeyForUserDevice(const QString& user, const QString& device) const
+QString Connection::edKeyForUserDevice(const QString& userId,
+ const QString& device) const
{
- return d->deviceKeys[user][device].keys["ed25519:" % device];
+ return d->deviceKeys[userId][device].keys["ed25519:" % device];
}
-bool Connection::isKnownCurveKey(const QString& user, const QString& curveKey)
+bool Connection::isKnownCurveKey(const QString& userId,
+ const QString& curveKey) const
{
auto query = database()->prepareQuery(QStringLiteral("SELECT * FROM tracked_devices WHERE matrixId=:matrixId AND curveKey=:curveKey"));
- query.bindValue(":matrixId", user);
+ query.bindValue(":matrixId", userId);
query.bindValue(":curveKey", curveKey);
database()->execute(query);
return query.next();
@@ -2243,25 +2239,32 @@ bool Connection::hasOlmSession(const QString& user, const QString& deviceId) con
return d->olmSessions.contains(curveKey) && !d->olmSessions[curveKey].empty();
}
-QPair<QOlmMessage::Type, QByteArray> Connection::olmEncryptMessage(const QString& user, const QString& device, const QByteArray& message)
+std::pair<QOlmMessage::Type, QByteArray> Connection::olmEncryptMessage(
+ const QString& userId, const QString& device, const QByteArray& message) const
{
- const auto& curveKey = curveKeyForUserDevice(user, device);
+ const auto& curveKey = curveKeyForUserDevice(userId, device);
QOlmMessage::Type type = d->olmSessions[curveKey][0]->encryptMessageType();
- auto result = d->olmSessions[curveKey][0]->encrypt(message);
- auto pickle = d->olmSessions[curveKey][0]->pickle(picklingMode());
- if (pickle) {
- database()->updateOlmSession(curveKey, d->olmSessions[curveKey][0]->sessionId(), *pickle);
+ const auto result = d->olmSessions[curveKey][0]->encrypt(message);
+ if (const auto pickle =
+ d->olmSessions[curveKey][0]->pickle(picklingMode())) {
+ database()->updateOlmSession(curveKey,
+ d->olmSessions[curveKey][0]->sessionId(),
+ *pickle);
} else {
qCWarning(E2EE) << "Failed to pickle olm session: " << pickle.error();
}
return { type, result.toCiphertext() };
}
-void Connection::createOlmSession(const QString& theirIdentityKey, const QString& theirOneTimeKey)
+void Connection::createOlmSession(const QString& theirIdentityKey,
+ const QString& theirOneTimeKey) const
{
- auto session = QOlmSession::createOutboundSession(olmAccount(), theirIdentityKey, theirOneTimeKey);
+ auto session = QOlmSession::createOutboundSession(olmAccount(),
+ theirIdentityKey,
+ theirOneTimeKey);
if (!session) {
- qCWarning(E2EE) << "Failed to create olm session for " << theirIdentityKey << session.error();
+ qCWarning(E2EE) << "Failed to create olm session for "
+ << theirIdentityKey << session.error();
return;
}
d->saveSession(**session, theirIdentityKey);