Jelajahi Sumber

bin/darkirc,bin/taud,bin/genev: use the genesis timestamp as a dag name

oars 10 bulan lalu
induk
melakukan
4e94188d75
3 mengubah file dengan 3 tambahan dan 3 penghapusan
  1. 1 1
      bin/darkirc/src/irc/client.rs
  2. 1 1
      bin/genev/genevd/src/rpc.rs
  3. 1 1
      bin/tau/taud/src/main.rs

+ 1 - 1
bin/darkirc/src/irc/client.rs

@@ -196,7 +196,7 @@ impl Client {
                                 let event_id = event.header.id();
                                 *self.last_sent.write().await = event_id;
                                 let current_genesis = self.server.darkirc.event_graph.current_genesis.read().await;
-                                let dag_name = current_genesis.id().to_string();
+                                let dag_name = current_genesis.header.timestamp.to_string();
 
                                 // If it fails for some reason, for now, we just note it and pass.
                                 if let Err(e) = self.server.darkirc.event_graph.header_dag_insert(vec![event.header.clone()], &dag_name).await {

+ 1 - 1
bin/genev/genevd/src/rpc.rs

@@ -209,7 +209,7 @@ impl JsonRpcInterface {
         let event = Event::new(serialize_async(&genevent).await, &self.event_graph).await;
 
         let current_genesis = self.event_graph.current_genesis.read().await;
-        let dag_name = current_genesis.id().to_string();
+        let dag_name = current_genesis.header.timestamp.to_string();
         if let Err(e) =
             self.event_graph.header_dag_insert(vec![event.header.clone()], &dag_name).await
         {

+ 1 - 1
bin/tau/taud/src/main.rs

@@ -323,7 +323,7 @@ async fn start_sync_loop(
                     // If it fails for some reason, for now, we just note it
                     // and pass.
                     let current_genesis = event_graph.current_genesis.read().await;
-                    let dag_name = current_genesis.id().to_string();
+                    let dag_name = current_genesis.header.timestamp.to_string();
                     if let Err(e) = event_graph.header_dag_insert(vec![event.header.clone()], &dag_name).await {
                         error!(target: "taud", "Failed inserting new header to DAG: {}", e);
                     }