import { Filter } from '../types.ts'
import { RealTimeFeedBase } from './realtimefeed.ts'

export class CryptoComRealTimeFeed extends RealTimeFeedBase {
  protected wssURL = 'wss://stream.crypto.com/exchange/v1/market'

  protected mapToSubscribeMessages(filters: Filter<string>[]): any[] {
    const channels = filters
      .map((filter) => {
        if (!filter.symbols || filter.symbols.length === 0) {
          throw new Error('CryptoComRealTimeFeed requires explicitly specified symbols when subscribing to live feed')
        }

        return filter.symbols.map((symbol) => {
          const suffix = filter.channel === 'book' ? '.50' : ''
          return `${filter.channel}.${symbol}${suffix}`
        })
      })
      .flatMap((s) => s)

    return [
      {
        id: 1,
        method: 'subscribe',
        nonce: new Date().valueOf(),
        params: {
          channels: channels,
          book_subscription_type: 'SNAPSHOT_AND_UPDATE'
        }
      }
    ]
  }

  protected messageIsError(message: any): boolean {
    return message.code !== undefined && message.code !== 0 && message.code !== 40003
  }

  protected onMessage(msg: any) {
    if (msg.method === 'public/heartbeat') {
      this.send({
        id: msg.id,
        method: 'public/respond-heartbeat'
      })
    }
  }
  protected messageIsHeartbeat(msg: any) {
    return msg.method === 'public/heartbeat'
  }
}