import { TopicMessage } from './protobuf-map'
import { ParseResult } from '../types/messages'
// @ts-ignore
import { Message } from '../generated/protobuf'
import { PARSER_ACTION, TOPIC } from '../types/all'

export interface RawMessage {
  fin: boolean
  topic: number
  action: number
  meta?: Buffer
  payload?: Buffer
  rawHeader: Buffer
}

export function parse (data: Uint8Array): Array<ParseResult> {
  try {
    const msg = Message.decodeDelimited(data)
    const message = TopicMessage[msg.topic].decode(msg.message, msg.message.length)
    return [{ topic: msg.topic, ...message }]
  } catch (e) {
    return [{ topic: TOPIC.PARSER, action: PARSER_ACTION.ERROR }]
  }
}

export function parseData (message: any): true | Error {
  if (message.requestorData) {
    message.requestorData = JSON.parse(message.requestorData)
  }

  if (message.parsedData !== undefined || message.data === undefined) {
    return true
  }

  message.parsedData = JSON.parse(message.data)
  if (message.parsedData === undefined) {
    return new Error(`unable to parse data ${message.data}`)
  }

  return true
}