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

Release/v0.0.1 alpha.20

Author: MichaelTaylor3D

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.20](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.19...v0.0.1-alpha.20) (2024-09-16)
+
+
+### Features
+
+* find any peer on the network with the store and or key ([15cf0af](https://github.com/DIG-Network/dig-chia-sdk/commit/15cf0af395ccc9009a6e9ff898c6f5d21ba4d92a))
+
 ### [0.0.1-alpha.19](https://github.com/DIG-Network/dig-chia-sdk/compare/v0.0.1-alpha.18...v0.0.1-alpha.19) (2024-09-16)
 
 

package-lock.json

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

package.json

@@ -83,7 +83,7 @@ export class ContentServer {
   }
 
   // Method to check if a specific store exists (HEAD request)
-  public async headStore(options?: { hasRootHash: boolean}): Promise<{
+  public async headStore(options?: { hasRootHash: string}): Promise<{
     success: boolean;
     headers?: http.IncomingHttpHeaders;
   }> {

src/DigNetwork/ContentServer.ts

@@ -157,6 +157,53 @@ export class DigNetwork {
     await digNetwork.downloadFiles(true);
   }
 
+  public static async findPeerWithStoreKey(
+    storeId: string,
+    rootHash: string,
+    key: string
+  ): Promise<string | null> {
+    const peerBlackList: string[] = [];
+    const serverCoin = new ServerCoin(storeId);
+
+    while (true) {
+      try {
+        const digPeers = await serverCoin.sampleCurrentEpoch(1, peerBlackList);
+        if (digPeers.length === 0) break;
+
+        const peerIp = digPeers[0];
+        const digPeer = new DigPeer(peerIp, storeId);
+        const storeResponse = await digPeer.contentServer.headStore({
+          hasRootHash: rootHash,
+        });
+
+        if (
+          storeResponse.success &&
+          storeResponse.headers?.["x-has-rootHash"] === "true"
+        ) {
+          if (!key) return peerIp;
+
+          const keyResponse = await digPeer.contentServer.headKey(key);
+          if (
+            keyResponse.success &&
+            keyResponse.headers?.["x-key-exists"] === "true"
+          ) {
+            return peerIp;
+          }
+        }
+
+        peerBlackList.push(peerIp);
+      } catch (error) {
+        console.error(
+          "Error while sampling the epoch or contacting peer:",
+          error
+        );
+        break;
+      }
+    }
+
+    return null;
+  }
+
   public static unsubscribeFromStore(storeId: string): void {
     fs.rmdirSync(path.join(DIG_FOLDER_PATH, "stores", storeId), {
       recursive: true,