Add getChainTopUserTransactions.graphql

src/api/general.ts

@@ -4,12 +4,22 @@
 import {
   getBlockByHeight,
   getBlockByVersion,
+  getChainTopUserTransactions,
   getLedgerInfo,
   getTableItem,
   queryIndexer,
   view,
 } from "../internal/general";
-import { Block, GraphqlQuery, LedgerInfo, LedgerVersion, MoveValue, TableItemRequest, ViewRequest } from "../types";
+import {
+  Block,
+  GetChainTopUserTransactionsResponse,
+  GraphqlQuery,
+  LedgerInfo,
+  LedgerVersion,
+  MoveValue,
+  TableItemRequest,
+  ViewRequest,
+} from "../types";
 import { AptosConfig } from "./aptos_config";
 
 /**
@@ -125,6 +135,21 @@ export class General {
     return data[0];
   }
 
+  /**
+   * Queries top user transactions
+   *
+   * @param args.limit
+   * @returns GetChainTopUserTransactionsResponse
+   */
+  async getChainTopUserTransactions(args: { limit: number }): Promise<GetChainTopUserTransactionsResponse> {
+    const data = getChainTopUserTransactions({
+      aptosConfig: this.config,
+      ...args,
+    });
+
+    return data;
+  }
+
   /**
    * A generic function for retrieving data from Aptos Indexer.
    * For more detailed queries specification see

src/internal/general.ts

@@ -10,7 +10,18 @@
 
 import { AptosConfig } from "../api/aptos_config";
 import { getAptosFullNode, postAptosFullNode, postAptosIndexer } from "../client";
-import { Block, GraphqlQuery, LedgerInfo, LedgerVersion, MoveValue, TableItemRequest, ViewRequest } from "../types";
+import {
+  Block,
+  GetChainTopUserTransactionsResponse,
+  GraphqlQuery,
+  LedgerInfo,
+  LedgerVersion,
+  MoveValue,
+  TableItemRequest,
+  ViewRequest,
+} from "../types";
+import { GetChainTopUserTransactionsQuery } from "../types/generated/operations";
+import { GetChainTopUserTransactions } from "../types/generated/queries";
 
 export async function getLedgerInfo(args: { aptosConfig: AptosConfig }): Promise<LedgerInfo> {
   const { aptosConfig } = args;
@@ -85,6 +96,25 @@ export async function view(args: {
   return data;
 }
 
+export async function getChainTopUserTransactions(args: {
+  aptosConfig: AptosConfig;
+  limit: number;
+}): Promise<GetChainTopUserTransactionsResponse> {
+  const { aptosConfig, limit } = args;
+  const graphqlQuery = {
+    query: GetChainTopUserTransactions,
+    variables: { limit },
+  };
+
+  const data = await queryIndexer<GetChainTopUserTransactionsQuery>({
+    aptosConfig,
+    query: graphqlQuery,
+    originMethod: "getChainTopUserTransactions",
+  });
+
+  return data.user_transactions;
+}
+
 export async function queryIndexer<T>(args: {
   aptosConfig: AptosConfig;
   query: GraphqlQuery;

src/internal/queries/getChainTopUserTransactions.graphql

@@ -0,0 +1,5 @@
+query getChainTopUserTransactions($limit: Int) {
+  user_transactions(limit: $limit, order_by: { version: desc }) {
+    version
+  }
+}

src/types/generated/operations.ts

@@ -331,6 +331,12 @@ export type GetAccountTransactionsCountQuery = {
   account_transactions_aggregate: { aggregate?: { count: number } | null };
 };
 
+export type GetChainTopUserTransactionsQueryVariables = Types.Exact<{
+  limit?: Types.InputMaybe<Types.Scalars["Int"]>;
+}>;
+
+export type GetChainTopUserTransactionsQuery = { user_transactions: Array<{ version: any }> };
+
 export type GetCollectionDataQueryVariables = Types.Exact<{
   where_condition: Types.CurrentCollectionsV2BoolExp;
 }>;

src/types/generated/queries.ts

@@ -205,6 +205,13 @@ export const GetAccountTransactionsCount = `
   }
 }
     `;
+export const GetChainTopUserTransactions = `
+    query getChainTopUserTransactions($limit: Int) {
+  user_transactions(limit: $limit, order_by: {version: desc}) {
+    version
+  }
+}
+    `;
 export const GetCollectionData = `
     query getCollectionData($where_condition: current_collections_v2_bool_exp!) {
   current_collections_v2(where: $where_condition) {
@@ -386,6 +393,20 @@ export function getSdk(client: GraphQLClient, withWrapper: SdkFunctionWrapper =
         "query",
       );
     },
+    getChainTopUserTransactions(
+      variables?: Types.GetChainTopUserTransactionsQueryVariables,
+      requestHeaders?: Dom.RequestInit["headers"],
+    ): Promise<Types.GetChainTopUserTransactionsQuery> {
+      return withWrapper(
+        (wrappedRequestHeaders) =>
+          client.request<Types.GetChainTopUserTransactionsQuery>(GetChainTopUserTransactions, variables, {
+            ...requestHeaders,
+            ...wrappedRequestHeaders,
+          }),
+        "getChainTopUserTransactions",
+        "query",
+      );
+    },
     getCollectionData(
       variables: Types.GetCollectionDataQueryVariables,
       requestHeaders?: Dom.RequestInit["headers"],

src/types/indexer.ts

@@ -20,6 +20,7 @@ import {
   GetDelegatedStakingActivitiesQuery,
   GetNumberOfDelegatorsQuery,
   GetCollectionDataQuery,
+  GetChainTopUserTransactionsQuery,
 } from "./generated/operations";
 
 /**
@@ -41,6 +42,7 @@ export type GetAccountOwnedTokensFromCollectionResponse =
 export type GetAccountCollectionsWithOwnedTokenResponse =
   GetAccountCollectionsWithOwnedTokensQuery["current_collection_ownership_v2_view"];
 export type GetAccountCoinsDataResponse = GetAccountCoinsDataQuery["current_fungible_asset_balances"];
+export type GetChainTopUserTransactionsResponse = GetChainTopUserTransactionsQuery["user_transactions"];
 
 export type GetNumberOfDelegatorsResponse = GetNumberOfDelegatorsQuery["num_active_delegator_per_pool"];
 export type GetDelegatedStakingActivitiesResponse = GetDelegatedStakingActivitiesQuery["delegated_staking_activities"];

tests/e2e/api/general.test.ts

@@ -103,4 +103,12 @@ describe("general api", () => {
 
     expect(chainId.ledger_infos[0].chain_id).toBe(2);
   });
+
+  test("it should fetch chain top user transactions", async () => {
+    const config = new AptosConfig({ network: Network.TESTNET });
+    const aptos = new Aptos(config);
+
+    const topUserTransactions = await aptos.getChainTopUserTransactions({ limit: 3 });
+    expect(topUserTransactions.length).toEqual(3);
+  });
 });