Merge pull request #123 from DIG-Network/release/v0.0.1-alpha.135

Release/v0.0.1 alpha.135

CHANGELOG.md

@@ -2,6 +2,18 @@
 
 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.135](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.134...v0.0.1-alpha.135) (2024-10-05)
+
+
+### Features
+
+* bottleneck fullnode requests to 100 requests per min ([85c7529](https://github.com/DIG-Network/dig-chia-sdk/commit/85c7529acf36b1df6c1dff127d9a8c6770abb3f0))
+
+
+### Bug Fixes
+
+* ping peer message ([a18ccae](https://github.com/DIG-Network/dig-chia-sdk/commit/a18ccae01f1685e7ebc73381599e77b334e9e7d5))
+
 ### [0.0.1-alpha.134](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.133...v0.0.1-alpha.134) (2024-10-05)
 
 

dig.crt

@@ -0,0 +1,19 @@
+-----BEGIN CERTIFICATE-----
+MIIDLDCCAhSgAwIBAgIUP/RkfZQ+VLvSfQ2qOf7peUnDd/gwDQYJKoZIhvcNAQEL
+BQAwRDENMAsGA1UECgwEQ2hpYTEQMA4GA1UEAwwHQ2hpYSBDQTEhMB8GA1UECwwY
+T3JnYW5pYyBGYXJtaW5nIERpdmlzaW9uMCAXDTI0MTAwNDE4MzQzNVoYDzIxMDAw
+ODAyMDAwMDAwWjBBMQ0wCwYDVQQDDARDaGlhMQ0wCwYDVQQKDARDaGlhMSEwHwYD
+VQQLDBhPcmdhbmljIEZhcm1pbmcgRGl2aXNpb24wggEiMA0GCSqGSIb3DQEBAQUA
+A4IBDwAwggEKAoIBAQCqvzy6I/4sgmPLLA78WVnmbO63PYS/E0EMNFP/OBi3/4ci
+XnsYzmXnLUgmvi/C5OJiJz8OKKC4sh3GJ1hZxqDDjwr8l2w4mL94IqzA9cvRLSuj
+KlJSlLBk3W9DBat/MGIgFp2bGyIn7EeRC/kg6AChuvWhuQ5LgIB9zjIkIaeIH5Pb
+meQEsNHGtnECO/RwXJ/Md//AlEmX70pwdfXaD83aXjacX/iSsIzzfZ3T6Y0DyncT
+oC+b/HpFsWCq5l72AKgRsn0zuh9gKYw1EjremRRhex/vEGoidncuVyS2Q7gaU+Zs
+6mXKUTYN10C/ffLyaY0j5HtrTAnRu+Sr2SxPqjErAgMBAAGjFzAVMBMGA1UdEQQM
+MAqCCGNoaWEubmV0MA0GCSqGSIb3DQEBCwUAA4IBAQAQ+8jR1tx1lTOpT6dkH8cD
+gLU/I/r2kMehkAVYPCZA2cASlNN1wW/TTfI+lmXDl93XqhLPVuwDXPUcDK/1gIEq
+NtJxBHBgCY4obdiYYWugV9XjwDoUCkqFNLiHBenUsFab6CHTQBh2EwI85bnstyl0
+vyEpeC6bLcCWkhGMX6pVUEGQ1vM6FsxkS/ViGPvLDXTHNRfllHyqvFx/tOwP19cL
+1gmuFFBQ1YEKusJ72eqWgmOL/GB/Zwgk1WeTtzhe7uK/HQdzL8s4Bdh/vcs+c8pH
+pMU+AuxVxBuyhj5XXZpzXt8hoSI0VWL6NNK/AUx7d7hbEsAVB7do7LlqUyWm4GUl
+-----END CERTIFICATE-----

dig.key

@@ -0,0 +1,28 @@
+-----BEGIN PRIVATE KEY-----
+MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCqvzy6I/4sgmPL
+LA78WVnmbO63PYS/E0EMNFP/OBi3/4ciXnsYzmXnLUgmvi/C5OJiJz8OKKC4sh3G
+J1hZxqDDjwr8l2w4mL94IqzA9cvRLSujKlJSlLBk3W9DBat/MGIgFp2bGyIn7EeR
+C/kg6AChuvWhuQ5LgIB9zjIkIaeIH5PbmeQEsNHGtnECO/RwXJ/Md//AlEmX70pw
+dfXaD83aXjacX/iSsIzzfZ3T6Y0DyncToC+b/HpFsWCq5l72AKgRsn0zuh9gKYw1
+EjremRRhex/vEGoidncuVyS2Q7gaU+Zs6mXKUTYN10C/ffLyaY0j5HtrTAnRu+Sr
+2SxPqjErAgMBAAECggEAThMZ4od4vsN0fD+OLqdwqyOeWB2CKJjWQo1e5zGwY9os
+4XNQWDxwbi/PcR+/2R8twPHvLDs5mpqfcK8nAA4KDsHGpU9cBdkanAVG9withN1h
+ub8tW2Nv8P8r0/qwu3zVMZUFxhm3GYg6BUHzTa+oMku565QhzDZbCquRU+Irp9sA
+rZ64MVlqG3rfRz8FdTM3TSNXhX1hcwuXFSWxP9LKnm7CNubKnNHYGtQHsvIrnY3s
+C3M/T8tGBKnuVew+jKBjDDz518Bdmtwmh1ccX7WHX0aYVYNoXvZaGlUTEyVLCZX3
+D/hoTf8FzCSFOy0qH0nPgT9lNopho+eOp+QEVZTDWQKBgQDjn5kY4hCu2WNk2TxA
+E6QIan6ih2EnYdMyrzNHrOX/sTi9iufvOA6yi/P6Ph7mALBdDhfJqFCEZnSqBiN+
+xTkPqqySyq1uy+gToE/tbpqSWZPUXMyNoc6E85jaRX15vngxVNiTOzJlEoykxn/n
+1Ng0pscqKBwvC2o9nf2O9gt9HQKBgQDACHp+rV8SM4dbUOqddQ208jIMTuHMf56d
+tzmE6R6/S2HmDy3siMAjRKgSft9hfDUo7x07UsF/jkUEWXpNHIiwfwLJ0ElkMCd0
+gIQLpsVfmveFa/qQ0cEp7kacuOOT6CE9XBMEIQtkVXCuV5L3Xo+5bC8Fx4jMyayw
+CYm9PCe85wKBgQC50QOt6H4t/pDBNwWUWXRC2ozeKR4KhDVg3t1B2cc4YHgtY0PL
+aTu2TcGxuxyGLnHKxUJuANUaAHmkgrZfOqlGPNH8UzAZjqO5wdj9vpi4eB/R8J+b
+z0dECYfyR2ATDoYX32edaWnOUMI3kUPBAWQuNyfHJk87qFnmSx8+oWTnkQKBgQCf
+VemdtmjOB2dmQ2uIHpmy68rPH5yHO9T2dBMLzwouG3Qtmaa3Pnh+SvdR8WeT0aWi
+Q1Tz5iSbnAZ0J3ItDWH1YE2F+ocK1FHIfuIRcN0QCNscH44WH5SxH/4DB/38uXzr
+FrzIjkqPg70tS4isLBABAFy75OYDVcstfZyGIaWvPQKBgQCTgp5CX8cGiFD5nJ3k
+2qdWSOB/160MdV7EH/FUrzpx/S3mrB+JvlK0J9ei6NH+SUvB7pLHcjzBCHso8h62
+nTzhHyYTo7mFbIOEFhU+Y386EMfIQSplM36a+ZxXC6r+Xz2QyWO4Yh6eI+eS050n
+gK+RBgUP/CyZFqG4I5ucWATdFQ==
+-----END PRIVATE KEY-----

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/dig-sdk",
-  "version": "0.0.1-alpha.134",
+  "version": "0.0.1-alpha.135",
   "description": "",
   "type": "commonjs",
   "main": "./dist/index.js",
@@ -30,6 +30,7 @@
     "archiver": "^7.0.1",
     "axios": "^1.7.7",
     "bip39": "^3.1.0",
+    "bottleneck": "^2.19.5",
     "chia-bls": "^1.0.2",
     "chia-config-loader": "^1.0.1",
     "chia-root-resolver": "^1.0.0",

src/DigNetwork/PropagationServer.ts

@@ -129,10 +129,6 @@ export class PropagationServer {
         headers: {
           "Content-Type": "application/json",
         },
-        validateStatus: (status) => {
-          // Accept all status codes to handle them manually
-          return true;
-        },
       };
 
       // Data to send in the request (storeId and rootHash)
@@ -144,48 +140,9 @@ export class PropagationServer {
 
       try {
         const response = await axios.post(url, data, config);
-
-        if (response.status === 200) {
-          console.log(green(`✔ Peer was up to date: ${this.ipAddress}`));
-          return;
-        } else if (
-          response.status === 400 &&
-          response.data?.error?.includes("does not exist")
-        ) {
-          console.log(
-            yellow(
-              `⚠ Peer ${this.ipAddress} does not have store ${this.storeId}. Notifying for update.`
-            )
-          );
-          // You can implement additional logic here if needed, such as retrying or logging
-          return;
-        } else {
-          console.error(
-            red(
-              `✖ Unexpected response from peer ${this.ipAddress}: ${response.status} ${response.statusText}`
-            )
-          );
-          throw new Error(
-            `Unexpected response: ${response.status} ${response.statusText}`
-          );
-        }
+        console.log(green(`✔ Successfully pinged peer: ${this.ipAddress}`));
+        return response.data;
       } catch (error: any) {
-        if (error.response) {
-          // Server responded with a status other than 2xx
-          if (
-            error.response.status === 400 &&
-            error.response.data?.error?.includes("does not exist")
-          ) {
-            console.log(
-              yellow(
-                `⚠ Peer ${this.ipAddress} does not have store ${this.storeId}. Notifying for update.`
-              )
-            );
-            // You can implement additional logic here if needed
-            return;
-          }
-        }
-
         console.error(red(`✖ Failed to ping peer: ${this.ipAddress}`));
         console.error(red(error.message));
         throw error;

src/blockchain/DataStore.ts

@@ -298,13 +298,13 @@ export class DataStore {
 
   public static getAllStores(): DataStore[] {
     const storeFolders = fs.readdirSync(STORE_PATH);
-    const storIds = storeFolders.filter(
+    const storeIds = storeFolders.filter(
       (folder) =>
         /^[a-f0-9]{64}$/.test(folder) &&
         fs.lstatSync(path.join(STORE_PATH, folder)).isDirectory()
     );
 
-    return storIds.map((storeId) => DataStore.from(storeId));
+    return storeIds.map((storeId) => DataStore.from(storeId));
   }
 
   /**