fix: added option to input ledger state for nf data call

Author: arthurvinci

src/GatewayProcessor/GatewayProcessor.ts

@@ -504,18 +504,20 @@ export class GatewayProcessor {
    * Retrieves non-fungibles items associated with specified resource address and ids.
    * @param resource_address Address of the non-fungible items.
    * @param ids Ids of the non-fungible items.
+   * @param at_ledger_state State against which to make the query.
    */
   async getNonFungibleItemsFromIds(
     resource_address: ResourceAddress,
     ids: string[],
+    at_ledger_state?: number,
   ): Promise<NonFungibleItem[]> {
     const nft_batches = divideInBatches(ids, 100);
     const limit = pLimit(this._concurrencyLimit);
     return (
       await Promise.all(
         nft_batches.map(async (batch) => {
           let items_data = await limit(async () =>
-            this.getNonFungibleData(resource_address, batch),
+            this.getNonFungibleData(resource_address, batch, at_ledger_state),
           );
           return items_data.map((item) => {
             let description: string = "";
@@ -874,10 +876,19 @@ export class GatewayProcessor {
   private async getNonFungibleData(
     address: ResourceAddress,
     ids: string[],
+    at_ledger_state?: number,
   ): Promise<StateNonFungibleDetailsResponseItem[]> {
     return withMaxLoops(
       async () => {
-        return await this._api.state.getNonFungibleData(address, ids);
+        return await this._api.state.getNonFungibleData(
+          address,
+          ids,
+          at_ledger_state
+            ? {
+                state_version: at_ledger_state,
+              }
+            : undefined,
+        );
       },
       "Could not query non fungible data",
       this._maxLoops,

tests/GatewayProcessor.tests.ts

@@ -203,3 +203,24 @@ test("Test transaction stream", async () => {
   );
   expect(stream.length).toEqual(10);
 });
+
+test("Test get data with state", async () => {
+  const transactionProcessor = GatewayProcessor.fromNetworkId(
+    NetworkId.Mainnet,
+  );
+
+  let stream = await transactionProcessor.getNonFungibleItemsFromIds(
+    "resource_rdx1n2pf8l2qwzzqz5lyuhmdnlxcjqdyxksa5uhtzjjx8zg2tegcdqkd7p",
+    ["#1750#"],
+    135409909,
+  );
+
+  expect(stream.length).toEqual(1);
+
+  const item = stream[0];
+
+  expect(item.description).toBeDefined();
+  expect(item.non_fungible_data).toBeDefined();
+  expect(item.name).toBeDefined();
+  expect(item.image_url).toBeDefined();
+});