Add new indexer API to getAccountAllTransactionVersions and use it in getAccountTransactions

CHANGELOG.md

@@ -4,6 +4,9 @@ All notable changes to the Aptos TypeScript SDK will be captured in this file. T
 
 # Unreleased
 
+- Add `getAllAccountTransactionVersions` which returns versions of all transaction versions related to the given address.
+- Add `getAllAccountTransactions` which returns all transactions related to given address instead of only ones sent by address. This makes the result has same length as calling `getAccountTransactionsCount`.
+
 # 1.13.1 (2024-04-23)
 
 - [`Fix`] Fixes Local ABI to use it locally rather than make an external network call

src/api/account.ts

@@ -22,6 +22,7 @@ import {
 } from "../types";
 import {
   deriveAccountFromPrivateKey,
+  GetAllAccountTransactionVersions,
   getAccountCoinAmount,
   getAccountCoinsCount,
   getAccountCoinsData,
@@ -31,6 +32,7 @@ import {
   getAccountOwnedTokensFromCollectionAddress,
   getAccountTokensCount,
   getAccountTransactionsCount,
+  getAllAccountTransactions,
   getInfo,
   getModule,
   getModules,
@@ -118,7 +120,7 @@ export class Account {
   }
 
   /**
-   * Queries account transactions given an account address
+   * Queries account transactions sent by a given account address
    *
    * Note: In order to get all account transactions, this function may call the API
    * multiple times as it auto paginates.
@@ -142,6 +144,52 @@ export class Account {
     });
   }
 
+  /**
+   * Queries account transactions related to a given account address
+   *
+   * Note: In order to get all account transactions, this function may call the API
+   * multiple times as it auto paginates.
+   *
+   * @example
+   * const transactions = await aptos.getAllAccountTransactions({accountAddress:"0x456"})
+   *
+   * @param args.accountAddress Aptos account address
+   * @param args.options.offset The number transaction to start returning results from
+   * @param args.options.limit The number of results to return
+   *
+   * @returns The account transactions
+   */
+  async getAllAccountTransactions(args: {
+    accountAddress: AccountAddressInput;
+    options?: PaginationArgs;
+  }): Promise<TransactionResponse[]> {
+    return getAllAccountTransactions({
+      aptosConfig: this.config,
+      ...args,
+    });
+  }
+
+  /**
+   * Queries account's all transaction versions given an account address
+   *
+   * Note: This returns both the transaction sent by the account and received by the account.
+   *
+   * @param args.accountAddress Aptos account address
+   * @param args.options.offset The number transaction to start returning results from
+   * @param args.options.limit The number of results to return
+   *
+   * @returns The account transaction versions
+   */
+  async GetAllAccountTransactionVersions(args: {
+    accountAddress: AccountAddressInput;
+    options?: PaginationArgs;
+  }): Promise<AnyNumber[]> {
+    return GetAllAccountTransactionVersions({
+      aptosConfig: this.config,
+      ...args,
+    });
+  }
+
   /**
    * Queries all account resources given an account address
    *

src/internal/account.ts

@@ -16,6 +16,7 @@ import { AnyPublicKey, Ed25519PublicKey, PrivateKey } from "../core/crypto";
 import { getTableItem, queryIndexer } from "./general";
 import {
   AccountData,
+  AnyNumber,
   GetAccountCoinsDataResponse,
   GetAccountCollectionsWithOwnedTokenResponse,
   GetAccountOwnedObjectsResponse,
@@ -32,6 +33,7 @@ import {
   WhereArg,
 } from "../types";
 import {
+  GetAllAccountTransactionVersionsQuery,
   GetAccountCoinsCountQuery,
   GetAccountCoinsDataQuery,
   GetAccountCollectionsWithOwnedTokensQuery,
@@ -42,6 +44,7 @@ import {
   GetAccountTransactionsCountQuery,
 } from "../types/generated/operations";
 import {
+  GetAllAccountTransactionVersions as GetAllAccountTransactionVersionsGql,
   GetAccountCoinsCount,
   GetAccountCoinsData,
   GetAccountCollectionsWithOwnedTokens,
@@ -54,6 +57,7 @@ import {
 import { memoizeAsync } from "../utils/memoize";
 import { Secp256k1PrivateKey, AuthenticationKey, Ed25519PrivateKey } from "../core";
 import { CurrentFungibleAssetBalancesBoolExp } from "../types/generated/types";
+import { getTransactionByVersion } from "./transaction";
 
 export async function getInfo(args: {
   aptosConfig: AptosConfig;
@@ -144,6 +148,51 @@ export async function getTransactions(args: {
   });
 }
 
+export async function getAllAccountTransactions(args: {
+  aptosConfig: AptosConfig;
+  accountAddress: AccountAddressInput;
+  options?: PaginationArgs;
+}): Promise<TransactionResponse[]> {
+  const { aptosConfig, accountAddress, options } = args;
+  const versions = await GetAllAccountTransactionVersions({ aptosConfig, accountAddress, options });
+  const results = [];
+  for (const version of versions) {
+    const tx = getTransactionByVersion({ aptosConfig, ledgerVersion: version });
+    results.push(tx);
+  }
+  return Promise.all(results);
+}
+
+export async function GetAllAccountTransactionVersions(args: {
+  aptosConfig: AptosConfig;
+  accountAddress: AccountAddressInput;
+  options?: PaginationArgs;
+}): Promise<AnyNumber[]> {
+  const { aptosConfig, accountAddress, options } = args;
+  const address = AccountAddress.from(accountAddress).toStringLong();
+
+  const whereCondition: { account_address: { _eq: string } } = {
+    account_address: { _eq: address },
+  };
+
+  const graphqlQuery = {
+    query: GetAllAccountTransactionVersionsGql,
+    variables: {
+      where_condition: whereCondition,
+      offset: options?.offset,
+      limit: options?.limit,
+    },
+  };
+
+  const data = await queryIndexer<GetAllAccountTransactionVersionsQuery>({
+    aptosConfig,
+    query: graphqlQuery,
+    originMethod: "GetAllAccountTransactionVersions",
+  });
+
+  return data.account_transactions.map((tx) => tx.transaction_version);
+}
+
 export async function getResources(args: {
   aptosConfig: AptosConfig;
   accountAddress: AccountAddressInput;

src/internal/queries/getAllAccountTransactionVersions.graphql

@@ -0,0 +1,10 @@
+query getAllAccountTransactionVersions($where_condition: account_transactions_bool_exp!, $offset: Int, $limit: Int) {
+  account_transactions(
+    where: $where_condition
+    order_by: { transaction_version: desc }
+    limit: $limit
+    offset: $offset
+  ) {
+    transaction_version
+  }
+}

src/types/generated/operations.ts

@@ -363,6 +363,14 @@ export type GetAccountTransactionsCountQuery = {
   account_transactions_aggregate: { aggregate?: { count: number } | null };
 };
 
+export type GetAllAccountTransactionVersionsQueryVariables = Types.Exact<{
+  where_condition: Types.AccountTransactionsBoolExp;
+  offset?: Types.InputMaybe<Types.Scalars["Int"]["input"]>;
+  limit?: Types.InputMaybe<Types.Scalars["Int"]["input"]>;
+}>;
+
+export type GetAllAccountTransactionVersionsQuery = { account_transactions: Array<{ transaction_version: any }> };
+
 export type GetChainTopUserTransactionsQueryVariables = Types.Exact<{
   limit?: Types.InputMaybe<Types.Scalars["Int"]["input"]>;
 }>;

src/types/generated/queries.ts

@@ -236,6 +236,18 @@ export const GetAccountTransactionsCount = `
   }
 }
     `;
+export const GetAllAccountTransactionVersions = `
+    query getAllAccountTransactionVersions($where_condition: account_transactions_bool_exp!, $offset: Int, $limit: Int) {
+  account_transactions(
+    where: $where_condition
+    order_by: {transaction_version: desc}
+    limit: $limit
+    offset: $offset
+  ) {
+    transaction_version
+  }
+}
+    `;
 export const GetChainTopUserTransactions = `
     query getChainTopUserTransactions($limit: Int) {
   user_transactions(limit: $limit, order_by: {version: desc}) {
@@ -593,6 +605,20 @@ export function getSdk(client: GraphQLClient, withWrapper: SdkFunctionWrapper =
         "query",
       );
     },
+    getAllAccountTransactionVersions(
+      variables: Types.GetAllAccountTransactionVersionsQueryVariables,
+      requestHeaders?: GraphQLClientRequestHeaders,
+    ): Promise<Types.GetAllAccountTransactionVersionsQuery> {
+      return withWrapper(
+        (wrappedRequestHeaders) =>
+          client.request<Types.GetAllAccountTransactionVersionsQuery>(GetAllAccountTransactionVersions, variables, {
+            ...requestHeaders,
+            ...wrappedRequestHeaders,
+          }),
+        "getAllAccountTransactionVersions",
+        "query",
+      );
+    },
     getChainTopUserTransactions(
       variables?: Types.GetChainTopUserTransactionsQueryVariables,
       requestHeaders?: GraphQLClientRequestHeaders,