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

On startup, load metadata in the background

Browse Source
This commit is contained in:
Mike Dilger 2023-01-11 08:23:16 +13:00 committed by Mike Dilger
parent 31fbf7342e
commit 170c90d374
1 changed files with 21 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/overlord/mod.rs
View File

@ -103,21 +103,29 @@ impl Overlord {
GLOBALS.people.write().await.load_all_followed().await?;
// Load latest metadata per person and update their metadata
{
let db_events = DbEvent::fetch_latest_metadata().await?;
for dbevent in db_events.iter() {
let e: Event = match serde_json::from_str(&dbevent.raw) {
Ok(e) => e,
Err(_) => {
tracing::error!("Bad raw event: id={}, raw={}", dbevent.id, dbevent.raw);
continue;
}
};
// This can happen in the background
task::spawn(async move {
if let Ok(db_events) = DbEvent::fetch_latest_metadata().await {
for dbevent in db_events.iter() {
let e: Event = match serde_json::from_str(&dbevent.raw) {
Ok(e) => e,
Err(_) => {
tracing::error!(
"Bad raw event: id={}, raw={}",
dbevent.id,
dbevent.raw
);
continue;
}
};
// Process this metadata event to update people
crate::process::process_new_event(&e, false, None, None).await?;
// Process this metadata event to update people
if let Err(e) = crate::process::process_new_event(&e, false, None, None).await {
tracing::error!("{}", e);
}
}
}
}
});
// Load feed-related events from database and process (TextNote, EventDeletion, Reaction)
{