Merge pull request #1 from SYS-Labs/update-lib

Update lib

Author: sidhujag

Cargo.lock

@@ -17,7 +17,8 @@ serde_json = "1"
 reqwest = { version = "0.12.12", features = ["json"] }
 hex = "0.4"
 tokio = { version = "1", features = ["full"] }
-tracing = "0.1" 
+tracing = "0.1"
+tracing-subscriber = "0.3.19"
 [dev-dependencies]
 mockito = "1.6.1"
 tokio = { version = "1.42.0", features = ["macros", "rt-multi-thread"] }

Cargo.toml

@@ -44,7 +44,7 @@ use std::time::Duration;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let rpc_url = "http://localhost:8332";
+    let rpc_url = "http://localhost:18370/wallet";
     let rpc_user = "your_rpc_user";
     let rpc_password = "your_rpc_password";
     let poda_url = "http://poda.example.com";

README.md

@@ -1,41 +1,121 @@
+use std::time::Duration;
+use tokio::time::sleep;
+use tracing::{info, debug, span, Level};
+use tracing::{Instrument};
+use tracing_subscriber::fmt;
 use bitcoin_da_client::SyscoinClient;
 
 type Error = Box<dyn std::error::Error + Send + Sync>;
 
 #[tokio::main]
 async fn main() -> Result<(), Error> {
-    // Create a real RPC client
-    println!("Starting");
-    let rpc_url = "http://127.0.0.1:8370";
-    let rpc_user = "u";
+    // 🎛️ Initialize tracing: compact output, max DEBUG, no file/line info
+    fmt()
+        .with_max_level(Level::INFO)
+        .with_file(false)
+        .with_line_number(false)
+        .with_target(false)
+        .compact()
+        .init();
+
+    info!("🚀 Starting Syscoin client application");
+
+    // 🔧 Configuration parameters
+    let rpc_url    = "http://127.0.0.1:8370";
+    let rpc_user   = "u";
     let rpc_password = "p";
-    let poda_url = "http://poda.tanenbaum.io/vh/";
-    let timeout = Some(std::time::Duration::from_secs(30));
+    let poda_url   = "https://poda.syscoin.org/vh/";
+    let timeout    = Some(Duration::from_secs(30));
+    let wallet     = "wallet200999";
+    debug!(rpc_url, rpc_user, poda_url, timeout = ?timeout, wallet, "🔍 Config loaded");
 
-    // Initialize the client
+    // 🔌 Initialize the Syscoin RPC client
+    info!("🔌 Connecting to Syscoin node…");
     let client = SyscoinClient::new(
         rpc_url,
         rpc_user,
         rpc_password,
         poda_url,
         timeout,
+        wallet,
     )?;
-    
-    // Create/load wallet
-    println!("Loading wallet");
-    client.create_or_load_wallet("wallet12").await?;
+    info!("✅ SyscoinClient initialized successfully");
+
+    // 💼 Create or load the wallet and ensure a stable funding address
+    info!("🆕 Loading or creating wallet “{}”", wallet);
+    client
+        .create_or_load_wallet(wallet)
+        .instrument(span!(Level::DEBUG, "create_or_load_wallet", wallet = wallet))
+        .await?;
+    let funding_label = "da_funding";
+    let funding_address = client
+        .ensure_address_by_label(funding_label)
+        .instrument(span!(Level::DEBUG, "ensure_address_by_label", label = funding_label))
+        .await?;
+    info!("🏷️ Funding label '{}' is bound to address: {}", funding_label, funding_address);
+
+    // 📥 Fetch the current balance
+    let mut balance = client
+        .get_balance()
+        .instrument(span!(Level::INFO, "get_balance_start"))
+        .await?;
+    debug!("📥 Balance fetched: {} SYS", balance);
+
+    // 💸 Funding flow if balance is zero
+    if balance <= 0.0 {
+        info!("⚠️ Balance empty, let's top you up!");
+        let address = match client
+            .fetch_address_by_label("podalabel")
+            .instrument(span!(Level::DEBUG, "fetch_address_by_label", label = "podalabel"))
+            .await?
+        {
+            Some(addr) => {
+                info!("📍 Found existing funding address: {}", addr);
+                addr
+            }
+            None => {
+                info!("✨ No address yet—creating a fresh one…");
+                let addr = client
+                    .get_new_address("podalabel")
+                    .instrument(span!(Level::DEBUG, "get_new_address", label = "podalabel"))
+                    .await?;
+                info!("📍 New funding address: {}", addr);
+                addr
+            }
+        };
+
+        info!("💌 Please send some SYS to: {}", address);
+
+        // 🔄 Poll until funds arrive
+        while balance <= 0.0 {
+            debug!("⏳ Waiting 10 seconds before checking balance again…");
+            sleep(Duration::from_secs(10)).await;
+            balance = client.get_balance().await?;
+            info!("🔄 Checking… current balance: {} SYS", balance);
+        }
+        info!("🎉 Funds detected! Continuing…");
+    }
 
-    println!("Checking balance");
-    let balance = client.get_balance().await?;
-    println!("Balance: {balance}");
+    // 📤 Blob upload/retrieval flow
+    let data_to_upload = [1, 2, 3, 4];
+    info!("📤 Uploading blob data: {:?}", data_to_upload);
+    let blob_hash = client
+        .create_blob(&data_to_upload)
+        .instrument(span!(Level::DEBUG, "create_blob", data = ?data_to_upload))
+        .await?;
+    info!("✅ Blob uploaded! Got hash: {}", blob_hash);
 
-    println!("Uploading blob data");
-    let blob_hash = client.create_blob(&[1, 2, 3, 4]).await?;
-    println!("Created blob: {blob_hash}");
+    info!("📥 Fetching blob back by hash…");
+    let blob_data = client
+        .get_blob(&blob_hash)
+        .instrument(span!(Level::DEBUG, "get_blob", hash = %blob_hash))
+        .await?;
+    info!("🗒️ Blob data retrieved: {:?}", blob_data);
 
-    println!("Fetching it back (RPC → cloud fallback)");
-    let blob_data = client.get_blob(&blob_hash).await?;
-    println!("Blob data: {blob_data:?}");
+    // 🔗 Log the data availability (DA) link
+    let da_link = format!("{}{}", poda_url, blob_hash);
+    info!("🔗 Access your data here: {}", da_link);
 
+    info!("🏁 Syscoin client flow complete—have a great day!");
     Ok(())
-}
+}