Merge pull request #45 from DIG-Network/release/v0.0.1-alpha.49

Release/v0.0.1 alpha.49

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.49](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.48...v0.0.1-alpha.49) (2024-09-20)
+
+
+### Features
+
+* add cache to getAllEpochPeers ([2ba45ef](https://github.com/DIG-Network/dig-chia-sdk/commit/2ba45effadb6efc6babdef37e82edc9fa2f0bfec))
+
 ### [0.0.1-alpha.48](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.47...v0.0.1-alpha.48) (2024-09-20)
 
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@dignetwork/dig-sdk",
-  "version": "0.0.1-alpha.48",
+  "version": "0.0.1-alpha.49",
   "description": "",
   "type": "commonjs",
   "main": "./dist/index.js",
@@ -41,6 +41,7 @@
     "merkletreejs": "^0.4.0",
     "nanospinner": "^1.1.0",
     "nconf": "^0.12.1",
+    "node-cache": "^5.1.2",
     "p-limit": "^6.1.0",
     "superagent": "^10.0.0"
   },

src/blockchain/ServerCoin.ts

@@ -14,9 +14,13 @@ import { Wallet } from "./Wallet";
 import { NconfManager } from "../utils/NconfManager";
 import { CoinData, ServerCoinData } from "../types";
 import { DataStore } from "./DataStore";
+import NodeCache from "node-cache";
 
 const serverCoinCollateral = 300_000_000;
 
+// Initialize the cache with a TTL of 300 seconds (5 minutes)
+const serverCoinPeersCache = new NodeCache({ stdTTL: 300 });
+
 export class ServerCoin {
   private storeId: string;
   public static readonly serverCoinManager = new NconfManager(
@@ -179,22 +183,21 @@ export class ServerCoin {
     );
   }
 
-  public async getAllEpochPeers(
-    epoch: number,
-    blacklist: string[] = []
-  ): Promise<string[]> {
-    const epochBasedHint = morphLauncherId(
-      Buffer.from(this.storeId, "hex"),
-      BigInt(epoch)
-    );
+  public async getAllEpochPeers(epoch: number, blacklist: string[] = []): Promise<string[]> {
+    const cacheKey = `serverCoinPeers-${this.storeId}-${epoch}`;
+
+    // Check if the result is already cached
+    const cachedPeers = serverCoinPeersCache.get<string[]>(cacheKey);
+    if (cachedPeers) {
+      return cachedPeers;
+    }
+
+    const epochBasedHint = morphLauncherId(Buffer.from(this.storeId, "hex"), BigInt(epoch));
 
     const peer = await FullNodePeer.connect();
     const maxClvmCost = BigInt(11_000_000_000);
 
-    const hintedCoinStates = await peer.getHintedCoinStates(
-      epochBasedHint,
-      false
-    );
+    const hintedCoinStates = await peer.getHintedCoinStates(epochBasedHint, false);
 
     const filteredCoinStates = hintedCoinStates.filter(
       (coinState) => coinState.coin.amount >= serverCoinCollateral
@@ -215,7 +218,12 @@ export class ServerCoin {
       console.log("Server Coin Peers: ", serverCoinPeers);
     }
 
-    return Array.from(serverCoinPeers);
+    const peerList = Array.from(serverCoinPeers);
+
+    // Cache the result
+    serverCoinPeersCache.set(cacheKey, peerList);
+
+    return peerList;
   }
 
   public async getActiveEpochPeers(