nostr/strfry
1
0
Fork 0
mirror of https://github.com/hoytech/strfry.git synced 2025-06-20 01:40:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

paginated user comment screens

Browse Source
This commit is contained in:
Doug Hoyte
2023-09-28 16:20:50 -04:00
parent e987b8dcfc
commit 4975dbc2e2
5 changed files with 70 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/apps/web/WebData.h
View File

@ -595,11 +595,14 @@ struct UserEvents {
};
std::vector<EventCluster> eventClusterArr;
uint64_t totalEvents = 0;
std::optional<uint64_t> timestampCutoff;
std::optional<uint64_t> nextResumeTime;
UserEvents(lmdb::txn &txn, Decompressor &decomp, const std::string &pubkey) : u(txn, decomp, pubkey) {
UserEvents(lmdb::txn &txn, Decompressor &decomp, const std::string &pubkey, uint64_t resumeTime) : u(txn, decomp, pubkey) {
flat_hash_map<std::string, EventCluster> eventClusters; // eventId (root) -> EventCluster
env.generic_foreachFull(txn, env.dbi_Event__pubkeyKind, makeKey_StringUint64Uint64(pubkey, 1, MAX_U64), "", [&](std::string_view k, std::string_view v){
env.generic_foreachFull(txn, env.dbi_Event__pubkeyKind, makeKey_StringUint64Uint64(pubkey, 1, resumeTime), "", [&](std::string_view k, std::string_view v){
ParsedKey_StringUint64Uint64 parsedKey(k);
if (parsedKey.s != pubkey || parsedKey.n1 != 1) return false;
@ -617,6 +620,7 @@ struct UserEvents {
cluster.isRootEventFromUser = rootEvent.getPubkey() == u.pubkey;
cluster.rootEventTimestamp = rootEvent.getCreatedAt();
cluster.eventCache.emplace(rootId, std::move(rootEvent));
totalEvents++;
};
if (ev.root.size()) {
@ -635,6 +639,7 @@ struct UserEvents {
}
eventClusters.at(ev.root).eventCache.emplace(id, std::move(ev));
totalEvents++;
} else {
// Event is root
@ -643,6 +648,15 @@ struct UserEvents {
}
}
if (timestampCutoff) {
if (*timestampCutoff != parsedKey.n2) {
nextResumeTime = *timestampCutoff - 1;
return false;
}
} else if (totalEvents > 100) {
timestampCutoff = parsedKey.n2;
}
return true;
}, true);
@ -666,9 +680,11 @@ struct UserEvents {
struct {
std::vector<TemplarResult> &renderedThreads;
User &u;
std::optional<uint64_t> nextResumeTime;
} ctx = {
renderedThreads,
u,
nextResumeTime,
};
return tmpl::user::comments(ctx);