/*
 * Websocket Loader
 */
/* eslint-disable */
import Event from '../events'
import EventHandler from '../event-handler'
import SlicesReader from '../utils/h264-nal-slicesreader.js'

class WebsocketLoader extends EventHandler {
  constructor(wfs) {
    super(
      wfs,
      Event.WEBSOCKET_ATTACHING,
      Event.WEBSOCKET_DATA_UPLOADING,
      Event.WEBSOCKET_MESSAGE_SENDING
    )
    this.buf = null
    this.slicesReader = new SlicesReader(wfs)
    this.mediaType = undefined
    this.channelName = undefined
    this.cameraInfo = {}
  }

  destroy() {
    !!this.client && this.client.close()
    this.slicesReader.destroy()
    EventHandler.prototype.destroy.call(this)
  }

  onWebsocketAttaching(data) {
    this.mediaType = data.mediaType
    this.channelName = data.channelName
    this.cameraInfo = data.cameraInfo
    if (data.websocket instanceof WebSocket) {
      this.client = data.websocket
      this.client.onopen = this.initSocketClient.bind(this)
      this.client.onclose = function (e) {
        console.log('Websocket Disconnected!')
        this.disconnected = true;
        // console.log(this)
        // this.close = true;
        // this.wfs.attachMedia(this.media, "chX", "H264Raw", this.client.url, this.cameraInfo);
      }
    }
  }

  initSocketClient(client) {
    this.client.binaryType = 'arraybuffer'
    this.client.onmessage = this.receiveSocketMessage.bind(this)
    this.wfs.trigger(Event.WEBSOCKET_MESSAGE_SENDING, {
      commandType: 'open',
      channelName: this.channelName,
      commandValue: 'NA',
      cameraInfo: this.cameraInfo
    })
    this.client.disconnected = false
    // console.log(this)
    console.log('Websocket Open!')
  }

  receiveSocketMessage(event) {
    this.buf = new Uint8Array(event.data)
    var copy = new Uint8Array(this.buf)

    if (this.mediaType === 'FMp4') {
      this.wfs.trigger(Event.WEBSOCKET_ATTACHED, { payload: copy })
    }
    if (this.mediaType === 'H264Raw') {
      this.wfs.trigger(Event.H264_DATA_PARSING, { data: copy })
    }
  }

  onWebsocketDataUploading(event) {
    this.client.send(event.data)
  }

  onWebsocketMessageSending(event) {
    this.client.send(
      JSON.stringify({
        cameraID: event.cameraInfo.cameraID,
        rtspUrl: event.cameraInfo.rtspUrl,
        isRunning: event.cameraInfo.isRunning,
        isGb28181: event.cameraInfo.isGb28181
      })
    )
  }
}

export default WebsocketLoader