feat: publish command to publish full relay index

nomen/src/config/cli.rs

@@ -32,6 +32,9 @@ pub enum Subcommand {
     /// Rebroadcast Nostr record events
     Rebroadcast,
 
+    /// Publish full name index to relay servers
+    Publish,
+
     /// Prints the current version of application
     Version,
 }

nomen/src/main.rs

@@ -19,6 +19,11 @@ use config::Config;
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
+    // No log output by default
+    if std::env::var("RUST_LOG").is_err() {
+        std::env::set_var("RUST_LOG", "off");
+    }
+
     tracing_subscriber::fmt::init();
     let config = parse_config()?;
 
@@ -37,6 +42,7 @@ async fn main() -> anyhow::Result<()> {
         config::Subcommand::Rebroadcast => {
             subcommands::rebroadcast(&config, &pool).await?;
         }
+        config::Subcommand::Publish => subcommands::publish(&config, &pool).await?,
         config::Subcommand::Version => {
             subcommands::version();
         }

nomen/src/subcommands/index/mod.rs

@@ -1,7 +1,7 @@
 use crate::{config::Config, db};
 
 mod blockchain;
-mod events;
+pub mod events;
 
 pub async fn index(config: &Config) -> anyhow::Result<()> {
     let pool = config.sqlite().await?;

nomen/src/subcommands/mod.rs

@@ -24,7 +24,7 @@ pub(crate) async fn reindex(
     pool: &SqlitePool,
     blockheight: i64,
 ) -> anyhow::Result<()> {
-    tracing::info!("Re-indexing blockchain from blockheight {blockheight}.");
+    println!("Re-indexing blockchain from blockheight {blockheight}.");
     db::index::reindex(pool, blockheight).await?;
     Ok(())
 }
@@ -34,7 +34,7 @@ pub(crate) async fn rescan(
     pool: &SqlitePool,
     blockheight: i64,
 ) -> anyhow::Result<()> {
-    tracing::info!("Re-scanning blockchain from blockheight {blockheight}.");
+    println!("Re-scanning blockchain from blockheight {blockheight}.");
     db::index::reindex(pool, blockheight).await?;
     sqlx::query("DELETE FROM index_height WHERE blockheight >= ?;")
         .bind(blockheight)
@@ -59,7 +59,7 @@ pub(crate) async fn rebroadcast(config: &Config, pool: &SqlitePool) -> anyhow::R
     )
     .fetch_all(pool)
     .await?;
-    tracing::info!(
+    println!(
         "Rebroadcasing {} events to {} relays",
         events.len(),
         config.relays().len()
@@ -72,3 +72,8 @@ pub(crate) async fn rebroadcast(config: &Config, pool: &SqlitePool) -> anyhow::R
 
     Ok(())
 }
+
+pub(crate) async fn publish(config: &Config, pool: &SqlitePool) -> anyhow::Result<()> {
+    println!("Publishing full relay index");
+    index::events::relay_index::publish(config, pool).await
+}