Merge pull request #66 from DIG-Network/release/v0.0.1-alpha.71

Release/v0.0.1 alpha.71

Author: MichaelTaylor3D

CHANGELOG.md

@@ -2,6 +2,13 @@
 
 All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
 
+### [0.0.1-alpha.71](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.70...v0.0.1-alpha.71) (2024-09-23)
+
+
+### Bug Fixes
+
+* bad propagation server constructor ([305782f](https://github.com/DIG-Network/dig-chia-sdk/commit/305782f03e6c5d99da01efd962a29bf04078155e))
+
 ### [0.0.1-alpha.70](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.69...v0.0.1-alpha.70) (2024-09-23)
 
 

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/dig-sdk",
-  "version": "0.0.1-alpha.70",
+  "version": "0.0.1-alpha.71",
   "description": "",
   "type": "commonjs",
   "main": "./dist/index.js",

package.json

@@ -417,37 +417,32 @@ export class PropagationServer {
     const config: AxiosRequestConfig = {
       responseType: "arraybuffer", // To store the file content in memory
       httpsAgent: this.createHttpsAgent(),
-    };
-
-    const url = `https://${this.ipAddress}:${PropagationServer.port}/fetch/${this.storeId}/${dataPath}`;
-
-    try {
-      const response = await axios.get(url, config);
-      const totalLength = parseInt(response.headers["content-length"], 10);
-
-      console.log(cyan(`Starting fetch for ${dataPath}...`));
-
-      // Create a progress bar for the download
-      const progressBar = PropagationServer.multiBar.create(totalLength, 0, {
-        dataPath: yellow(dataPath),
-        percentage: 0,
-      });
-
-      let downloadedBytes = 0;
+      onDownloadProgress: (progressEvent) => {
+        const totalLength = progressEvent.total || 0;
+        const downloadedBytes = progressEvent.loaded;
+
+        // Update progress bar
+        const progressBar = PropagationServer.multiBar.create(totalLength, 0, {
+          dataPath: yellow(dataPath),
+          percentage: 0,
+        });
 
-      // Track progress of downloading the file
-      response.data.on("data", (chunk: Buffer) => {
-        downloadedBytes += chunk.length;
         progressBar.update(downloadedBytes, {
           percentage: Math.round((downloadedBytes / totalLength) * 100),
         });
-      });
 
-      // Complete the progress bar once done
-      progressBar.update(totalLength, { percentage: 100 });
-      progressBar.stop();
+        if (downloadedBytes === totalLength) {
+          progressBar.update(totalLength, { percentage: 100 });
+          progressBar.stop();
+          console.log(green(`✔ File ${dataPath} fetched successfully.`));
+        }
+      },
+    };
 
-      console.log(green(`✔ File ${dataPath} fetched successfully.`));
+    const url = `https://${this.ipAddress}:${PropagationServer.port}/fetch/${this.storeId}/${dataPath}`;
+
+    try {
+      const response = await axios.get(url, config);
 
       // Return the file contents as a Buffer
       return Buffer.from(response.data);
@@ -581,7 +576,8 @@ export class PropagationServer {
     await propagationServer.initializeWallet();
 
     // Check if the store exists
-    const { storeExists, rootHashExists} = await propagationServer.checkStoreExists(rootHash);
+    const { storeExists, rootHashExists } =
+      await propagationServer.checkStoreExists(rootHash);
     if (!storeExists || !rootHashExists) {
       throw new Error(`Store ${storeId} does not exist.`);
     }