diff --git a/src/db.rs b/src/db.rs index 1b345a4..85b480d 100644 --- a/src/db.rs +++ b/src/db.rs @@ -314,8 +314,9 @@ pub async fn db_writer( notice_tx.try_send(Notice::duplicate(event.id)).ok(); } else { info!( - "persisted event: {:?} from: {:?} in: {:?}", + "persisted event: {:?} (kind={}) from: {:?} in: {:?}", event.get_event_id_prefix(), + event.kind, event.get_author_prefix(), start.elapsed() ); diff --git a/src/schema.rs b/src/schema.rs index f4b6990..6e86222 100644 --- a/src/schema.rs +++ b/src/schema.rs @@ -626,7 +626,6 @@ fn mig_14_to_15(conn: &mut PooledConnection) -> Result { let upgrade_sql = r##" CREATE INDEX IF NOT EXISTS author_created_at_index ON event(author,created_at); CREATE INDEX IF NOT EXISTS author_kind_index ON event(author,kind); -pragma optimize; PRAGMA user_version = 15; "##; match conn.execute_batch(upgrade_sql) { @@ -638,5 +637,17 @@ PRAGMA user_version = 15; panic!("database could not be upgraded"); } } + // clear out hidden events + let clear_hidden_sql = r##"DELETE FROM event WHERE HIDDEN=true;"##; + info!("removing hidden events; this may take awhile..."); + match conn.execute_batch(clear_hidden_sql) { + Ok(()) => { + info!("all hidden events removed"); + }, + Err(err) => { + error!("delete failed: {}", err); + panic!("could not remove hidden events"); + } + } Ok(15) }