diff --git a/packages/services/indexer/src/indexer.gen.ts b/packages/services/indexer/src/indexer.gen.ts index 8dba62d16..7c8627207 100644 --- a/packages/services/indexer/src/indexer.gen.ts +++ b/packages/services/indexer/src/indexer.gen.ts @@ -1,5 +1,5 @@ /* eslint-disable */ -// sequence-indexer v0.4.0 2bca559c4c590bce7d70c33df115a58399efec82 +// sequence-indexer v0.4.0 0c0483fc5c990f1bc8022d176228c27f40d3d055 // -- // Code generated by Webrpc-gen@v0.31.2 with typescript generator. DO NOT EDIT. // @@ -12,18 +12,14 @@ export const WebrpcVersion = 'v1' export const WebrpcSchemaVersion = 'v0.4.0' // Schema hash generated from your RIDL schema -export const WebrpcSchemaHash = '2bca559c4c590bce7d70c33df115a58399efec82' +export const WebrpcSchemaHash = '0c0483fc5c990f1bc8022d176228c27f40d3d055' // // Client interface // export interface IndexerClient { - addWebhookListener( - req: AddWebhookListenerRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + addWebhookListener(req: AddWebhookListenerRequest, headers?: object, signal?: AbortSignal): Promise /** * Fetches a single receipt and then will stop the subscription @@ -31,7 +27,7 @@ export interface IndexerClient { fetchTransactionReceipt( req: FetchTransactionReceiptRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -40,7 +36,7 @@ export interface IndexerClient { fetchTransactionReceiptWithFilter( req: FetchTransactionReceiptWithFilterRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -49,18 +45,14 @@ export interface IndexerClient { getAllWebhookListeners( req: GetAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** * Get balance update aggregate values -- useful for syncing balance details of a contract, ie. from Skyweaver. * Also consider using SubscribeBalanceUpdates or SubscribeEvents as other alternatives. */ - getBalanceUpdates( - req: GetBalanceUpdatesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getBalanceUpdates(req: GetBalanceUpdatesRequest, headers?: object, signal?: AbortSignal): Promise /** * Get the chain ID of the indexer @@ -102,7 +94,7 @@ export interface IndexerClient { getMarketplaceOrders( req: GetMarketplaceOrdersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -126,7 +118,7 @@ export interface IndexerClient { getMarketplaceTopOrders( req: GetMarketplaceTopOrdersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -137,7 +129,7 @@ export interface IndexerClient { getNativeTokenBalance( req: GetNativeTokenBalanceRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -152,11 +144,7 @@ export interface IndexerClient { * * @deprecated GetTokenBalancesSummary */ - getTokenBalances( - req: GetTokenBalancesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getTokenBalances(req: GetTokenBalancesRequest, headers?: object, signal?: AbortSignal): Promise /** * GetTokenBalancesByContract returns a balances for a specific accounts and @@ -172,7 +160,7 @@ export interface IndexerClient { getTokenBalancesByContract( req: GetTokenBalancesByContractRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -189,7 +177,7 @@ export interface IndexerClient { getTokenBalancesDetails( req: GetTokenBalancesDetailsRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -206,7 +194,7 @@ export interface IndexerClient { getTokenBalancesSummary( req: GetTokenBalancesSummaryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -224,11 +212,7 @@ export interface IndexerClient { * will return just a single range from [1,100_000], but if there are gaps between the sequence, then * those will be broken into separate range entries. */ - getTokenIDRanges( - req: GetTokenIDRangesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getTokenIDRanges(req: GetTokenIDRangesRequest, headers?: object, signal?: AbortSignal): Promise /** * GetTokenIDs returns the list of each individual token id for a token collection contract. @@ -244,11 +228,7 @@ export interface IndexerClient { * GetTokenSupplies returns the set of tokenIDs used by a contract address, supporting ERC-20, ERC-721, and ERC-1155 * contracts, and their respective supply as well. */ - getTokenSupplies( - req: GetTokenSuppliesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getTokenSupplies(req: GetTokenSuppliesRequest, headers?: object, signal?: AbortSignal): Promise /** * GetTokenSuppliesMap returns the token supplies of ERC-20 and ERC-1155 tokens as requested in the `tokenMap` @@ -260,7 +240,7 @@ export interface IndexerClient { getTokenSuppliesMap( req: GetTokenSuppliesMapRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -270,21 +250,17 @@ export interface IndexerClient { getTransactionHistory( req: GetTransactionHistoryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise - getWebhookListener( - req: GetWebhookListenerRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getWebhookListener(req: GetWebhookListenerRequest, headers?: object, signal?: AbortSignal): Promise listTokenPrices(req: ListTokenPricesRequest, headers?: object, signal?: AbortSignal): Promise pauseAllWebhookListeners( req: PauseAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -295,19 +271,19 @@ export interface IndexerClient { removeAllWebhookListeners( req: RemoveAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise removeWebhookListener( req: RemoveWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise resumeAllWebhookListeners( req: ResumeAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -320,7 +296,7 @@ export interface IndexerClient { */ subscribeBalanceUpdates( req: SubscribeBalanceUpdatesRequest, - options: WebrpcStreamOptions, + options: WebrpcStreamOptions ): WebrpcStreamController /** @@ -329,17 +305,14 @@ export interface IndexerClient { * TODO: some additional options can be passed such as block, reorg true, etc. * or stay behind, etc. */ - subscribeEvents( - req: SubscribeEventsRequest, - options: WebrpcStreamOptions, - ): WebrpcStreamController + subscribeEvents(req: SubscribeEventsRequest, options: WebrpcStreamOptions): WebrpcStreamController /** * Listen to transaction receipts on-chain based on the filter criteria */ subscribeReceipts( req: SubscribeReceiptsRequest, - options: WebrpcStreamOptions, + options: WebrpcStreamOptions ): WebrpcStreamController /** @@ -353,13 +326,13 @@ export interface IndexerClient { toggleWebhookListener( req: ToggleWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise updateWebhookListener( req: UpdateWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -388,7 +361,26 @@ export interface Asset { export enum BackupMode { INCREMENTAL = 'INCREMENTAL', - COMPLETE = 'COMPLETE', + COMPLETE = 'COMPLETE' +} + +export interface BackupProgress { + id: string + status: BackupStatus + mode: BackupMode + startedAt: string + completedAt?: string + filesDone: number + filesTotal: number + bytesDone: number + bytesTotal: number + error?: string +} + +export enum BackupStatus { + RUNNING = 'RUNNING', + COMPLETED = 'COMPLETED', + FAILED = 'FAILED' } export interface BloomStats { @@ -470,13 +462,13 @@ export enum ContractType { ERC721_BRIDGE = 'ERC721_BRIDGE', ERC1155_BRIDGE = 'ERC1155_BRIDGE', SEQ_MARKETPLACE = 'SEQ_MARKETPLACE', - ERC6909 = 'ERC6909', + ERC6909 = 'ERC6909' } export enum ContractVerificationStatus { VERIFIED = 'VERIFIED', UNVERIFIED = 'UNVERIFIED', - ALL = 'ALL', + ALL = 'ALL' } export interface DiskUsage { @@ -530,13 +522,13 @@ export enum EventLogDataType { EVENT = 'EVENT', TOKEN_TRANSFER = 'TOKEN_TRANSFER', NATIVE_TOKEN_TRANSFER = 'NATIVE_TOKEN_TRANSFER', - SEQUENCE_TXN = 'SEQUENCE_TXN', + SEQUENCE_TXN = 'SEQUENCE_TXN' } export enum EventLogType { UNKNOWN = 'UNKNOWN', BLOCK_ADDED = 'BLOCK_ADDED', - BLOCK_REMOVED = 'BLOCK_REMOVED', + BLOCK_REMOVED = 'BLOCK_REMOVED' } export interface GatewayBackendResponseTime { @@ -676,13 +668,13 @@ export interface NativeTokenBalance { export enum NetworkType { MAINNETS = 'MAINNETS', TESTNETS = 'TESTNETS', - ALL = 'ALL', + ALL = 'ALL' } export enum OrderStatus { OPEN = 'OPEN', CLOSED = 'CLOSED', - CANCELLED = 'CANCELLED', + CANCELLED = 'CANCELLED' } export interface Page { @@ -713,7 +705,7 @@ export interface Price { export enum ResourceStatus { NOT_AVAILABLE = 'NOT_AVAILABLE', REFRESHING = 'REFRESHING', - AVAILABLE = 'AVAILABLE', + AVAILABLE = 'AVAILABLE' } export interface RuntimeChecks { @@ -750,7 +742,7 @@ export interface SortBy { export enum SortOrder { DESC = 'DESC', - ASC = 'ASC', + ASC = 'ASC' } export interface TokenBalance { @@ -907,13 +899,13 @@ export interface TransactionReceipt { export enum TransactionStatus { FAILED = 'FAILED', - SUCCESSFUL = 'SUCCESSFUL', + SUCCESSFUL = 'SUCCESSFUL' } export enum TransactionType { LegacyTxnType = 'LegacyTxnType', AccessListTxnType = 'AccessListTxnType', - DynamicFeeTxnType = 'DynamicFeeTxnType', + DynamicFeeTxnType = 'DynamicFeeTxnType' } export interface TxnInfo { @@ -940,7 +932,7 @@ export interface TxnTransfer { export enum TxnTransferType { UNKNOWN = 'UNKNOWN', SEND = 'SEND', - RECEIVE = 'RECEIVE', + RECEIVE = 'RECEIVE' } export interface Version { @@ -969,6 +961,8 @@ export interface WebhookListener { name: string updatedAt: string active: boolean + disabledAt?: string + disabledReason?: string } export interface AddWebhookListenerRequest { @@ -1325,8 +1319,7 @@ export class Indexer implements IndexerClient { queryKey = { addWebhookListener: (req: AddWebhookListenerRequest) => ['Indexer', 'addWebhookListener', req] as const, - fetchTransactionReceipt: (req: FetchTransactionReceiptRequest) => - ['Indexer', 'fetchTransactionReceipt', req] as const, + fetchTransactionReceipt: (req: FetchTransactionReceiptRequest) => ['Indexer', 'fetchTransactionReceipt', req] as const, fetchTransactionReceiptWithFilter: (req: FetchTransactionReceiptWithFilterRequest) => ['Indexer', 'fetchTransactionReceiptWithFilter', req] as const, getAllWebhookListeners: (req: GetAllWebhookListenersRequest) => ['Indexer', 'getAllWebhookListeners', req] as const, @@ -1334,16 +1327,13 @@ export class Indexer implements IndexerClient { getChainID: () => ['Indexer', 'getChainID'] as const, getEtherBalance: (req: GetEtherBalanceRequest) => ['Indexer', 'getEtherBalance', req] as const, getMarketplaceOrders: (req: GetMarketplaceOrdersRequest) => ['Indexer', 'getMarketplaceOrders', req] as const, - getMarketplaceTopOrders: (req: GetMarketplaceTopOrdersRequest) => - ['Indexer', 'getMarketplaceTopOrders', req] as const, + getMarketplaceTopOrders: (req: GetMarketplaceTopOrdersRequest) => ['Indexer', 'getMarketplaceTopOrders', req] as const, getNativeTokenBalance: (req: GetNativeTokenBalanceRequest) => ['Indexer', 'getNativeTokenBalance', req] as const, getTokenBalances: (req: GetTokenBalancesRequest) => ['Indexer', 'getTokenBalances', req] as const, getTokenBalancesByContract: (req: GetTokenBalancesByContractRequest) => ['Indexer', 'getTokenBalancesByContract', req] as const, - getTokenBalancesDetails: (req: GetTokenBalancesDetailsRequest) => - ['Indexer', 'getTokenBalancesDetails', req] as const, - getTokenBalancesSummary: (req: GetTokenBalancesSummaryRequest) => - ['Indexer', 'getTokenBalancesSummary', req] as const, + getTokenBalancesDetails: (req: GetTokenBalancesDetailsRequest) => ['Indexer', 'getTokenBalancesDetails', req] as const, + getTokenBalancesSummary: (req: GetTokenBalancesSummaryRequest) => ['Indexer', 'getTokenBalancesSummary', req] as const, getTokenIDRanges: (req: GetTokenIDRangesRequest) => ['Indexer', 'getTokenIDRanges', req] as const, getTokenIDs: (req: GetTokenIDsRequest) => ['Indexer', 'getTokenIDs', req] as const, getTokenPrice: (req: GetTokenPriceRequest) => ['Indexer', 'getTokenPrice', req] as const, @@ -1353,721 +1343,626 @@ export class Indexer implements IndexerClient { getTransactionHistory: (req: GetTransactionHistoryRequest) => ['Indexer', 'getTransactionHistory', req] as const, getWebhookListener: (req: GetWebhookListenerRequest) => ['Indexer', 'getWebhookListener', req] as const, listTokenPrices: (req: ListTokenPricesRequest) => ['Indexer', 'listTokenPrices', req] as const, - pauseAllWebhookListeners: (req: PauseAllWebhookListenersRequest) => - ['Indexer', 'pauseAllWebhookListeners', req] as const, + pauseAllWebhookListeners: (req: PauseAllWebhookListenersRequest) => ['Indexer', 'pauseAllWebhookListeners', req] as const, ping: () => ['Indexer', 'ping'] as const, - removeAllWebhookListeners: (req: RemoveAllWebhookListenersRequest) => - ['Indexer', 'removeAllWebhookListeners', req] as const, + removeAllWebhookListeners: (req: RemoveAllWebhookListenersRequest) => ['Indexer', 'removeAllWebhookListeners', req] as const, removeWebhookListener: (req: RemoveWebhookListenerRequest) => ['Indexer', 'removeWebhookListener', req] as const, - resumeAllWebhookListeners: (req: ResumeAllWebhookListenersRequest) => - ['Indexer', 'resumeAllWebhookListeners', req] as const, + resumeAllWebhookListeners: (req: ResumeAllWebhookListenersRequest) => ['Indexer', 'resumeAllWebhookListeners', req] as const, runtimeStatus: () => ['Indexer', 'runtimeStatus'] as const, - subscribeBalanceUpdates: (req: SubscribeBalanceUpdatesRequest) => - ['Indexer', 'subscribeBalanceUpdates', req] as const, + subscribeBalanceUpdates: (req: SubscribeBalanceUpdatesRequest) => ['Indexer', 'subscribeBalanceUpdates', req] as const, subscribeEvents: (req: SubscribeEventsRequest) => ['Indexer', 'subscribeEvents', req] as const, subscribeReceipts: (req: SubscribeReceiptsRequest) => ['Indexer', 'subscribeReceipts', req] as const, syncBalance: (req: SyncBalanceRequest) => ['Indexer', 'syncBalance', req] as const, toggleWebhookListener: (req: ToggleWebhookListenerRequest) => ['Indexer', 'toggleWebhookListener', req] as const, updateWebhookListener: (req: UpdateWebhookListenerRequest) => ['Indexer', 'updateWebhookListener', req] as const, - version: () => ['Indexer', 'version'] as const, + version: () => ['Indexer', 'version'] as const } addWebhookListener = ( req: AddWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('AddWebhookListener'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'AddWebhookListenerResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } fetchTransactionReceipt = ( req: FetchTransactionReceiptRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('FetchTransactionReceipt'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'FetchTransactionReceiptResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } fetchTransactionReceiptWithFilter = ( req: FetchTransactionReceiptWithFilterRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { - return this.fetch( - this.url('FetchTransactionReceiptWithFilter'), - createHttpRequest(JsonEncode(req), headers, signal), - ).then( - (res) => { - return buildResponse(res).then((_data) => { - return JsonDecode( - _data, - 'FetchTransactionReceiptWithFilterResponse', - ) - }) - }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, + return this.fetch(this.url('FetchTransactionReceiptWithFilter'), createHttpRequest(JsonEncode(req), headers, signal)).then( + res => { + return buildResponse(res).then(_data => { + return JsonDecode(_data, 'FetchTransactionReceiptWithFilterResponse') }) }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getAllWebhookListeners = ( req: GetAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetAllWebhookListeners'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetAllWebhookListenersResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getBalanceUpdates = ( req: GetBalanceUpdatesRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetBalanceUpdates'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetBalanceUpdatesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getChainID = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetChainID'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetChainIDResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } - getEtherBalance = ( - req: GetEtherBalanceRequest, - headers?: object, - signal?: AbortSignal, - ): Promise => { + getEtherBalance = (req: GetEtherBalanceRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetEtherBalance'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetEtherBalanceResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getMarketplaceOrders = ( req: GetMarketplaceOrdersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetMarketplaceOrders'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetMarketplaceOrdersResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getMarketplaceTopOrders = ( req: GetMarketplaceTopOrdersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetMarketplaceTopOrders'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetMarketplaceTopOrdersResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getNativeTokenBalance = ( req: GetNativeTokenBalanceRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetNativeTokenBalance'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetNativeTokenBalanceResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalances = ( req: GetTokenBalancesRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalances'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalancesByContract = ( req: GetTokenBalancesByContractRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalancesByContract'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesByContractResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalancesDetails = ( req: GetTokenBalancesDetailsRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalancesDetails'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesDetailsResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalancesSummary = ( req: GetTokenBalancesSummaryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalancesSummary'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesSummaryResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenIDRanges = ( req: GetTokenIDRangesRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenIDRanges'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenIDRangesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenIDs = (req: GetTokenIDsRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetTokenIDs'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenIDsResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } - getTokenPrice = ( - req: GetTokenPriceRequest, - headers?: object, - signal?: AbortSignal, - ): Promise => { + getTokenPrice = (req: GetTokenPriceRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetTokenPrice'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenPriceResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } - getTokenPrices = ( - req: GetTokenPricesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise => { + getTokenPrices = (req: GetTokenPricesRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetTokenPrices'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenPricesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenSupplies = ( req: GetTokenSuppliesRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenSupplies'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenSuppliesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenSuppliesMap = ( req: GetTokenSuppliesMapRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenSuppliesMap'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenSuppliesMapResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTransactionHistory = ( req: GetTransactionHistoryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTransactionHistory'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTransactionHistoryResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getWebhookListener = ( req: GetWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetWebhookListener'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetWebhookListenerResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } - listTokenPrices = ( - req: ListTokenPricesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise => { + listTokenPrices = (req: ListTokenPricesRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('ListTokenPrices'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'ListTokenPricesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } pauseAllWebhookListeners = ( req: PauseAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('PauseAllWebhookListeners'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'PauseAllWebhookListenersResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } ping = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('Ping'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'PingResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } removeAllWebhookListeners = ( req: RemoveAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('RemoveAllWebhookListeners'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'RemoveAllWebhookListenersResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } removeWebhookListener = ( req: RemoveWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('RemoveWebhookListener'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'RemoveWebhookListenerResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } resumeAllWebhookListeners = ( req: ResumeAllWebhookListenersRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('ResumeAllWebhookListeners'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'ResumeAllWebhookListenersResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } runtimeStatus = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('RuntimeStatus'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'RuntimeStatusResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } subscribeBalanceUpdates = ( req: SubscribeBalanceUpdatesRequest, - options: WebrpcStreamOptions, + options: WebrpcStreamOptions ): WebrpcStreamController => { const abortController = new AbortController() const abortSignal = abortController.signal if (options.signal) { abortSignal.addEventListener('abort', () => abortController.abort(options.signal?.reason), { - signal: options.signal, + signal: options.signal }) } const _fetch = () => - this.fetch( - this.url('SubscribeBalanceUpdates'), - createHttpRequest(JsonEncode(req), options.headers, abortSignal), - ).then( - async (res) => { + this.fetch(this.url('SubscribeBalanceUpdates'), createHttpRequest(JsonEncode(req), options.headers, abortSignal)).then( + async res => { await sseResponse(res, options, _fetch) }, - (error) => { + error => { options.onError(error, _fetch) - }, + } ) const resp = _fetch() return { abort: abortController.abort.bind(abortController), - closed: resp, + closed: resp } } subscribeEvents = ( req: SubscribeEventsRequest, - options: WebrpcStreamOptions, + options: WebrpcStreamOptions ): WebrpcStreamController => { const abortController = new AbortController() const abortSignal = abortController.signal if (options.signal) { abortSignal.addEventListener('abort', () => abortController.abort(options.signal?.reason), { - signal: options.signal, + signal: options.signal }) } const _fetch = () => this.fetch(this.url('SubscribeEvents'), createHttpRequest(JsonEncode(req), options.headers, abortSignal)).then( - async (res) => { + async res => { await sseResponse(res, options, _fetch) }, - (error) => { + error => { options.onError(error, _fetch) - }, + } ) const resp = _fetch() return { abort: abortController.abort.bind(abortController), - closed: resp, + closed: resp } } subscribeReceipts = ( req: SubscribeReceiptsRequest, - options: WebrpcStreamOptions, + options: WebrpcStreamOptions ): WebrpcStreamController => { const abortController = new AbortController() const abortSignal = abortController.signal if (options.signal) { abortSignal.addEventListener('abort', () => abortController.abort(options.signal?.reason), { - signal: options.signal, + signal: options.signal }) } const _fetch = () => this.fetch(this.url('SubscribeReceipts'), createHttpRequest(JsonEncode(req), options.headers, abortSignal)).then( - async (res) => { + async res => { await sseResponse(res, options, _fetch) }, - (error) => { + error => { options.onError(error, _fetch) - }, + } ) const resp = _fetch() return { abort: abortController.abort.bind(abortController), - closed: resp, + closed: resp } } syncBalance = (req: SyncBalanceRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('SyncBalance'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'SyncBalanceResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } toggleWebhookListener = ( req: ToggleWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('ToggleWebhookListener'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'ToggleWebhookListenerResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } updateWebhookListener = ( req: UpdateWebhookListenerRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('UpdateWebhookListener'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'UpdateWebhookListenerResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } version = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('Version'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'VersionResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } } @@ -2089,9 +1984,9 @@ const sseResponse = async (res: Response, options: WebrpcStreamOptions, ret onError( WebrpcBadResponseError.new({ status: res.status, - cause: 'Invalid response, missing body', + cause: 'Invalid response, missing body' }), - retryFetch, + retryFetch ) return } @@ -2125,18 +2020,18 @@ const sseResponse = async (res: Response, options: WebrpcStreamOptions, ret onError( WebrpcClientAbortedError.new({ message: 'AbortError', - cause: `AbortError: ${error instanceof Error ? error.message : String(error)}`, + cause: `AbortError: ${error instanceof Error ? error.message : String(error)}` }), () => { throw new Error('Abort signal cannot be used to reconnect') - }, + } ) } else { onError( WebrpcStreamLostError.new({ - cause: `reader.read(): ${error instanceof Error ? error.message : String(error)}`, + cause: `reader.read(): ${error instanceof Error ? error.message : String(error)}` }), - retryFetch, + retryFetch ) } return @@ -2164,9 +2059,9 @@ const sseResponse = async (res: Response, options: WebrpcStreamOptions, ret onError( WebrpcBadResponseError.new({ status: res.status, - cause: `JSON.parse(): ${error instanceof Error ? error.message : String(error)}`, + cause: `JSON.parse(): ${error instanceof Error ? error.message : String(error)}` }), - retryFetch, + retryFetch ) } onMessage(data) @@ -2187,20 +2082,20 @@ const createHttpRequest = (body: string = '{}', headers: object = {}, signal: Ab const reqHeaders: { [key: string]: string } = { ...headers, 'Content-Type': 'application/json', - [WebrpcHeader]: WebrpcHeaderValue, + [WebrpcHeader]: WebrpcHeaderValue } return { method: 'POST', headers: reqHeaders, body, signal } } const buildResponse = (res: Response): Promise => { - return res.text().then((text) => { + return res.text().then(text => { let data try { data = JSON.parse(text) } catch (error) { throw WebrpcBadResponseError.new({ status: res.status, - cause: `JSON.parse(): ${error instanceof Error ? error.message : String(error)}: response text: ${text}`, + cause: `JSON.parse(): ${error instanceof Error ? error.message : String(error)}: response text: ${text}` }) } if (!res.ok) { @@ -2756,7 +2651,7 @@ export enum errors { Timeout = 'Timeout', Unauthorized = 'Unauthorized', UnauthorizedUser = 'UnauthorizedUser', - Unavailable = 'Unavailable', + Unavailable = 'Unavailable' } export enum WebrpcErrorCodes { @@ -2796,7 +2691,7 @@ export enum WebrpcErrorCodes { Timeout = 1900, Unauthorized = 1000, UnauthorizedUser = 1105, - Unavailable = 2002, + Unavailable = 2002 } export const webrpcErrorByCode: { [code: number]: any } = { @@ -2836,7 +2731,7 @@ export const webrpcErrorByCode: { [code: number]: any } = { [1900]: TimeoutError, [1000]: UnauthorizedError, [1105]: UnauthorizedUserError, - [2002]: UnavailableError, + [2002]: UnavailableError } // @@ -2863,7 +2758,7 @@ export function VersionFromHeader(headers: Headers): WebrpcGenVersions { codeGenName: '', codeGenVersion: '', schemaName: '', - schemaVersion: '', + schemaVersion: '' } } @@ -2878,7 +2773,7 @@ function parseWebrpcGenVersions(header: string): WebrpcGenVersions { codeGenName: '', codeGenVersion: '', schemaName: '', - schemaVersion: '', + schemaVersion: '' } } @@ -2891,6 +2786,6 @@ function parseWebrpcGenVersions(header: string): WebrpcGenVersions { codeGenName: codeGenName ?? '', codeGenVersion: codeGenVersion ?? '', schemaName: schemaName ?? '', - schemaVersion: schemaVersion ?? '', + schemaVersion: schemaVersion ?? '' } } diff --git a/packages/services/indexer/src/indexergw.gen.ts b/packages/services/indexer/src/indexergw.gen.ts index d22bc5b56..8b5cbcdee 100644 --- a/packages/services/indexer/src/indexergw.gen.ts +++ b/packages/services/indexer/src/indexergw.gen.ts @@ -1,5 +1,5 @@ /* eslint-disable */ -// sequence-indexer v0.4.0 212120aad9a46e88ead9a2183c5717e9902d8c2b +// sequence-indexer v0.4.0 16adfeb4287edca1bd1f5d85a3512431796807d5 // -- // Code generated by Webrpc-gen@v0.31.2 with typescript generator. DO NOT EDIT. // @@ -12,7 +12,7 @@ export const WebrpcVersion = 'v1' export const WebrpcSchemaVersion = 'v0.4.0' // Schema hash generated from your RIDL schema -export const WebrpcSchemaHash = '212120aad9a46e88ead9a2183c5717e9902d8c2b' +export const WebrpcSchemaHash = '16adfeb4287edca1bd1f5d85a3512431796807d5' // // Client interface @@ -24,11 +24,7 @@ export interface IndexerGatewayClient { * on all indexer nodes. By default if accountAddress is left empty, it will * use the account from the jwt session. */ - getBalanceUpdates( - req: GetBalanceUpdatesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getBalanceUpdates(req: GetBalanceUpdatesRequest, headers?: object, signal?: AbortSignal): Promise /** * GetChains returns a list of chains with their ID and name @@ -42,7 +38,7 @@ export interface IndexerGatewayClient { getNativeTokenBalance( req: GetNativeTokenBalanceRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -52,11 +48,7 @@ export interface IndexerGatewayClient { * * @deprecated Use GetTokenBalancesSummary or GetTokenBalancesDetails instead. */ - getTokenBalances( - req: GetTokenBalancesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise + getTokenBalances(req: GetTokenBalancesRequest, headers?: object, signal?: AbortSignal): Promise /** * GetTokenBalancesByContract returns a balances for specific accounts and @@ -66,7 +58,7 @@ export interface IndexerGatewayClient { getTokenBalancesByContract( req: GetTokenBalancesByContractRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -77,7 +69,7 @@ export interface IndexerGatewayClient { getTokenBalancesDetails( req: GetTokenBalancesDetailsRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -88,7 +80,7 @@ export interface IndexerGatewayClient { getTokenBalancesSummary( req: GetTokenBalancesSummaryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise getTokenPrice(req: GetTokenPriceRequest, headers?: object, signal?: AbortSignal): Promise @@ -103,7 +95,7 @@ export interface IndexerGatewayClient { getTransactionHistory( req: GetTransactionHistoryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise /** @@ -142,7 +134,26 @@ export interface Asset { export enum BackupMode { INCREMENTAL = 'INCREMENTAL', - COMPLETE = 'COMPLETE', + COMPLETE = 'COMPLETE' +} + +export interface BackupProgress { + id: string + status: BackupStatus + mode: BackupMode + startedAt: string + completedAt?: string + filesDone: number + filesTotal: number + bytesDone: number + bytesTotal: number + error?: string +} + +export enum BackupStatus { + RUNNING = 'RUNNING', + COMPLETED = 'COMPLETED', + FAILED = 'FAILED' } export interface BloomStats { @@ -224,13 +235,13 @@ export enum ContractType { ERC721_BRIDGE = 'ERC721_BRIDGE', ERC1155_BRIDGE = 'ERC1155_BRIDGE', SEQ_MARKETPLACE = 'SEQ_MARKETPLACE', - ERC6909 = 'ERC6909', + ERC6909 = 'ERC6909' } export enum ContractVerificationStatus { VERIFIED = 'VERIFIED', UNVERIFIED = 'UNVERIFIED', - ALL = 'ALL', + ALL = 'ALL' } export interface DiskUsage { @@ -284,13 +295,13 @@ export enum EventLogDataType { EVENT = 'EVENT', TOKEN_TRANSFER = 'TOKEN_TRANSFER', NATIVE_TOKEN_TRANSFER = 'NATIVE_TOKEN_TRANSFER', - SEQUENCE_TXN = 'SEQUENCE_TXN', + SEQUENCE_TXN = 'SEQUENCE_TXN' } export enum EventLogType { UNKNOWN = 'UNKNOWN', BLOCK_ADDED = 'BLOCK_ADDED', - BLOCK_REMOVED = 'BLOCK_REMOVED', + BLOCK_REMOVED = 'BLOCK_REMOVED' } export interface GatewayBackendResponseTime { @@ -430,13 +441,13 @@ export interface NativeTokenBalance { export enum NetworkType { MAINNETS = 'MAINNETS', TESTNETS = 'TESTNETS', - ALL = 'ALL', + ALL = 'ALL' } export enum OrderStatus { OPEN = 'OPEN', CLOSED = 'CLOSED', - CANCELLED = 'CANCELLED', + CANCELLED = 'CANCELLED' } export interface Page { @@ -467,7 +478,7 @@ export interface Price { export enum ResourceStatus { NOT_AVAILABLE = 'NOT_AVAILABLE', REFRESHING = 'REFRESHING', - AVAILABLE = 'AVAILABLE', + AVAILABLE = 'AVAILABLE' } export interface RuntimeChecks { @@ -504,7 +515,7 @@ export interface SortBy { export enum SortOrder { DESC = 'DESC', - ASC = 'ASC', + ASC = 'ASC' } export interface TokenBalance { @@ -661,13 +672,13 @@ export interface TransactionReceipt { export enum TransactionStatus { FAILED = 'FAILED', - SUCCESSFUL = 'SUCCESSFUL', + SUCCESSFUL = 'SUCCESSFUL' } export enum TransactionType { LegacyTxnType = 'LegacyTxnType', AccessListTxnType = 'AccessListTxnType', - DynamicFeeTxnType = 'DynamicFeeTxnType', + DynamicFeeTxnType = 'DynamicFeeTxnType' } export interface TxnInfo { @@ -694,7 +705,7 @@ export interface TxnTransfer { export enum TxnTransferType { UNKNOWN = 'UNKNOWN', SEND = 'SEND', - RECEIVE = 'RECEIVE', + RECEIVE = 'RECEIVE' } export interface Version { @@ -723,6 +734,8 @@ export interface WebhookListener { name: string updatedAt: string active: boolean + disabledAt?: string + disabledReason?: string } export interface GetBalanceUpdatesRequest { @@ -892,252 +905,214 @@ export class IndexerGateway implements IndexerGatewayClient { queryKey = { getBalanceUpdates: (req: GetBalanceUpdatesRequest) => ['IndexerGateway', 'getBalanceUpdates', req] as const, getChains: (req: GetChainsRequest) => ['IndexerGateway', 'getChains', req] as const, - getNativeTokenBalance: (req: GetNativeTokenBalanceRequest) => - ['IndexerGateway', 'getNativeTokenBalance', req] as const, + getNativeTokenBalance: (req: GetNativeTokenBalanceRequest) => ['IndexerGateway', 'getNativeTokenBalance', req] as const, getTokenBalances: (req: GetTokenBalancesRequest) => ['IndexerGateway', 'getTokenBalances', req] as const, getTokenBalancesByContract: (req: GetTokenBalancesByContractRequest) => ['IndexerGateway', 'getTokenBalancesByContract', req] as const, - getTokenBalancesDetails: (req: GetTokenBalancesDetailsRequest) => - ['IndexerGateway', 'getTokenBalancesDetails', req] as const, - getTokenBalancesSummary: (req: GetTokenBalancesSummaryRequest) => - ['IndexerGateway', 'getTokenBalancesSummary', req] as const, + getTokenBalancesDetails: (req: GetTokenBalancesDetailsRequest) => ['IndexerGateway', 'getTokenBalancesDetails', req] as const, + getTokenBalancesSummary: (req: GetTokenBalancesSummaryRequest) => ['IndexerGateway', 'getTokenBalancesSummary', req] as const, getTokenPrice: (req: GetTokenPriceRequest) => ['IndexerGateway', 'getTokenPrice', req] as const, getTokenPrices: (req: GetTokenPricesRequest) => ['IndexerGateway', 'getTokenPrices', req] as const, - getTransactionHistory: (req: GetTransactionHistoryRequest) => - ['IndexerGateway', 'getTransactionHistory', req] as const, + getTransactionHistory: (req: GetTransactionHistoryRequest) => ['IndexerGateway', 'getTransactionHistory', req] as const, ping: () => ['IndexerGateway', 'ping'] as const, runtimeStatus: () => ['IndexerGateway', 'runtimeStatus'] as const, - version: () => ['IndexerGateway', 'version'] as const, + version: () => ['IndexerGateway', 'version'] as const } getBalanceUpdates = ( req: GetBalanceUpdatesRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetBalanceUpdates'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetBalanceUpdatesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getChains = (req: GetChainsRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetChains'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetChainsResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getNativeTokenBalance = ( req: GetNativeTokenBalanceRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetNativeTokenBalance'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetNativeTokenBalanceResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalances = ( req: GetTokenBalancesRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalances'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalancesByContract = ( req: GetTokenBalancesByContractRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalancesByContract'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesByContractResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalancesDetails = ( req: GetTokenBalancesDetailsRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalancesDetails'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesDetailsResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTokenBalancesSummary = ( req: GetTokenBalancesSummaryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTokenBalancesSummary'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenBalancesSummaryResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } - getTokenPrice = ( - req: GetTokenPriceRequest, - headers?: object, - signal?: AbortSignal, - ): Promise => { + getTokenPrice = (req: GetTokenPriceRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetTokenPrice'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenPriceResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } - getTokenPrices = ( - req: GetTokenPricesRequest, - headers?: object, - signal?: AbortSignal, - ): Promise => { + getTokenPrices = (req: GetTokenPricesRequest, headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('GetTokenPrices'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTokenPricesResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } getTransactionHistory = ( req: GetTransactionHistoryRequest, headers?: object, - signal?: AbortSignal, + signal?: AbortSignal ): Promise => { return this.fetch(this.url('GetTransactionHistory'), createHttpRequest(JsonEncode(req), headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'GetTransactionHistoryResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } ping = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('Ping'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'PingResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } runtimeStatus = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('RuntimeStatus'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'RuntimeStatusResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } version = (headers?: object, signal?: AbortSignal): Promise => { return this.fetch(this.url('Version'), createHttpRequest('{}', headers, signal)).then( - (res) => { - return buildResponse(res).then((_data) => { + res => { + return buildResponse(res).then(_data => { return JsonDecode(_data, 'VersionResponse') }) }, - (error) => { - throw WebrpcRequestFailedError.new({ - cause: `fetch(): ${error instanceof Error ? error.message : String(error)}`, - }) - }, + error => { + throw WebrpcRequestFailedError.new({ cause: `fetch(): ${error instanceof Error ? error.message : String(error)}` }) + } ) } } @@ -1146,20 +1121,20 @@ const createHttpRequest = (body: string = '{}', headers: object = {}, signal: Ab const reqHeaders: { [key: string]: string } = { ...headers, 'Content-Type': 'application/json', - [WebrpcHeader]: WebrpcHeaderValue, + [WebrpcHeader]: WebrpcHeaderValue } return { method: 'POST', headers: reqHeaders, body, signal } } const buildResponse = (res: Response): Promise => { - return res.text().then((text) => { + return res.text().then(text => { let data try { data = JSON.parse(text) } catch (error) { throw WebrpcBadResponseError.new({ status: res.status, - cause: `JSON.parse(): ${error instanceof Error ? error.message : String(error)}: response text: ${text}`, + cause: `JSON.parse(): ${error instanceof Error ? error.message : String(error)}: response text: ${text}` }) } if (!res.ok) { @@ -1698,7 +1673,7 @@ export enum errors { Timeout = 'Timeout', Unauthorized = 'Unauthorized', UnauthorizedUser = 'UnauthorizedUser', - Unavailable = 'Unavailable', + Unavailable = 'Unavailable' } export enum WebrpcErrorCodes { @@ -1738,7 +1713,7 @@ export enum WebrpcErrorCodes { Timeout = 1900, Unauthorized = 1000, UnauthorizedUser = 1105, - Unavailable = 2002, + Unavailable = 2002 } export const webrpcErrorByCode: { [code: number]: any } = { @@ -1778,7 +1753,7 @@ export const webrpcErrorByCode: { [code: number]: any } = { [1900]: TimeoutError, [1000]: UnauthorizedError, [1105]: UnauthorizedUserError, - [2002]: UnavailableError, + [2002]: UnavailableError } // @@ -1805,7 +1780,7 @@ export function VersionFromHeader(headers: Headers): WebrpcGenVersions { codeGenName: '', codeGenVersion: '', schemaName: '', - schemaVersion: '', + schemaVersion: '' } } @@ -1820,7 +1795,7 @@ function parseWebrpcGenVersions(header: string): WebrpcGenVersions { codeGenName: '', codeGenVersion: '', schemaName: '', - schemaVersion: '', + schemaVersion: '' } } @@ -1833,6 +1808,6 @@ function parseWebrpcGenVersions(header: string): WebrpcGenVersions { codeGenName: codeGenName ?? '', codeGenVersion: codeGenVersion ?? '', schemaName: schemaName ?? '', - schemaVersion: schemaVersion ?? '', + schemaVersion: schemaVersion ?? '' } }