Merge pull request #114 from NextDotID/fix/upstream-dotbit-farcaster

LGTM for me. Merge to staging server for testing for now.

Cargo.toml

@@ -66,6 +66,7 @@ surf = "2.0.0"
 reqwest = { version = "^0.11", features = ["json", "blocking"] }
 isahc = "1.7.2"
 async-recursion = "1.0.4"
+regex = "1.10.2"
 
 [dev-dependencies]
 fake = { version = "2.4", features = ["uuid", "chrono"] }

config/main.sample.toml

@@ -46,5 +46,9 @@ token = "4cb4358d-ce8b-4bf5-fill-yourstokenid"
 [upstream.datamgr_api]
 url = "https://cryptodata.store"
 
+[upstream.warpcast_api]
+url = "https://api.warpcast.com"
+token = "MK-ABC123..."
+
 [upstream.spaceid_api]
 url = "https://api.prd.space.id"

src/config/mod.rs

@@ -43,6 +43,7 @@ pub struct Upstream {
     pub lens_api: ConfigLensAPI,
     pub unstoppable_api: ConfigUnstoppableDomainsAPI,
     pub datamgr_api: ConfigDataMgrAPI,
+    pub warpcast_api: ConfigWarpcastAPI,
     pub spaceid_api: ConfigSpaceIdAPI,
 }
 
@@ -122,6 +123,12 @@ pub struct ConfigDataMgrAPI {
     pub url: String,
 }
 
+#[derive(Clone, Deserialize, Default)]
+pub struct ConfigWarpcastAPI {
+    pub url: String,
+    pub token: String,
+}
+
 #[derive(Clone, Deserialize, Default)]
 pub struct ConfigSpaceIdAPI {
     pub url: String,

src/tigergraph/vertex/identity.rs

@@ -1058,7 +1058,7 @@ impl BatchFn<String, Option<IdentityRecord>> for OwnerLoadFn {
 #[async_trait::async_trait]
 impl BatchFn<String, Option<bool>> for NeighborReverseLoadFn {
     async fn load(&mut self, ids: &[String]) -> HashMap<String, Option<bool>> {
-        tracing::info!("Loading ids for neighbor_reverse_by_ids {:?}", ids);
+        trace!("Loading ids for neighbor_reverse_by_ids {:?}", ids);
         let records = get_neighbor_reverse_by_ids(&self.client, ids.to_vec()).await;
         match records {
             Ok(records) => records,