add changes

atoma-network · Apr 15, 2024 · 1e3ab00 · 1e3ab00
1 parent af9d620
commit 1e3ab00
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/atoma-event-subscribe/sui/src/main.rs b/atoma-event-subscribe/sui/src/main.rs
@@ -22,9 +22,9 @@ async fn main() -> Result<(), SuiSubscriberError> {
 
     let args = Args::parse();
     let package_id = ObjectID::from_hex_literal(&args.package_id)?;
-
     let http_url = args.http_addr;
     let ws_url = args.ws_socket_addr;
+
     let (event_sender, mut event_receiver) = tokio::sync::mpsc::channel(32);
 
     let event_subscriber =

diff --git a/atoma-event-subscribe/sui/src/subscriber.rs b/atoma-event-subscribe/sui/src/subscriber.rs
@@ -52,10 +52,7 @@ impl SuiSubscriber {
 
     pub async fn subscribe(self) -> Result<(), SuiSubscriberError> {
         let event_api = self.sui_client.event_api();
-        let mut subscribe_event = event_api.subscribe_event(self.filter).await.map_err(|e| {
-            error!("Got error: {e}");
-            e
-        })?;
+        let mut subscribe_event = event_api.subscribe_event(self.filter).await?;
         info!("Starting event while loop");
         while let Some(event) = subscribe_event.next().await {
             match event {

diff --git a/atoma-node/src/main.rs b/atoma-node/src/main.rs
@@ -1,3 +1,5 @@
+use std::time::Duration;
+
 use atoma_node::{AtomaNode, AtomaNodeError};
 use clap::Parser;
 use tokio::sync::mpsc;
@@ -25,7 +27,7 @@ async fn main() -> Result<(), AtomaNodeError> {
 
     let (_, json_rpc_server_rx) = mpsc::channel(CHANNEL_BUFFER);
     tokio::spawn(async move {
-        let atoma_node = AtomaNode::start(
+        let _atoma_node = AtomaNode::start(
             model_config_path,
             private_key_path,
             sui_subscriber_path,
@@ -35,5 +37,6 @@ async fn main() -> Result<(), AtomaNodeError> {
         Ok::<(), AtomaNodeError>(())
     });
 
+    tokio::time::sleep(Duration::from_secs(20)).await;
     Ok(())
 }