feat: added pagination in invoice

Change response type + test cases

TICKET: BTC-2110

Author: parvbitgo067

examples/ts/btc/lightning/list-invoices.ts

@@ -58,7 +58,7 @@ async function main(): Promise<void> {
       status,
       limit: limit ? BigInt(limit) : undefined,
     };
-    const invoices = await lightning.listInvoices(query);
+    const { invoices } = await lightning.listInvoices(query);
 
     // Display invoice summary
     console.log(`\nFound ${invoices.length} invoices:`);

modules/abstract-lightning/src/codecs/api/invoice.ts

@@ -82,10 +82,29 @@ export const InvoiceInfo = t.intersection(
 );
 export type InvoiceInfo = t.TypeOf<typeof InvoiceInfo>;
 
+export const ListInvoicesResponse = t.intersection(
+  [
+    t.type({
+      invoices: t.array(InvoiceInfo),
+    }),
+    t.partial({
+      /**
+       * This is the paymentHash of the last Invoice in the last iteration.
+       * Providing this value as the prevId in the next request will return the next batch of invoices.
+       * */
+      nextBatchPrevId: t.string,
+    }),
+  ],
+  'ListInvoicesResponse'
+);
+export type ListInvoicesResponse = t.TypeOf<typeof ListInvoicesResponse>;
+
 export const InvoiceQuery = t.partial(
   {
     status: InvoiceStatus,
     limit: BigIntFromString,
+    /** paymentHash provided by nextBatchPrevId in the previous list */
+    prevId: t.string,
     startDate: DateFromISOString,
     endDate: DateFromISOString,
   },

modules/abstract-lightning/src/wallet/lightning.ts

@@ -26,6 +26,7 @@ import {
   PaymentQuery,
   LightningOnchainWithdrawParams,
   LightningOnchainWithdrawResponse,
+  ListInvoicesResponse,
 } from '../codecs';
 import { LightningPaymentIntent, LightningPaymentRequest } from '@bitgo/public-types';
 
@@ -143,9 +144,10 @@ export interface ILightningWallet {
    * @param {bigint} [params.limit] The maximum number of invoices to return
    * @param {Date} [params.startDate] The start date for the query
    * @param {Date} [params.endDate] The end date for the query
-   * @returns {Promise<InvoiceInfo[]>} List of invoices
+   * @param {Date} [params.prevId] Continue iterating (provided by nextBatchPrevId in the previous list)
+   * @returns {Promise<ListInvoicesResponse>} List of invoices and nextBatchPrevId
    */
-  listInvoices(params: InvoiceQuery): Promise<InvoiceInfo[]>;
+  listInvoices(params: InvoiceQuery): Promise<ListInvoicesResponse>;
 
   /**
    * Pay a lightning invoice
@@ -234,8 +236,8 @@ export class LightningWallet implements ILightningWallet {
     });
   }
 
-  async listInvoices(params: InvoiceQuery): Promise<InvoiceInfo[]> {
-    const returnCodec = t.array(InvoiceInfo);
+  async listInvoices(params: InvoiceQuery): Promise<ListInvoicesResponse> {
+    const returnCodec = ListInvoicesResponse;
     const createInvoiceResponse = await this.wallet.bitgo
       .get(this.wallet.bitgo.url(`/wallet/${this.wallet.id()}/lightning/invoice`, 2))
       .query(InvoiceQuery.encode(params))

modules/bitgo/test/v2/unit/lightning/lightningWallets.ts

@@ -264,10 +264,49 @@ describe('Lightning wallets', function () {
       const listInvoicesNock = nock(bgUrl)
         .get(`/api/v2/wallet/${wallet.wallet.id()}/lightning/invoice`)
         .query(InvoiceQuery.encode(query))
-        .reply(200, [InvoiceInfo.encode(invoice)]);
+        .reply(200, { invoices: [InvoiceInfo.encode(invoice)] });
       const invoiceResponse = await wallet.listInvoices(query);
-      assert.strictEqual(invoiceResponse.length, 1);
-      assert.deepStrictEqual(invoiceResponse[0], invoice);
+      assert.strictEqual(invoiceResponse.invoices.length, 1);
+      assert.deepStrictEqual(invoiceResponse.invoices[0], invoice);
+      listInvoicesNock.done();
+    });
+
+    it('should work properly with pagination while listing invoices', async function () {
+      const invoice1: InvoiceInfo = {
+        valueMsat: 1000n,
+        paymentHash: 'foo1',
+        invoice: 'tlnfoobar1',
+        walletId: wallet.wallet.id(),
+        status: 'open',
+        expiresAt: new Date(),
+        createdAt: new Date(),
+        updatedAt: new Date(),
+      };
+      const invoice2: InvoiceInfo = {
+        ...invoice1,
+        paymentHash: 'foo2',
+        invoice: 'tlnfoobar2',
+      };
+      const invoice3: InvoiceInfo = {
+        ...invoice1,
+        paymentHash: 'foo3',
+        invoice: 'tlnfoobar3',
+      };
+      const allInvoices = [InvoiceInfo.encode(invoice1), InvoiceInfo.encode(invoice2), InvoiceInfo.encode(invoice3)];
+      const query = {
+        status: 'open',
+        startDate: new Date(),
+        limit: 2n,
+      } as InvoiceQuery;
+      const listInvoicesNock = nock(bgUrl)
+        .get(`/api/v2/wallet/${wallet.wallet.id()}/lightning/invoice`)
+        .query(InvoiceQuery.encode(query))
+        .reply(200, { invoices: allInvoices.slice(0, 2), nextBatchPrevId: invoice2.paymentHash });
+      const invoiceResponse = await wallet.listInvoices(query);
+      assert.strictEqual(invoiceResponse.invoices.length, 2);
+      assert.deepStrictEqual(invoiceResponse.invoices[0], invoice1);
+      assert.deepStrictEqual(invoiceResponse.invoices[1], invoice2);
+      assert.strictEqual(invoiceResponse.nextBatchPrevId, invoice2.paymentHash);
       listInvoicesNock.done();
     });