@aresrpg/sui-checkpoint-reader - npm Package Compare versions

Comparing version 4.1.23 to 4.1.24

package.json

 {
   "name": "@aresrpg/sui-checkpoint-reader",
-  "version": "4.1.23",
+  "version": "4.1.24",
   "description": "",
@@ -5,0 +5,0 @@ "main": "src/index.js",

src/bcs-generator.js

@@ -5,3 +5,3 @@ import { writeFile } from 'fs/promises'
 
-const VERSION = 'testnet-v1.35.0'
+const VERSION = 'testnet-v1.36.1'
 const YAML_URL =
@@ -8,0 +8,0 @@ 'https://raw.githubusercontent.com/MystenLabs/sui/{version}/crates/sui-core/tests/staged/sui.yaml'

src/snapshot/download_snapshot.js

@@ -118,36 +118,43 @@ import { existsSync } from 'fs'
     const current_batch = object_metadata.splice(0, concurrent_downloads)
-    const objects = await Promise.all(
-      current_batch.map(
-        async ({
-          bucket_num,
-          part_num,
-          file_compression,
-          file_type,
-          sha3_digest,
-        }) => {
-          const { buffer, ref_buffer } = await fetch_object({
-            network,
-            epoch,
-            bucket_num,
-            part_num,
-            save,
-            obj_folder,
-            include_refs,
-          })
 
-          return {
+    try {
+      const objects = await Promise.all(
+        current_batch.map(
+          async ({
             bucket_num,
             part_num,
-            buffer: Buffer.from(buffer),
-            ref_buffer: ref_buffer && Buffer.from(ref_buffer),
             file_compression,
             file_type,
             sha3_digest,
-          }
-        },
-      ),
-    )
+          }) => {
+            const { buffer, ref_buffer } = await fetch_object({
+              network,
+              epoch,
+              bucket_num,
+              part_num,
+              save,
+              obj_folder,
+              include_refs,
+            })
 
-    yield objects
+            return {
+              bucket_num,
+              part_num,
+              buffer: Buffer.from(buffer),
+              ref_buffer: ref_buffer && Buffer.from(ref_buffer),
+              file_compression,
+              file_type,
+              sha3_digest,
+            }
+          },
+        ),
+      )
+
+      yield objects
+    } catch (error) {
+      log.error(error, 'Error downloading checkpoint file. Retrying..')
+      // add the batch back for immediate retry
+      object_metadata.unshift(...current_batch)
+    }
   }
 }

types/get_local_checkpoints.d.ts

@@ -1,1 +0,1 @@
-export function get_local_checkpoints(checkpoints_folder: any): any[];
+export function get_local_checkpoints(checkpoints_folder: any): number[];

No alert changes

Improved metrics

Total package byte prevSize

735549

0.04%

Lines of code

19549

0.03%

No dependency changes