chore: updates as per PR review/feedbacks

Author: Frederick-88

packages/sdk-ts/src/client/indexer/ws/GrpcWebSocketTransport.ts

@@ -19,7 +19,6 @@ import type {
  *
  * Handles:
  * - WebSocket connection lifecycle
- * - Automatic ping/pong to keep connection alive
  * - Reconnection with exponential backoff
  * - State management
  * - Binary message framing
@@ -30,7 +29,6 @@ export class GrpcWebSocketTransport {
   private config: ResolvedWsTransportConfig
   private ws: IsomorphicWebSocket | null = null
   private state: WsState = WsState.Idle
-  private pingInterval: ReturnType<typeof setInterval> | null = null
   private connectionTimeout: ReturnType<typeof setTimeout> | null = null
   private reconnectTimeout: ReturnType<typeof setTimeout> | null = null
   private reconnectAttempts = 0
@@ -203,8 +201,6 @@ export class GrpcWebSocketTransport {
     const isReconnect = this.hasConnectedOnce
     this.hasConnectedOnce = true
 
-    this.startPingInterval()
-
     this.emit('connect', { isReconnect })
     resolve()
   }
@@ -213,8 +209,6 @@ export class GrpcWebSocketTransport {
     event: CloseEvent | { code: number; reason: string },
     reject?: (error: Error) => void,
   ): void {
-    this.clearPingInterval()
-
     // Handle close during connection attempt
     if (this.state === WsState.Connecting) {
       this.clearConnectionTimeout()
@@ -287,26 +281,6 @@ export class GrpcWebSocketTransport {
     }
   }
 
-  private startPingInterval(): void {
-    this.clearPingInterval()
-
-    this.pingInterval = setInterval(() => {
-      if (this.isConnected()) {
-        // Send an empty ping frame - the actual ping message should be
-        // handled by the higher-level stream classes using the codec
-        // This is just to keep the connection alive at the transport level
-        // The stream classes will handle the gRPC-level ping/pong
-      }
-    }, this.config.pingIntervalMs)
-  }
-
-  private clearPingInterval(): void {
-    if (this.pingInterval) {
-      clearInterval(this.pingInterval)
-      this.pingInterval = null
-    }
-  }
-
   private clearConnectionTimeout(): void {
     if (this.connectionTimeout) {
       clearTimeout(this.connectionTimeout)
@@ -381,7 +355,6 @@ export class GrpcWebSocketTransport {
 
   private cleanup(reason: WsDisconnectReason, willRetry: boolean): void {
     this.clearConnectionTimeout()
-    this.clearPingInterval()
     this.clearReconnectTimeout()
 
     if (this.ws) {
@@ -421,8 +394,6 @@ export class GrpcWebSocketTransport {
     return {
       url: config.url,
       protocol: config.protocol ?? DEFAULT_TRANSPORT_CONFIG.protocol,
-      pingIntervalMs:
-        config.pingIntervalMs ?? DEFAULT_TRANSPORT_CONFIG.pingIntervalMs,
       connectionTimeoutMs:
         config.connectionTimeoutMs ??
         DEFAULT_TRANSPORT_CONFIG.connectionTimeoutMs,

packages/sdk-ts/src/client/indexer/ws/rfq/IndexerWsMakerStream.ts

@@ -35,7 +35,6 @@ export class IndexerWsMakerStream {
 
     this.transport = new GrpcWebSocketTransport({
       url: fullUrl,
-      pingIntervalMs: this.pingIntervalMs,
       connectionTimeoutMs: config.connectionTimeoutMs,
       reconnect: config.reconnect,
       metadata: {

packages/sdk-ts/src/client/indexer/ws/rfq/IndexerWsTakerStream.ts

@@ -35,7 +35,6 @@ export class IndexerWsTakerStream {
 
     this.transport = new GrpcWebSocketTransport({
       url: fullUrl,
-      pingIntervalMs: this.pingIntervalMs,
       connectionTimeoutMs: config.connectionTimeoutMs,
       reconnect: config.reconnect,
       metadata: {

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

@@ -63,8 +63,6 @@ export interface WsTransportConfig {
   url: string
   /** WebSocket subprotocol (default: 'grpc-ws') */
   protocol?: string
-  /** Ping interval in milliseconds (default: 1000) */
-  pingIntervalMs?: number
   /** Connection timeout in milliseconds (default: 10000) */
   connectionTimeoutMs?: number
   /** Reconnection configuration */
@@ -79,7 +77,6 @@ export interface WsTransportConfig {
 export interface ResolvedWsTransportConfig {
   url: string
   protocol: string
-  pingIntervalMs: number
   connectionTimeoutMs: number
   reconnect: WsReconnectConfig
   metadata?: Record<string, string>
@@ -101,7 +98,6 @@ export const DEFAULT_RECONNECT_CONFIG: WsReconnectConfig = {
  */
 export const DEFAULT_TRANSPORT_CONFIG = {
   protocol: 'grpc-ws',
-  pingIntervalMs: 1000, // 1 second (server timeout is 2 seconds)
   connectionTimeoutMs: 10000, // 10 seconds
 }
 

protoV2/indexer/src/index.d.ts

@@ -16,7 +16,7 @@ export { InjectivePortfolioRPCClient } from './generated/injective_portfolio_rpc
 export { InjectiveReferralRPCClient } from './generated/injective_referral_rpc_pb.client.js'
 export { InjectiveSpotExchangeRPCClient } from './generated/injective_spot_exchange_rpc_pb.client.js'
 export { InjectiveTradingRPCClient } from './generated/injective_trading_rpc_pb.client.js'
-export { InjectiveRfqRPCClient } from './generated/injective_rfq_rpc_pb.client.js'
+export { InjectiveRFQRPCClient } from './generated/injective_rfqrpc_pb.client.js'
 
 export * as EventProviderApiPb from './generated/event_provider_api_pb.js'
 export * as HealthPb from './generated/health_pb.js'
@@ -36,4 +36,4 @@ export * as InjectivePortfolioRpcPb from './generated/injective_portfolio_rpc_pb
 export * as InjectiveReferralRpcPb from './generated/injective_referral_rpc_pb.js'
 export * as InjectiveSpotExchangeRpcPb from './generated/injective_spot_exchange_rpc_pb.js'
 export * as InjectiveTradingRpcPb from './generated/injective_trading_rpc_pb.js'
-export * as InjectiveRfqRpcPb from './generated/injective_rfq_rpc_pb.js'
+export * as InjectiveRFQRpcPb from './generated/injective_rfqrpc_pb.js'

protoV2/indexer/src/index.template.ts

@@ -19,7 +19,7 @@ export { InjectivePortfolioRPCClient } from './generated/injective_portfolio_rpc
 export { InjectiveReferralRPCClient } from './generated/injective_referral_rpc_pb.client.js'
 export { InjectiveSpotExchangeRPCClient } from './generated/injective_spot_exchange_rpc_pb.client.js'
 export { InjectiveTradingRPCClient } from './generated/injective_trading_rpc_pb.client.js'
-export { InjectiveRfqRPCClient } from './generated/injective_rfq_rpc_pb.client.js'
+export { InjectiveRFQRPCClient } from './generated/injective_rfqrpc_pb.client.js'
 
 // Export all types as namespaces for easy import
 export * as EventProviderApiPb from './generated/event_provider_api_pb.js'
@@ -40,4 +40,4 @@ export * as InjectivePortfolioRpcPb from './generated/injective_portfolio_rpc_pb
 export * as InjectiveReferralRpcPb from './generated/injective_referral_rpc_pb.js'
 export * as InjectiveSpotExchangeRpcPb from './generated/injective_spot_exchange_rpc_pb.js'
 export * as InjectiveTradingRpcPb from './generated/injective_trading_rpc_pb.js'
-export * as InjectiveRfqRpcPb from './generated/injective_rfq_rpc_pb.js'
+export * as InjectiveRFQRpcPb from './generated/injective_rfqrpc_pb.js'

protoV2/indexer/src/index.ts

@@ -19,7 +19,7 @@ export { InjectivePortfolioRPCClient } from './generated/injective_portfolio_rpc
 export { InjectiveReferralRPCClient } from './generated/injective_referral_rpc_pb.client.js'
 export { InjectiveSpotExchangeRPCClient } from './generated/injective_spot_exchange_rpc_pb.client.js'
 export { InjectiveTradingRPCClient } from './generated/injective_trading_rpc_pb.client.js'
-export { InjectiveRfqRPCClient } from './generated/injective_rfq_rpc_pb.client.js'
+export { InjectiveRFQRPCClient } from './generated/injective_rfqrpc_pb.client.js'
 
 // Export all types as namespaces for easy import
 export * as EventProviderApiPb from './generated/event_provider_api_pb.js'
@@ -40,4 +40,4 @@ export * as InjectivePortfolioRpcPb from './generated/injective_portfolio_rpc_pb
 export * as InjectiveReferralRpcPb from './generated/injective_referral_rpc_pb.js'
 export * as InjectiveSpotExchangeRpcPb from './generated/injective_spot_exchange_rpc_pb.js'
 export * as InjectiveTradingRpcPb from './generated/injective_trading_rpc_pb.js'
-export * as InjectiveRfqRpcPb from './generated/injective_rfq_rpc_pb.js'
+export * as InjectiveRFQRpcPb from './generated/injective_rfqrpc_pb.js'