Indexer 스트리밍

import { getNetworkEndpoints, Network } from '@injectivelabs/networks'
import { 
  StreamManagerV2,
  IndexerGrpcSpotStreamV2 
} from '@injectivelabs/sdk-ts/client/indexer'

const endpoints = getNetworkEndpoints(Network.Testnet)
const stream = new IndexerGrpcSpotStreamV2(endpoints.indexer)

const streamManager = new StreamManagerV2({
  id: 'my-stream',
  streamFactory: () => stream.streamOrders({ 
    marketId: '0x...',
    callback: (response) => {
      streamManager.emit('data', response)
    }
  }),
  onData: (data) => {
    console.log(data)
  },
  retryConfig: {
    enabled: true,
    maxAttempts: 5,
    initialDelayMs: 1000,
    maxDelayMs: 30000,
    backoffMultiplier: 2,
    persistent: true
  }
})

// 이벤트 리스너
streamManager.on('connect', () => console.log('연결됨'))
streamManager.on('disconnect', (reason) => console.log('연결 끊김:', reason))
streamManager.on('error', (error) => console.error('오류:', error))
streamManager.on('stateChange', ({ from, to }) => console.log(`상태: ${from} -> ${to}`))

// 시작/중지
streamManager.start()
streamManager.stop()

retryConfig: {
  enabled: true,           // 재시도 활성화/비활성화
  maxAttempts: 5,          // 최대 재시도 횟수 (0 = 무제한)
  initialDelayMs: 1000,    // 초기 백오프 지연
  maxDelayMs: 30000,       // 최대 백오프 지연
  backoffMultiplier: 2,    // 지수 백오프 배수
  persistent: true         // maxAttempts 후에도 최대 지연으로 계속
}