Merge pull request #109 from DIG-Network/release/v0.0.1-alpha.120

Release/v0.0.1 alpha.120

Author: MichaelTaylor3D

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.120](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.119...v0.0.1-alpha.120) (2024-10-03)
+
 ### [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)

package-lock.json

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

package.json

@@ -319,34 +319,69 @@ export class DataStore {
         latestStore: ReturnType<DataStoreSerializer["serialize"]>;
         latestHeight: number;
         latestHash: string;
-      }>(`stores`, USER_DIR_PATH);
+      }>(`stores`);
 
-      if (!Environment.CLI_MODE) {
-        // Kick off the updater instance in the backgounf if not already running
-        StoreInfoCacheUpdater.initInstance();
+      // Try to get cached store info
+      const cachedInfo = storeCoinCache.get(this.storeId);
 
-        // Try to get cached store info
-        const cachedInfo = storeCoinCache.get(this.storeId);
+      if (cachedInfo) {
+        try {
+          const {
+            latestStore: serializedStore,
+            latestHeight: previousHeight,
+            latestHash: previousHash,
+          } = cachedInfo;
 
-        if (cachedInfo) {
-          // If we have cached info, return it directly
-          const { latestStore } = DataStoreSerializer.deserialize(
+          // Deserialize the stored data using DataStoreSerializer
+          const { latestStore: previousInfo } = DataStoreSerializer.deserialize(
             {
-              latestStore: cachedInfo.latestStore,
-              latestHeight: cachedInfo.latestHeight.toString(),
-              latestHash: cachedInfo.latestHash,
+              latestStore: serializedStore,
+              latestHeight: previousHeight.toString(),
+              latestHash: previousHash,
             }
           );
 
+          // Sync with peer if necessary
+          const peer = await FullNodePeer.connect();
+          const { latestStore, latestHeight } = await peer.syncStore(
+            previousInfo,
+            previousHeight,
+            Buffer.from(previousHash, "hex"),
+            false
+          );
+          const latestHash = await peer.getHeaderHash(latestHeight);
+
+          // Serialize the store data for caching
+          const serializedLatestStore = new DataStoreSerializer(
+            latestStore,
+            latestHeight,
+            latestHash
+          ).serialize();
+
+          // Cache updated store info
+          storeCoinCache.set(this.storeId, {
+            latestStore: serializedLatestStore,
+            latestHeight,
+            latestHash: latestHash.toString("hex"),
+          });
+
+          return { latestStore, latestHeight, latestHash };
+        } catch {
+          // Return cached info if sync fails
+          const { latestStore, latestHeight, latestHash } =
+            DataStoreSerializer.deserialize({
+              latestStore: cachedInfo.latestStore,
+              latestHeight: cachedInfo.latestHeight.toString(),
+              latestHash: cachedInfo.latestHash,
+            });
           return {
             latestStore,
-            latestHeight: cachedInfo.latestHeight,
-            latestHash: Buffer.from(cachedInfo.latestHash, "hex"),
+            latestHeight,
+            latestHash: latestHash,
           };
         }
       }
 
-      // If no cached info, proceed to fetch and cache it
       // Use getCreationHeight to retrieve height and hash information
       const { createdAtHeight, createdAtHash } = await this.getCreationHeight();