feat: update chaincode to get with pagination for reducing storage load on blockchain

backend/blockchain/chaincode/logVerification/lib/logVerification.js

@@ -1,5 +1,5 @@
 "use strict";
-
+// CC_VERSION=1.3 CC_SEQUENCE=4 ./deployChaincode.sh
 const stringify = require("json-stringify-deterministic");
 const sortKeysRecursive = require("sort-keys-recursive");
 const { Contract } = require("fabric-contract-api");
@@ -142,6 +142,58 @@ class LogVerification extends Contract {
     return allResults;
   }
 
+  async getLogsWithPagination(ctx, pageSize, bookmark) {
+    if (!pageSize || isNaN(pageSize) || pageSize <= 0) {
+      throw new Error("Page size must be a positive integer");
+    }
+
+    if (!bookmark) {
+      bookmark = "";
+    }
+
+    if (pageSize > 100) {
+      throw new Error("Page size must not exceed 100");
+    }
+
+    const { iterator, metadata } = await ctx.stub.getStateByRangeWithPagination(
+      "",
+      "",
+      pageSize,
+      bookmark
+    );
+
+    const logs = [];
+
+    try {
+      while (true) {
+        const res = await iterator.next();
+        if (res.value && res.value.value.length > 0) {
+          const payload = res.value.value.toString("utf8");
+          try {
+            logs.push({
+              txId: res.value.txId,
+              value: JSON.parse(payload),
+            });
+          } catch (err) {
+            throw new Error(`Failed to parse log data: ${err}`);
+          }
+        }
+        if (res.done) {
+          break;
+        }
+      }
+    } finally {
+      await iterator.close();
+    }
+
+    return {
+      logs: logs,
+      fetchedRecordsCount: metadata.fetchedRecordsCount,
+      bookmark: metadata.bookmark,
+      metadata: metadata,
+    };
+  }
+
   async logExists(ctx, id) {
     const logJSON = await ctx.stub.getState(id);
     return logJSON && logJSON.length > 0;