fix: allow passing grpc options into client classes

Author: billyjacoby

packages/sdk-ts/src/client/base/BaseGrpcConsumer.ts

@@ -7,6 +7,7 @@ import {
 } from '@injectivelabs/exceptions'
 import { GrpcWebRpcTransport } from './GrpcWebRpcTransport.js'
 import type { UnaryCall, RpcOptions } from '@protobuf-ts/runtime-rpc'
+import type { GrpcWebTransportAdditionalOptions } from '../../utils/grpc.js'
 
 /**
  * BaseGrpcConsumer provides base functionality for all gRPC consumers.
@@ -17,19 +18,20 @@ export default class BaseGrpcConsumer {
   protected module: string = ''
   protected metadata?: Record<string, string>
   protected endpoint: string
+  protected options?: GrpcWebTransportAdditionalOptions
 
-  constructor(endpoint: string) {
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
     this.endpoint = endpoint
-    this.transport = new GrpcWebRpcTransport(endpoint, {
-      headers: {},
-    })
+    this.options = options
+    this.transport = new GrpcWebRpcTransport(endpoint, options)
   }
 
   public setMetadata(map: Record<string, string>) {
     this.metadata = map
-    // Recreate transport with new metadata
+    // Recreate transport with new metadata, preserving existing options
     this.transport = new GrpcWebRpcTransport(this.endpoint, {
-      headers: this.metadata,
+      ...this.options,
+      meta: this.metadata,
     })
     return this
   }

packages/sdk-ts/src/client/base/GrpcWebRpcTransport.ts

@@ -1,4 +1,7 @@
-import { getGrpcWebTransport } from '../../utils/grpc.js'
+import {
+  getGrpcWebTransport,
+  type GrpcWebTransportAdditionalOptions,
+} from '../../utils/grpc.js'
 import type {
   UnaryCall,
   RpcOptions,
@@ -18,15 +21,7 @@ import type {
 export class GrpcWebRpcTransport implements RpcTransport {
   private transport: RpcTransport
 
-  constructor(
-    baseUrl: string,
-    options?: {
-      fetch?: typeof fetch
-      headers?: Record<string, string>
-      timeout?: number
-      credentials?: RequestCredentials
-    },
-  ) {
+  constructor(baseUrl: string, options?: GrpcWebTransportAdditionalOptions) {
     this.transport = getGrpcWebTransport(baseUrl, options)
   }
 

packages/sdk-ts/src/client/chain/grpc/ChainGrpcAuctionApi.ts

@@ -3,6 +3,7 @@ import { QueryClient as InjectiveAuctionV1Beta1QueryClient } from '@injectivelab
 import { ChainModule } from '../types/index.js'
 import BaseGrpcConsumer from '../../base/BaseGrpcConsumer.js'
 import { ChainGrpcAuctionTransformer } from '../transformers/index.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 /**
  * @category Chain Grpc API
@@ -12,8 +13,8 @@ export class ChainGrpcAuctionApi extends BaseGrpcConsumer {
 
   private client: InjectiveAuctionV1Beta1QueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
 
     this.client = new InjectiveAuctionV1Beta1QueryClient(this.transport)
   }

packages/sdk-ts/src/client/chain/grpc/ChainGrpcAuthApi.ts

@@ -5,6 +5,7 @@ import BaseGrpcConsumer from '../../base/BaseGrpcConsumer.js'
 import { ChainGrpcAuthTransformer } from '../transformers/ChainGrpcAuthTransformer.js'
 import { ChainGrpcCommonTransformer } from '../transformers/ChainGrpcCommonTransformer.js'
 import type { PaginationOption } from '../../../types/pagination.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 /**
  * @category Chain Grpc API
@@ -13,8 +14,8 @@ export class ChainGrpcAuthApi extends BaseGrpcConsumer {
   protected module: string = ChainModule.Auth
   private client: CosmosAuthV1BetaQueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
     this.client = new CosmosAuthV1BetaQueryClient(this.transport)
   }
 

packages/sdk-ts/src/client/chain/grpc/ChainGrpcAuthZApi.ts

@@ -5,6 +5,7 @@ import BaseGrpcConsumer from '../../base/BaseGrpcConsumer.js'
 import { ChainGrpcAuthZTransformer } from '../transformers/ChainGrpcAuthZTransformer.js'
 import { ChainGrpcCommonTransformer } from '../transformers/ChainGrpcCommonTransformer.js'
 import type { PaginationOption } from '../../../types/pagination.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 /**
  * @category Chain Grpc API
@@ -13,8 +14,8 @@ export class ChainGrpcAuthZApi extends BaseGrpcConsumer {
   protected module: string = ChainModule.Authz
   private client: CosmosAuthzV1BetaQueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
     this.client = new CosmosAuthzV1BetaQueryClient(this.transport)
   }
 

packages/sdk-ts/src/client/chain/grpc/ChainGrpcBankApi.ts

@@ -6,6 +6,7 @@ import { ChainGrpcBankTransformer } from '../transformers/index.js'
 import { fetchAllWithPagination } from '../../../utils/pagination.js'
 import { ChainGrpcCommonTransformer } from '../transformers/ChainGrpcCommonTransformer.js'
 import type { PaginationOption } from '../../../types/pagination.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 const MAX_LIMIT_FOR_SUPPLY = 10000
 
@@ -16,8 +17,8 @@ export class ChainGrpcBankApi extends BaseGrpcConsumer {
   protected module: string = ChainModule.Bank
   private client: CosmosBankV1BetaQueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
     this.client = new CosmosBankV1BetaQueryClient(this.transport)
   }
 

packages/sdk-ts/src/client/chain/grpc/ChainGrpcDistributionApi.ts

@@ -5,6 +5,7 @@ import BaseGrpcConsumer from '../../base/BaseGrpcConsumer.js'
 import { ChainGrpcDistributionTransformer } from '../transformers/index.js'
 import type { Coin } from '@injectivelabs/ts-types'
 import type { ValidatorRewards } from '../types/index.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 /**
  * @category Chain Grpc API
@@ -13,8 +14,8 @@ export class ChainGrpcDistributionApi extends BaseGrpcConsumer {
   protected module: string = ChainModule.Distribution
   private client: CosmosDistributionV1Beta1QueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
     this.client = new CosmosDistributionV1Beta1QueryClient(this.transport)
   }
 

packages/sdk-ts/src/client/chain/grpc/ChainGrpcErc20Api.ts

@@ -8,6 +8,7 @@ import {
   ChainGrpcCommonTransformer,
 } from '../transformers/index.js'
 import type { PaginationOption } from '../../../types/pagination.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 const MAX_LIMIT_FOR_SUPPLY = 10000
 
@@ -19,8 +20,8 @@ export class ChainGrpcErc20Api extends BaseGrpcConsumer {
 
   private client: InjectiveErc20V1Beta1QueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
 
     this.client = new InjectiveErc20V1Beta1QueryClient(this.transport)
   }

packages/sdk-ts/src/client/chain/grpc/ChainGrpcEvmApi.ts

@@ -3,6 +3,7 @@ import { QueryClient as InjectiveEvmV1QueryClient } from '@injectivelabs/core-pr
 import { ChainModule } from '../types/index.js'
 import BaseGrpcConsumer from '../../base/BaseGrpcConsumer.js'
 import { ChainGrpcEvmTransformer } from '../transformers/index.js'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 /**
  * @category Chain Grpc API
@@ -12,8 +13,8 @@ export class ChainGrpcEvmApi extends BaseGrpcConsumer {
 
   private client: InjectiveEvmV1QueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
 
     this.client = new InjectiveEvmV1QueryClient(this.transport)
   }

packages/sdk-ts/src/client/chain/grpc/ChainGrpcExchangeApi.ts

@@ -5,6 +5,7 @@ import BaseGrpcConsumer from '../../base/BaseGrpcConsumer.js'
 import { ChainGrpcExchangeTransformer } from '../transformers/index.js'
 import type * as InjectiveExchangeV1Beta1GenesisPb from '@injectivelabs/core-proto-ts-v2/generated/injective/exchange/v1beta1/genesis_pb'
 import type * as InjectiveExchangeV1Beta1ExchangePb from '@injectivelabs/core-proto-ts-v2/generated/injective/exchange/v1beta1/exchange_pb'
+import type { GrpcWebTransportAdditionalOptions } from '../../../utils/grpc.js'
 
 /**
  * @category Chain Grpc API
@@ -13,8 +14,8 @@ export class ChainGrpcExchangeApi extends BaseGrpcConsumer {
   protected module: string = ChainModule.Exchange
   private client: InjectiveExchangeV1Beta1QueryClient
 
-  constructor(endpoint: string) {
-    super(endpoint)
+  constructor(endpoint: string, options?: GrpcWebTransportAdditionalOptions) {
+    super(endpoint, options)
     this.client = new InjectiveExchangeV1Beta1QueryClient(this.transport)
   }