Merge pull request #23 from DIG-Network/release/v0.0.1-alpha.25

Release/v0.0.1 alpha.25

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.25](https://github.com/DIG-Network/dig-propagation-server/compare/v0.0.1-alpha.24...v0.0.1-alpha.25) (2024-09-20)
+
 ### [0.0.1-alpha.24](https://github.com/DIG-Network/dig-propagation-server/compare/v0.0.1-alpha.23...v0.0.1-alpha.24) (2024-09-20)
 
 ### [0.0.1-alpha.23](https://github.com/DIG-Network/dig-propagation-server/compare/v0.0.1-alpha.22...v0.0.1-alpha.23) (2024-09-20)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dig-propagation-server",
-  "version": "0.0.1-alpha.24",
+  "version": "0.0.1-alpha.25",
   "description": "",
   "type": "commonjs",
   "main": "./dist/index.js",
@@ -24,7 +24,7 @@
     "LICENSE"
   ],
   "dependencies": {
-    "@dignetwork/dig-sdk": "^0.0.1-alpha.46",
+    "@dignetwork/dig-sdk": "^0.0.1-alpha.48",
     "async-mutex": "^0.5.0",
     "chia-server-coin": "^0.0.5",
     "express": "^4.19.2",

src/tasks/sync_stores.ts

@@ -1,14 +1,14 @@
 import fs from "fs";
+import path from 'path';
 import { SimpleIntervalJob, Task } from "toad-scheduler";
 import {
   getStoresList,
-  getManifestFilePath,
   Wallet, 
   DataStore,
   DigNetwork,
   NconfManager,
-  ServerCoin
-  // @ts-ignore
+  ServerCoin,
+  STORE_PATH
 } from "@dignetwork/dig-sdk";
 import { Mutex } from "async-mutex";
 
@@ -42,19 +42,23 @@ const isStoreUpToDate = async (storeId: string): Promise<boolean> => {
   const dataStore = await DataStore.from(storeId);
 
   const rootHistory = await dataStore.getRootHistory();
+  const storePath = path.join(STORE_PATH, storeId);
 
-  const manifestFilePath = getManifestFilePath(storeId);
-  if (!fs.existsSync(manifestFilePath)) {
-    console.log(`Manifest file not found for store ${storeId}.`);
+  if (!fs.existsSync(storePath)) {
+    console.log(`Store path not found for store ${storeId}.`);
     return false;
   }
 
-  const manifest = fs.readFileSync(manifestFilePath, "utf-8").trim();
-  const manifestRootHashes = manifest.split("\n");
+  // Get the count of .dat files in the store directory
+  const datFiles = fs.readdirSync(storePath).filter(file => file.endsWith(".dat") && !file.includes('manifest'));
+  const datFileCount = datFiles.length;
 
-  return rootHistory.length === manifestRootHashes.length;
+  console.log(`Root history count: ${rootHistory.length}, .dat files count: ${datFileCount}`);
+
+  return rootHistory.length === datFileCount;
 };
 
+
 const syncStoreFromNetwork = async (storeId: string): Promise<void> => {
   try {
     console.log(`Attempting to sync store ${storeId} from the network...`);