Feat/denom holders and stats

packages/sdk-ts/package.json

@@ -44,7 +44,7 @@
  "@injectivelabs/grpc-web": "^0.0.1",
  "@injectivelabs/grpc-web-node-http-transport": "^0.0.2",
  "@injectivelabs/grpc-web-react-native-transport": "^0.0.2",
- "@injectivelabs/indexer-proto-ts": "1.11.49",
+ "@injectivelabs/indexer-proto-ts": "1.11.53",
  "@injectivelabs/mito-proto-ts": "1.0.65",
  "@injectivelabs/networks": "^1.14.14",
  "@injectivelabs/test-utils": "^1.14.14",

packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcArchiverApi.spec.ts

@@ -1,12 +1,13 @@
 import { getNetworkEndpoints, Network } from '@injectivelabs/networks'
+import { INJ_DENOM } from '@injectivelabs/utils'
 import { mockFactory } from '@injectivelabs/test-utils'
 import { IndexerGrpcArchiverTransformer } from '../transformers'
 import { IndexerGrpcArchiverApi } from './IndexerGrpcArchiverApi'
 
 const account = mockFactory.injectiveAddress
 const resolution = '1D'
-const startDate = 1622505600
-const endDate = 1625097600
+const startDate = '1622505600'
+const endDate = '1625097600'
 const limit = 10
 const endpoints = getNetworkEndpoints(Network.MainnetSentry)
 const indexerGrpcArchiverApi = new IndexerGrpcArchiverApi(endpoints.indexer)
@@ -173,4 +174,26 @@ describe('IndexerGrpcArchiverApi', () => {
  )
  }
  })
+
+ test('fetchDenomHolders', async () => {
+ try {
+ const response = await indexerGrpcArchiverApi.fetchDenomHolders({
+ denom: INJ_DENOM,
+ limit,
+ })
+
+ expect(response).toBeDefined()
+ expect(response).toEqual(
+ expect.objectContaining<
+ ReturnType<
+ typeof IndexerGrpcArchiverTransformer.grpcDenomHoldersResponseToDenomHolders
+ >
+ >(response),
+ )
+ } catch (e) {
+ console.error(
+ 'IndexerGrpcArchiverApi.fetchDenomHolders => ' + (e as any).message,
+ )
+ }
+ })
 })

packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcArchiverApi.ts

@@ -305,4 +305,51 @@ export class IndexerGrpcArchiverApi extends BaseGrpcConsumer {
  })
  }
  }
+
+ async fetchDenomHolders({
+ denom,
+ token,
+ limit,
+ }: {
+ denom: string
+ token?: string
+ limit?: number
+ }) {
+ const request = InjectiveArchiverRpc.DenomHoldersRequest.create()
+
+ request.denom = denom
+
+ if (token) {
+ request.token = token
+ }
+
+ if (limit) {
+ request.limit = limit
+ }
+
+ try {
+ const response =
+ await this.retry<InjectiveArchiverRpc.DenomHoldersResponse>(() =>
+ this.client.DenomHolders(request),
+ )
+
+ return IndexerGrpcArchiverTransformer.grpcDenomHoldersResponseToDenomHolders(
+ response,
+ )
+ } catch (e: unknown) {
+ if (e instanceof InjectiveArchiverRpc.GrpcWebError) {
+ throw new GrpcUnaryRequestException(new Error(e.toString()), {
+ code: e.code,
+ context: 'DenomHolders',
+ contextModule: this.module,
+ })
+ }
+
+ throw new GrpcUnaryRequestException(e as Error, {
+ code: UnspecifiedErrorCode,
+ context: 'DenomHolders',
+ contextModule: this.module,
+ })
+ }
+ }
 }

packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcExplorerApi.spec.ts

@@ -222,4 +222,23 @@ describe('IndexerGrpcExplorerApi', () => {
  )
  }
  })
+
+ test('fetchExplorerStats', async () => {
+ try {
+ const response = await indexerGrpcExplorerApi.fetchExplorerStats()
+
+ expect(response).toBeDefined()
+ expect(response).toEqual(
+ expect.objectContaining<
+ ReturnType<
+ typeof IndexerGrpcExplorerTransformer.getExplorerStatsResponseToExplorerStats
+ >
+ >(response),
+ )
+ } catch (e) {
+ console.error(
+ 'IndexerGrpcExplorerApi.fetchExplorerStats => ' + (e as any).message,
+ )
+ }
+ })
 })

packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcExplorerApi.ts

@@ -540,4 +540,32 @@ export class IndexerGrpcExplorerApi extends BaseGrpcConsumer {
  })
  }
  }
+
+ async fetchExplorerStats() {
+ const request = InjectiveExplorerRpc.GetStatsRequest.create()
+
+ try {
+ const response = await this.retry<InjectiveExplorerRpc.GetStatsResponse>(
+ () => this.client.GetStats(request),
+ )
+
+ return IndexerGrpcExplorerTransformer.getExplorerStatsResponseToExplorerStats(
+ response,
+ )
+ } catch (e: unknown) {
+ if (e instanceof InjectiveExplorerRpc.GrpcWebError) {
+ throw new GrpcUnaryRequestException(new Error(e.toString()), {
+ code: e.code,
+ context: 'GetExplorerStats',
+ contextModule: this.module,
+ })
+ }
+
+ throw new GrpcUnaryRequestException(e as Error, {
+ code: UnspecifiedErrorCode,
+ context: 'GetExplorerStats',
+ contextModule: this.module,
+ })
+ }
+ }
 }

packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcPortfolioApi.ts

@@ -104,51 +104,4 @@ export class IndexerGrpcAccountPortfolioApi extends BaseGrpcConsumer {
  })
  }
  }
-
- async fetchAccountPortfolioTokenHolders({
- denom,
- cursor,
- limit,
- }: {
- denom: string
- cursor?: string
- limit?: number
- }) {
- const request = InjectivePortfolioRpc.TokenHoldersRequest.create()
-
- request.denom = denom
-
- if (cursor) {
- request.cursor = cursor
- }
-
- if (limit) {
- request.limit = limit
- }
-
- try {
- const response =
- await this.retry<InjectivePortfolioRpc.TokenHoldersResponse>(() =>
- this.client.TokenHolders(request),
- )
-
- return IndexerGrpcAccountPortfolioTransformer.tokenHoldersResponseToTokenHolders(
- response,
- )
- } catch (e: unknown) {
- if (e instanceof InjectivePortfolioRpc.GrpcWebError) {
- throw new GrpcUnaryRequestException(new Error(e.toString()), {
- code: e.code,
- context: 'TokenHolders',
- contextModule: this.module,
- })
- }
-
- throw new GrpcUnaryRequestException(e as Error, {
- code: UnspecifiedErrorCode,
- context: 'TokenHolders',
- contextModule: this.module,
- })
- }
- }
 }

packages/sdk-ts/src/client/indexer/transformers/IndexerAccountPortfolioTransformer.ts

@@ -1,7 +1,6 @@
 import { Coin } from '@injectivelabs/ts-types'
 import { GrpcCoin } from '../../../types'
 import {
- TokenHolders,
  PositionsWithUPNL,
  AccountPortfolioV2,
  SubaccountDepositV2,
@@ -118,16 +117,4 @@ export class IndexerGrpcAccountPortfolioTransformer {
  : undefined,
  }
  }
-
- static tokenHoldersResponseToTokenHolders(
- response: InjectivePortfolioRpc.TokenHoldersResponse,
- ): TokenHolders {
- return {
- holders: response.holders.map((holder) => ({
- accountAddress: holder.accountAddress,
- balance: holder.balance,
- })),
- nextCursors: response.nextCursors,
- }
- }
 }

packages/sdk-ts/src/client/indexer/transformers/IndexerGrpcArchiverTransformer.ts

@@ -1,10 +1,11 @@
 import {
+ DenomHolders,
  HistoricalRPNL,
- HistoricalBalance,
- HistoricalVolumes,
  LeaderboardRow,
  PnlLeaderboard,
  VolLeaderboard,
+ HistoricalBalance,
+ HistoricalVolumes,
 } from '../types/archiver'
 import { InjectiveArchiverRpc } from '@injectivelabs/indexer-proto-ts'
 
@@ -133,4 +134,16 @@ export class IndexerGrpcArchiverTransformer {
  ),
  }
  }
+
+ static grpcDenomHoldersResponseToDenomHolders(
+ response: InjectiveArchiverRpc.DenomHoldersResponse,
+ ): DenomHolders {
+ return {
+ holders: response.holders.map((holder) => ({
+ accountAddress: holder.accountAddress,
+ balance: holder.balance,
+ })),
+ next: response.next,
+ }
+ }
 }

packages/sdk-ts/src/client/indexer/transformers/IndexerGrpcExplorerTransformer.ts

@@ -1,25 +1,26 @@
 import {
- BankMsgSendTransaction,
  Block,
- BlockWithTxs,
  GasFee,
- GrpcBankMsgSendMessage,
  GrpcGasFee,
- GrpcIndexerValidatorDescription,
- GrpcValidatorSlashingEvent,
- GrpcValidatorUptime,
  Transaction,
- ExplorerValidator,
- ExplorerValidatorDescription,
- ValidatorSlashingEvent,
- ValidatorUptime,
+ BlockWithTxs,
  IBCTransferTx,
+ ExplorerStats,
  PeggyDepositTx,
+ ValidatorUptime,
+ ExplorerValidator,
  PeggyWithdrawalTx,
  GrpcIBCTransferTx,
  GrpcPeggyDepositTx,
+ GrpcValidatorUptime,
  GrpcPeggyWithdrawalTx,
+ BankMsgSendTransaction,
+ GrpcBankMsgSendMessage,
+ ValidatorSlashingEvent,
  IndexerStreamTransaction,
+ GrpcValidatorSlashingEvent,
+ ExplorerValidatorDescription,
+ GrpcIndexerValidatorDescription,
 } from '../types/explorer'
 import { grpcPagingToPaging } from '../../../utils'
 import { InjectiveExplorerRpc } from '@injectivelabs/indexer-proto-ts'
@@ -395,4 +396,20 @@ export class IndexerGrpcExplorerTransformer {
  updatedAt: grpcPeggyWithdrawalTx.updatedAt,
  }
  }
+
+ static getExplorerStatsResponseToExplorerStats(
+ response: InjectiveExplorerRpc.GetStatsResponse,
+ ): ExplorerStats {
+ return {
+ assets: response.assets,
+ txsTotal: response.txsTotal,
+ addresses: response.addresses,
+ injSupply: response.injSupply,
+ txsInPast24Hours: response.txs24H,
+ txsInPast30Days: response.txs30D,
+ blockCountInPast24Hours: response.blockCount24H,
+ txsPerSecondInPast24Hours: response.txsPs24H,
+ txsPerSecondInPast100Blocks: response.txsPs100B,
+ }
+ }
 }

packages/sdk-ts/src/client/indexer/types/account-portfolio.ts

@@ -31,20 +31,9 @@ export interface AccountPortfolioBalances {
  subaccountsList: PortfolioSubaccountBalanceV2[]
 }
 
-export interface Holder {
- accountAddress: string
- balance: string
-}
-
-export interface TokenHolders {
- holders: Holder[]
- nextCursors: string[]
-}
-
 export type GrpcPositionV2 = InjectivePortfolioRpc.DerivativePosition
 export type GrpcAccountPortfolioV2 = InjectivePortfolioRpc.Portfolio
 export type GrpcSubaccountDepositV2 = InjectivePortfolioRpc.SubaccountDeposit
 export type GrpcPositionsWithUPNL = InjectivePortfolioRpc.PositionsWithUPNL
 export type GrpcPortfolioSubaccountBalanceV2 =
  InjectivePortfolioRpc.SubaccountBalanceV2
-export type GrpcTokenHolders = InjectivePortfolioRpc.TokenHoldersResponse

packages/sdk-ts/src/client/indexer/types/archiver.ts

@@ -34,6 +34,16 @@ export interface VolLeaderboard {
  leaders: LeaderboardRow[]
 }
 
+export interface Holder {
+ accountAddress: string
+ balance: string
+}
+
+export interface DenomHolders {
+ holders: Holder[]
+ next: string[]
+}
+
 export type GrpcHistoricalRPNL = InjectiveArchiverRpc.HistoricalRPNL
 export type GrpcHistoricalBalance = InjectiveArchiverRpc.HistoricalBalance
 export type GrpcHistoricalVolumes = InjectiveArchiverRpc.HistoricalVolumes
@@ -44,3 +54,4 @@ export type GrpcVolLeaderboard =
  | InjectiveArchiverRpc.VolLeaderboardResponse
  | InjectiveArchiverRpc.VolLeaderboardFixedResolutionResponse
 export type GrpcLeaderboardRow = InjectiveArchiverRpc.LeaderboardRow
+export type GrpcDenomHolders = InjectiveArchiverRpc.DenomHoldersResponse

packages/sdk-ts/src/client/indexer/types/explorer.ts

@@ -379,6 +379,18 @@ export interface CosmWasmChecksum {
  hash: string
 }
 
+export interface ExplorerStats {
+ assets: string
+ txsTotal: string
+ addresses: string
+ injSupply: string
+ txsInPast30Days: string
+ txsInPast24Hours: string
+ blockCountInPast24Hours: string
+ txsPerSecondInPast24Hours: string
+ txsPerSecondInPast100Blocks: string
+}
+
 export type GrpcIBCTransferTx = InjectiveExplorerRpc.IBCTransferTx
 export type GrpcPeggyDepositTx = InjectiveExplorerRpc.PeggyDepositTx
 export type GrpcPeggyWithdrawalTx = InjectiveExplorerRpc.PeggyWithdrawalTx
@@ -387,3 +399,4 @@ export type GrpcValidatorUptime = InjectiveExplorerRpc.ValidatorUptime
 export type GrpcIndexerValidatorDescription =
  InjectiveExplorerRpc.ValidatorDescription
 export type GrpcValidatorSlashingEvent = InjectiveExplorerRpc.SlashingEvent
+export type GrpcExplorerStats = InjectiveExplorerRpc.GetStatsResponse