import { EVENT } from '../constants'
import { ALL_ACTIONS, ACTIONS, Message } from '@deepstream/protobuf/dist/types/messages'
import { TOPIC, JSONObject } from '@deepstream/protobuf/dist/types/all'
import { Emitter } from './emitter'

function isEvent (action: EVENT | ALL_ACTIONS | undefined): boolean {
  // @ts-ignore
  return EVENT[action] !== undefined
}

export class Logger {
  constructor (private emitter: Emitter) {
  }

  public warn (message: { topic: TOPIC } | Message, event?: EVENT | ALL_ACTIONS, meta?: any): void {
    let warnMessage = `Warning: ${TOPIC[message.topic]}`
    const action = (message as Message).action
    if (action) {
      warnMessage += ` (${(ACTIONS as any)[message.topic][action]})`
    }
    if (event) {
      warnMessage += `: ${(EVENT as any)[event]}`
    }
    if (meta) {
      warnMessage += ` – ${typeof meta === 'string' ? meta : JSON.stringify(meta)}`
    }
    // tslint:disable-next-line:no-console
    console.warn(warnMessage)
  }

  public error (message: { topic: TOPIC } | Message, event?: EVENT | ALL_ACTIONS, meta?: string | JSONObject | Error): void {
    if (isEvent(event)) {
      if (event === EVENT.IS_CLOSED || event === EVENT.CONNECTION_ERROR) {
        this.emitter.emit('error', meta, EVENT[event], TOPIC[TOPIC.CONNECTION])
      } else {
        // @ts-ignore
        this.emitter.emit('error', meta, EVENT[event], TOPIC[message.topic])
      }
    } else {
      const action = event ? event : (message as Message).action
      this.emitter.emit(
        'error',
        meta || message,
        (ACTIONS as any)[message.topic][action],
        TOPIC[message.topic]
      )
    }
  }
}