chore(sui): do less calls to sui

Signed-off-by: aeryz <[email protected]>

wip even more

Signed-off-by: aeryz <[email protected]>

Author: aeryz

voyager/plugins/client-update/sui/src/main.rs

@@ -12,7 +12,7 @@ use sui_sdk::{
         base_types::ObjectID, committee::EpochId, full_checkpoint_content::CheckpointTransaction,
     },
 };
-use tracing::instrument;
+use tracing::{info, instrument};
 use unionlabs::ibc::core::client::height::Height;
 use voyager_sdk::{
     DefaultCmd, anyhow,
@@ -177,26 +177,36 @@ impl Module {
         let mut headers = vec![];
 
         let mut is_first = true;
-        for epoch in from..to {
-            let query = json!({
-              "query": "query ($epoch_id: UInt53) { epoch(epochId: $epoch_id) { checkpoints(last: 1) { edges { node { sequenceNumber } } }  } }",
-              "variables": { "epoch_id": epoch }
-            });
-
-            let resp = client
-                .try_clone()
-                .expect("no body, so this will work")
-                .body(query.to_string())
-                .send()
-                .await
-                .unwrap()
-                .text()
-                .await
-                .unwrap();
+        let epoch_ids: Vec<u64> = (from..to).collect();
+        let query = json!({
+          "query": "query ($epoch_ids: [UInt53]) { multiGetEpochs(keys: $epoch_ids) { checkpoints(last: 1) { edges { node { sequenceNumber } } }  } }",
+          "variables": { "epoch_ids": epoch_ids}
+        });
+
+        let resp = client
+            .try_clone()
+            .expect("no body, so this will work")
+            .body(query.to_string())
+            .send()
+            .await
+            .map_err(RpcError::retryable("error fetching epoch checkpoint"))?
+            .error_for_status()
+            .map_err(RpcError::retryable(
+                "error fetching epoch checkpoint: error status",
+            ))?
+            .text()
+            .await
+            .map_err(RpcError::retryable(
+                "error fetching epoch checkpoint: error reading text from body",
+            ))?;
+
+        info!(%resp);
 
-            let v: serde_json::Value = serde_json::from_str(&resp).unwrap();
+        let v: &serde_json::Value =
+            &serde_json::from_str::<serde_json::Value>(&resp).unwrap()["data"]["multiGetEpochs"];
 
-            let update_to = v["data"]["epoch"]["checkpoints"]["edges"][0]["node"]["sequenceNumber"]
+        for (i, _) in (from..to).enumerate() {
+            let update_to = v[i]["checkpoints"]["edges"][0]["node"]["sequenceNumber"]
                 .as_u64()
                 .unwrap();