nostr/gossip
1
0
Fork 0
mirror of https://github.com/mikedilger/gossip.git synced 2024-09-19 19:46:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve seek by desiring entire reply chain at once

Browse Source
This commit is contained in:
Mike Dilger 2022-12-26 21:33:26 +13:00
parent cee213b1c5
commit 2072a445df
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/process.rs
View File

@ -114,7 +114,7 @@ pub async fn process_new_event(
// Save event relationships
{
// replies to
if let Some((id, maybe_url)) = event.replies_to() {
if let Some((id, _)) = event.replies_to() {
if from_relay {
let db_event_relationship = DbEventRelationship {
original: event.id.as_hex_string(),
@ -125,11 +125,6 @@ pub async fn process_new_event(
db_event_relationship.insert().await?;
}
// Insert desired event if relevant
if !GLOBALS.events.lock().await.contains_key(&id) {
Globals::store_desired_event(id, maybe_url).await;
}
// Insert into relationships
Globals::add_relationship(id, event.id, Relationship::Reply).await;
@ -137,6 +132,14 @@ pub async fn process_new_event(
Globals::update_last_reply(id, event.created_at);
}
// We desire all ancestors
for (id, maybe_url) in event.replies_to_ancestors() {
// Insert desired event if relevant
if !GLOBALS.events.lock().await.contains_key(&id) {
Globals::store_desired_event(id, maybe_url).await;
}
}
// reacts to
if let Some((id, reaction, maybe_url)) = event.reacts_to() {
if from_relay {