summary refs log tree commit diff
path: root/src/Cache.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/Cache.cpp')
-rw-r--r--src/Cache.cpp39
1 files changed, 31 insertions, 8 deletions
diff --git a/src/Cache.cpp b/src/Cache.cpp

index aca01c1a..8cfc4b55 100644 --- a/src/Cache.cpp +++ b/src/Cache.cpp
@@ -960,9 +960,15 @@ Cache::saveState(const mtx::responses::Sync &res) for (const auto &room : res.rooms.join) { if (!room.second.ephemeral.receipts.empty()) { std::vector<QString> receipts; - for (const auto &receipt : room.second.ephemeral.receipts) - if (receipt.first != user_id) - receipts.push_back(QString::fromStdString(receipt.first)); + for (const auto &receipt : room.second.ephemeral.receipts) { + for (const auto &receiptUsersTs : receipt.second) { + if (receiptUsersTs.first != user_id) { + receipts.push_back( + QString::fromStdString(receipt.first)); + break; + } + } + } if (!receipts.empty()) emit newReadReceipts(QString::fromStdString(room.first), receipts); } @@ -1314,16 +1320,33 @@ Cache::getLastMessageInfo(lmdb::txn &txn, const std::string &room_id) std::string timestamp, msg; - QSettings settings; const auto local_user = utils::localUser(); + DescInfo fallbackDesc{}; + auto cursor = lmdb::cursor::open(txn, db); while (cursor.get(timestamp, msg, MDB_NEXT)) { auto obj = json::parse(msg); - if (obj.count("event") == 0 || !(obj["event"]["type"] == "m.room.message" || - obj["event"]["type"] == "m.sticker" || - obj["event"]["type"] == "m.room.encrypted")) + if (obj.count("event") == 0) + continue; + + if (fallbackDesc.event_id.isEmpty() && obj["event"]["type"] == "m.room.member" && + obj["event"]["state_key"] == local_user.toStdString() && + obj["event"]["content"]["membership"] == "join") { + uint64_t ts = obj["event"]["origin_server_ts"]; + auto time = QDateTime::fromMSecsSinceEpoch(ts); + fallbackDesc = DescInfo{QString::fromStdString(obj["event"]["event_id"]), + local_user, + tr("You joined this room"), + utils::descriptiveTime(time), + ts, + time}; + } + + if (!(obj["event"]["type"] == "m.room.message" || + obj["event"]["type"] == "m.sticker" || + obj["event"]["type"] == "m.room.encrypted")) continue; mtx::events::collections::TimelineEvent event; @@ -1335,7 +1358,7 @@ Cache::getLastMessageInfo(lmdb::txn &txn, const std::string &room_id) } cursor.close(); - return DescInfo{}; + return fallbackDesc; } std::map<QString, bool>