Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion sdk/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ export type {
Unsubscribe,
} from "./events/types.js";

export { getInvoice, listInvoicesBySubmitter, listInvoicesByLP } from "./methods/queries.js";
export { getInvoice, listInvoicesBySubmitter, listInvoicesByLP, getSubmitterInvoices } from "./methods/queries.js";
export { getNftMetadata, getNftOwner } from "./methods/nft.js";
export { submitInvoice } from "./methods/submitInvoice.js";
export { transferLPPosition } from "./methods/transferLPPosition.js";
Expand Down
54 changes: 54 additions & 0 deletions sdk/src/methods/queries.ts
Original file line number Diff line number Diff line change
Expand Up @@ -121,6 +121,60 @@ export async function listInvoicesBySubmitter(

}

/**
* Get invoices submitted by a specific submitter address with pagination.
* @param server Soroban RPC server instance
* @param contractAddress The contract's address
* @param submitter The submitter's address
* @param sourceAccount Account used for simulation
* @param networkPassphrase The network passphrase
* @param page The page number (0-indexed)
* @param pageSize The number of items per page
* @returns Array of invoices
* @throws {ILNError} On simulation errors
* @example
* ```ts
* const invoices = await getSubmitterInvoices(server, contractAddress, "G...", sourceAccount, Networks.TESTNET, 0, 10);
* ```
*/
export async function getSubmitterInvoices(
server: SorobanRpc.Server,
contractAddress: string,
submitter: string,
sourceAccount: Account,
networkPassphrase: string,
page: number = 0,
pageSize: number = 50
): Promise<Invoice[]> {
const contract = new Contract(contractAddress);
const op = contract.call(
"list_invoices_by_submitter",
nativeToScVal(submitter, { type: "address" }),
nativeToScVal(page, { type: "u32" }),
nativeToScVal(pageSize, { type: "u32" })
);

const tx = new TransactionBuilder(sourceAccount, {
fee: BASE_FEE,
networkPassphrase,
})
.addOperation(op)
.setTimeout(30)
.build();

const sim = await retry(() => server.simulateTransaction(tx));

if (SorobanRpc.Api.isSimulationError(sim)) {
throw ILNError.fromError(sim.error);
}
if (!sim.result?.retval) {
return [];
}

const rawArr = scValToNative(sim.result.retval) as Record<string, unknown>[];
return rawArr.map(raw => decodeInvoice(raw as Record<string, unknown>));
}

/**
* List invoices funded by a specific LP address.
* @param server Soroban RPC server instance
Expand Down
22 changes: 21 additions & 1 deletion sdk/tests/queries.test.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { vi, describe, it, expect, beforeEach, afterEach } from 'vitest';
import { getInvoice, listInvoicesBySubmitter, listInvoicesByLP } from '../src/methods/queries.js';
import { getInvoice, listInvoicesBySubmitter, listInvoicesByLP, getSubmitterInvoices } from '../src/methods/queries.js';
import { ILNError } from '../src/errors.js';
import { Account, SorobanRpc } from '@stellar/stellar-sdk';

Expand All @@ -12,4 +12,24 @@ describe('queries', () => {
mockServer.simulateTransaction.mockResolvedValue({ error: 'NotFound' });
await expect(getInvoice(mockServer, "CAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABSC4", 1n, mockAccount, 'pass')).rejects.toThrow(ILNError.InvoiceNotFound);
});

it('getSubmitterInvoices returns empty array when retval is null', async () => {
// @ts-ignore
mockServer.simulateTransaction.mockResolvedValue({ result: { retval: null } });
const result = await getSubmitterInvoices(mockServer, "CAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABSC4", "GAGZSXAR7P7PASD2PGYISBMEZCMSI35TRJXYZTZNNCAUZRDEMHQM2XJS", mockAccount, 'pass', 0, 10);
expect(result).toEqual([]);
});

it('getSubmitterInvoices throws error on simulation error', async () => {
// @ts-ignore
mockServer.simulateTransaction.mockResolvedValue({ error: 'ContractError' });
await expect(getSubmitterInvoices(mockServer, "CAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABSC4", "GAGZSXAR7P7PASD2PGYISBMEZCMSI35TRJXYZTZNNCAUZRDEMHQM2XJS", mockAccount, 'pass', 0, 10)).rejects.toThrow();
});

it('getSubmitterInvoices uses default pagination values', async () => {
// @ts-ignore
mockServer.simulateTransaction.mockResolvedValue({ result: { retval: null } });
const result = await getSubmitterInvoices(mockServer, "CAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAABSC4", "GAGZSXAR7P7PASD2PGYISBMEZCMSI35TRJXYZTZNNCAUZRDEMHQM2XJS", mockAccount, 'pass');
expect(result).toEqual([]);
});
});
Loading