d3v1l/matrixion
1
0
Fork 0
mirror of https://github.com/Nheko-Reborn/nheko.git synced 2024-10-30 09:30:47 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix pagination in rooms with a full batch of redactions

Browse source
This commit is contained in:
Nicolas Werner 2023-07-09 15:41:39 +02:00
parent 246a6d35f5
commit 7fc7aa2da3
No known key found for this signature in database
GPG key ID: C8D75E610773F2D9
1 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
src/Cache.cpp
View file

@ -3790,10 +3790,27 @@ Cache::saveOldMessages(const std::string &room_id, const mtx::responses::Message
}
}
nlohmann::json orderEntry = nlohmann::json::object();
orderEntry["event_id"] = event_id_val;
orderEntry["prev_batch"] = res.end;
orderDb.put(txn, lmdb::to_sv(index), orderEntry.dump());
if (!event_id_val.empty()) {
nlohmann::json orderEntry = nlohmann::json::object();
orderEntry["event_id"] = event_id_val;
orderEntry["prev_batch"] = res.end;
orderDb.put(txn, lmdb::to_sv(index), orderEntry.dump());
} else if (!res.chunk.empty()) {
// to not break pagination, even if all events are redactions we try to persist something in
// the batch.
nlohmann::json orderEntry = nlohmann::json::object();
event_id_val = mtx::accessors::event_id(res.chunk.back());
--index;
auto event = mtx::accessors::serialize_event(res.chunk.back()).dump();
eventsDb.put(txn, event_id_val, event);
evToOrderDb.put(txn, event_id_val, lmdb::to_sv(index));
orderEntry["event_id"] = event_id_val;
orderEntry["prev_batch"] = res.end;
orderDb.put(txn, lmdb::to_sv(index), orderEntry.dump());
}
txn.commit();