[!] fix update hold_edge

ZhongFuze · May 15, 2024 · ea240e4 · ea240e4
1 parent e67bc47
commit ea240e4
Showing 1 changed file with 15 additions and 11 deletions.
diff --git a/src/upstream/genome/mod.rs b/src/upstream/genome/mod.rs
@@ -3,11 +3,11 @@ mod tests;
 use crate::config::C;
 use crate::error::Error;
 use crate::tigergraph::edge::{Hold, Resolve};
-use crate::tigergraph::upsert::create_ens_identity_ownership;
+// use crate::tigergraph::upsert::create_ens_identity_ownership;
 use crate::tigergraph::upsert::create_identity_domain_resolve_record;
 use crate::tigergraph::upsert::create_identity_domain_reverse_resolve_record;
-use crate::tigergraph::upsert::create_identity_to_contract_hold_record;
-// use crate::tigergraph::upsert::create_identity_to_identity_hold_record;
+// use crate::tigergraph::upsert::create_identity_to_contract_hold_record;
+use crate::tigergraph::upsert::create_identity_to_identity_hold_record;
 use crate::tigergraph::vertex::{Contract, Identity};
 use crate::upstream::{
     Chain, ContractCategory, DataFetcher, DataSource, DomainNameSystem, Fetcher, Platform, Target,
@@ -164,7 +164,7 @@ async fn fetch_domain_by_address(
             updated_at: naive_now(),
         };
 
-        let contract = Contract {
+        let _contract = Contract {
             uuid: Uuid::new_v4(),
             category: ContractCategory::GNS,
             address: ContractCategory::GNS.default_contract_address().unwrap(),
@@ -173,12 +173,14 @@ async fn fetch_domain_by_address(
             updated_at: naive_now(),
         };
 
+        tracing::debug!("{} => {} created.", address, d.name);
+        create_identity_to_identity_hold_record(&cli, &addr, &gno, &hold).await?;
         // 'regular' resolution involves mapping from a name to an address.
         create_identity_domain_resolve_record(&cli, &gno, &addr, &resolve).await?;
 
         // ownership create `Hold_Identity` connection but only Wallet connected to HyperVertex
-        create_ens_identity_ownership(&cli, &addr, &gno, &hold).await?;
-        create_identity_to_contract_hold_record(&cli, &addr, &contract, &hold).await?;
+        // create_ens_identity_ownership(&cli, &addr, &gno, &hold).await?;
+        // create_identity_to_contract_hold_record(&cli, &addr, &contract, &hold).await?;
 
         if d.is_default {
             // 'reverse' resolution maps from an address back to a name.
@@ -190,7 +192,7 @@ async fn fetch_domain_by_address(
                 fetcher: DataFetcher::DataMgrService,
                 updated_at: naive_now(),
             };
-            tracing::info!("is_default: {:?}", d.is_default);
+            tracing::debug!("{} => {} is_default: {:?}", address, d.name, d.is_default);
             create_identity_domain_reverse_resolve_record(&cli, &addr, &gno, &reverse).await?;
         }
     }
@@ -274,7 +276,7 @@ async fn fetch_address_by_domain(
             updated_at: naive_now(),
         };
 
-        let contract = Contract {
+        let _contract = Contract {
             uuid: Uuid::new_v4(),
             category: ContractCategory::GNS,
             address: ContractCategory::GNS.default_contract_address().unwrap(),
@@ -283,12 +285,14 @@ async fn fetch_address_by_domain(
             updated_at: naive_now(),
         };
 
+        tracing::debug!("{} => {} created.", address, d.name);
+        create_identity_to_identity_hold_record(&cli, &addr, &gno, &hold).await?;
         // 'regular' resolution involves mapping from a name to an address.
         create_identity_domain_resolve_record(&cli, &gno, &addr, &resolve).await?;
 
         // ownership create `Hold_Identity` connection but only Wallet connected to HyperVertex
-        create_ens_identity_ownership(&cli, &addr, &gno, &hold).await?;
-        create_identity_to_contract_hold_record(&cli, &addr, &contract, &hold).await?;
+        // create_ens_identity_ownership(&cli, &addr, &gno, &hold).await?;
+        // create_identity_to_contract_hold_record(&cli, &addr, &contract, &hold).await?;
 
         if d.is_default {
             // 'reverse' resolution maps from an address back to a name.
@@ -300,7 +304,7 @@ async fn fetch_address_by_domain(
                 fetcher: DataFetcher::DataMgrService,
                 updated_at: naive_now(),
             };
-            tracing::info!("is_default: {:?}", d.is_default);
+            tracing::debug!("{} => {} is_default: {:?}", address, d.name, d.is_default);
             create_identity_domain_reverse_resolve_record(&cli, &addr, &gno, &reverse).await?;
         }
     }