command: backdate_eose()

gossip-bin/src/commands.rs

@@ -29,7 +29,7 @@ impl Command {
     }
 }
 
-const COMMANDS: [Command; 30] = [
+const COMMANDS: [Command; 31] = [
     Command {
         cmd: "oneshot",
         usage_params: "{depends}",
@@ -45,6 +45,11 @@ const COMMANDS: [Command; 30] = [
         usage_params: "<listname>",
         desc: "add a new person list with the given name",
     },
+    Command {
+        cmd: "backdate_eose",
+        usage_params: "",
+        desc: "backdate last_general_eose_at by 24 hours for every relay",
+    },
     Command {
         cmd: "bech32_decode",
         usage_params: "<bech32string>",
@@ -202,6 +207,7 @@ pub fn handle_command(mut args: env::Args, runtime: &Runtime) -> Result<bool, Er
         "oneshot" => oneshot(command, args)?,
         "add_person_relay" => add_person_relay(command, args)?,
         "add_person_list" => add_person_list(command, args)?,
+        "backdate_eose" => backdate_eose()?,
         "bech32_decode" => bech32_decode(command, args)?,
         "bech32_encode_event_addr" => bech32_encode_event_addr(command, args)?,
         "decrypt" => decrypt(command, args)?,
@@ -307,6 +313,24 @@ pub fn add_person_list(cmd: Command, mut args: env::Args) -> Result<(), Error> {
     Ok(())
 }
 
+pub fn backdate_eose() -> Result<(), Error> {
+    let now = Unixtime::now().unwrap();
+    let ago = (now.0 - 60 * 60 * 24) as u64;
+
+    GLOBALS.storage.modify_all_relays(
+        |relay| {
+            if let Some(eose) = relay.last_general_eose_at {
+                if eose > ago {
+                    relay.last_general_eose_at = Some(ago);
+                }
+            }
+        },
+        None,
+    )?;
+
+    Ok(())
+}
+
 pub fn bech32_decode(cmd: Command, mut args: env::Args) -> Result<(), Error> {
     let mut param = match args.next() {
         Some(s) => s,

gossip-lib/src/storage/mod.rs

@@ -1100,7 +1100,7 @@ impl Storage {
 
     //// Modify all relay records
     #[inline]
-    pub(crate) fn modify_all_relays<'a, M>(
+    pub fn modify_all_relays<'a, M>(
         &'a self,
         modify: M,
         rw_txn: Option<&mut RwTxn<'a>>,