blockworks-foundation
/
mango-feeds
mirror of https://github.com/blockworks-foundation/mango-feeds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Wipe old slots from table, now nothing accumulates

This commit is contained in:
Christian Kamm 2021-11-08 12:09:14 +01:00
parent 47f8bb823d
commit 7f6e25e107
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lib/src/postgres_target.rs
View File

@ -111,6 +111,9 @@ impl SlotsProcessing {
)
})
.collect();
self.cleanup_table_sql
.push("DELETE FROM slot WHERE slot + 100000 < $newest_final_slot".into());
}
async fn process(
@ -149,12 +152,13 @@ impl SlotsProcessing {
self.slots.remove(&update.slot);
// TODO: should also convert all parents to rooted, just in case we missed an update?
// TODO: Or, instead, wipe some old slots, to avoid accumulating them needlessly?
// Keep only the most recent final write per pubkey
if self.newest_final_slot.unwrap_or(-1) < update.slot {
// Keep only the newest rooted account write and also
// wipe old slots
for cleanup_sql in &self.cleanup_table_sql {
let query = query_dyn!(cleanup_sql, newest_final_slot = update.slot,)?;
let query = query_dyn!(cleanup_sql, newest_final_slot = update.slot)?;
let _ = query
.execute(client)
.await