Merge pull request #108 from DIG-Network/release/v0.0.1-alpha.119

Release/v0.0.1 alpha.119

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 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.119](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.118...v0.0.1-alpha.119) (2024-10-03)
+
 ### [0.0.1-alpha.118](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.117...v0.0.1-alpha.118) (2024-10-03)
 
 ### [0.0.1-alpha.117](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.116...v0.0.1-alpha.117) (2024-10-03)

package.json

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

src/blockchain/StoreInfoCacheUpdater.ts

@@ -10,6 +10,7 @@ import {
   Peer,
   getMainnetGenesisChallenge,
 } from "@dignetwork/datalayer-driver";
+import { get } from "lodash";
 
 export class StoreInfoCacheUpdater {
   private static instance: StoreInfoCacheUpdater;
@@ -52,7 +53,7 @@ export class StoreInfoCacheUpdater {
   private async startMonitors() {
     try {
       console.log("Checking if lockfile exists...");
-      
+
       // Check if the lock file exists
       if (!fs.existsSync(this.lockFilePath)) {
         console.log("Lockfile does not exist. Proceeding without lock.");
@@ -80,7 +81,7 @@ export class StoreInfoCacheUpdater {
       });
 
       console.log("Lock acquired, starting monitors...");
-      
+
       // Renew the lock every minute by reacquiring it
       this.renewLock();
 
@@ -190,12 +191,29 @@ export class StoreInfoCacheUpdater {
 
         console.log(`Waiting for coin to be spent: ${coinId.toString("hex")}`);
 
-        // Wait for the coin to be spent
-        await peer.waitForCoinToBeSpent(
-          coinId,
-          latestHeight,
-          Buffer.from(latestHash, "hex")
-        );
+        try {
+          // Wait for the coin to be spent
+          await peer.waitForCoinToBeSpent(
+            coinId,
+            latestHeight,
+            Buffer.from(latestHash, "hex")
+          );
+        } catch {
+          const genesisChallenge = await getMainnetGenesisChallenge();
+          const storeInfo = await withTimeout(
+            peer.syncStore(latestStore, null, genesisChallenge, false),
+            60000,
+            `Timeout syncing store for storeId ${storeId}`
+          );
+
+          const headerHash = await peer.getHeaderHash(storeInfo.latestHeight);
+
+          await peer.waitForCoinToBeSpent(
+            getCoinId(storeInfo.latestStore.coin),
+            storeInfo.latestHeight,
+            headerHash
+          );
+        }
 
         console.log(`Detected Coin Spend: ${coinId.toString("hex")}`);