dnetview: Import fixes and explicit hex crate usage.

bin/dnetview/Cargo.toml

@@ -36,4 +36,4 @@ thiserror = "1.0.34"
 # Encoding and parsing
 serde_json = "1.0.85"
 serde = {version = "1.0.144", features = ["derive"]}
-
+hex = "0.4.3"

bin/dnetview/src/main.rs

@@ -1,12 +1,7 @@
-use async_std::sync::Arc;
 use std::{fs::File, io, io::Read};
 
+use async_std::sync::Arc;
 use clap::Parser;
-use darkfi::util::{
-    cli::{get_log_config, get_log_level, spawn_config, Config},
-    expand_path,
-    path::get_config_path,
-};
 use easy_parallel::Parallel;
 use log::info;
 use simplelog::*;
@@ -16,6 +11,13 @@ use tui::{
     backend::{Backend, TermionBackend},
     Terminal,
 };
+
+use darkfi::util::{
+    async_util,
+    cli::{get_log_config, get_log_level, spawn_config, Config},
+    path::{expand_path, get_config_path},
+};
+
 pub mod config;
 pub mod error;
 pub mod model;
@@ -101,7 +103,7 @@ impl DnetView {
                     _ => (),
                 }
             }
-            util::sleep(100).await;
+            async_util::msleep(100).await;
         }
     }
 }

bin/dnetview/src/model.rs

@@ -1,9 +1,8 @@
 use async_std::sync::{Arc, Mutex};
-
 use fxhash::FxHashMap;
 use serde::{Deserialize, Serialize};
 
-use darkfi::util::NanoTimestamp;
+use darkfi::util::time::NanoTimestamp;
 
 type MsgLog = Vec<(NanoTimestamp, String, String)>;
 type MsgMap = Mutex<FxHashMap<String, MsgLog>>;

bin/dnetview/src/parser.rs

@@ -1,12 +1,12 @@
-use async_std::sync::Arc;
 use std::collections::hash_map::Entry;
 
+use async_std::sync::Arc;
 use log::{debug, error, info};
 use serde_json::Value;
 use smol::Executor;
 use url::Url;
 
-use darkfi::util::NanoTimestamp;
+use darkfi::util::{async_util, time::NanoTimestamp};
 
 use crate::{
     config::{DnvConfig, Node, NodeType},
@@ -55,7 +55,7 @@ impl DataParser {
                 }
             }
             self.parse_offline(node.name.clone()).await?;
-            crate::util::sleep(2000).await;
+            async_util::sleep(2000).await;
         }
     }
 
@@ -96,7 +96,7 @@ impl DataParser {
             }
 
             // Sleep until next poll
-            crate::util::sleep(2000).await;
+            async_util::sleep(2000).await;
         }
     }
 

bin/dnetview/src/rpc.rs

@@ -1,11 +1,11 @@
+use serde_json::{json, Value};
+use url::Url;
+
 use darkfi::{
     error::Result,
     rpc::{client::RpcClient, jsonrpc::JsonRequest},
 };
 
-use serde_json::{json, Value};
-use url::Url;
-
 use crate::error::{DnetViewError, DnetViewResult};
 
 pub struct RpcConnect {

bin/dnetview/src/util.rs

@@ -1,15 +1,9 @@
-use crate::model::{ConnectInfo, Session};
-use darkfi::{util::serial, Result};
-use smol::Timer;
-use std::time::Duration;
+use darkfi::Result;
 
-/// Sleep for any number of milliseconds.
-pub async fn sleep(millis: u64) {
-    Timer::after(Duration::from_millis(millis)).await;
-}
+use crate::model::{ConnectInfo, Session};
 
 pub fn make_node_id(node_name: &String) -> Result<String> {
-    let mut id = serial::serialize_hex(node_name);
+    let mut id = hex::encode(node_name);
     id.insert_str(0, "NODE");
     Ok(id)
 }
@@ -32,13 +26,13 @@ pub fn make_session_id(node_id: &str, session: &Session) -> Result<String> {
         num += i as u64
     }
 
-    let mut id = serial::serialize_hex(&num);
+    let mut id = hex::encode(&num.to_ne_bytes());
     id.insert_str(0, "SESSION");
     Ok(id)
 }
 
 pub fn make_connect_id(id: &u64) -> Result<String> {
-    let mut id = serial::serialize_hex(id);
+    let mut id = hex::encode(&id.to_ne_bytes());
     id.insert_str(0, "CONNECT");
     Ok(id)
 }
@@ -58,7 +52,7 @@ pub fn make_empty_id(node_id: &str, session: &Session, count: u64) -> Result<Str
                 num += i as u64
             }
             num += count;
-            let mut id = serial::serialize_hex(&num);
+            let mut id = hex::encode(&num.to_ne_bytes());
             id.insert_str(0, "EMPTYIN");
             id
         }
@@ -71,7 +65,7 @@ pub fn make_empty_id(node_id: &str, session: &Session, count: u64) -> Result<Str
                 num += i as u64
             }
             num += count;
-            let mut id = serial::serialize_hex(&num);
+            let mut id = hex::encode(&num.to_ne_bytes());
             id.insert_str(0, "EMPTYOUT");
             id
         }
@@ -84,7 +78,7 @@ pub fn make_empty_id(node_id: &str, session: &Session, count: u64) -> Result<Str
                 num += i as u64
             }
             num += count;
-            let mut id = serial::serialize_hex(&num);
+            let mut id = hex::encode(&num.to_ne_bytes());
             id.insert_str(0, "EMPTYMAN");
             id
         }
@@ -97,7 +91,7 @@ pub fn make_empty_id(node_id: &str, session: &Session, count: u64) -> Result<Str
                 num += i as u64
             }
             num += count;
-            let mut id = serial::serialize_hex(&num);
+            let mut id = hex::encode(&num.to_ne_bytes());
             id.insert_str(0, "EMPTYOFF");
             id
         }

bin/dnetview/src/view.rs

@@ -1,5 +1,4 @@
 use fxhash::FxHashMap;
-
 use tui::{
     backend::Backend,
     layout::{Constraint, Direction, Layout, Rect},
@@ -9,7 +8,7 @@ use tui::{
     Frame,
 };
 
-use darkfi::util::NanoTimestamp;
+use darkfi::util::time::NanoTimestamp;
 
 use crate::{
     error::{DnetViewError, DnetViewResult},