import Debug from 'debug';
import { EventEmitter } from 'events';
import { SerialPort } from '../interfaces/SerialPort';

const debug = Debug('OBD2.Serial.Base');

export class SerialBase extends EventEmitter {
  private Serial: SerialPort;
  private port: string;
  private options: any;
  private opened: boolean = false;

  /**
   * Constructor
   */
  constructor() {
    super();

    this.emit('ready');
  }

  public onData(callBack: any) {
    this.Serial.on('data', callBack);
  }

  /**
   * Serial port connect
   */
  public connect(callBack: any) {
    this.Serial.open(error => {
      this.opened = !!(typeof this.Serial.isOpen === 'function'
        ? this.Serial.isOpen()
        : this.Serial.isOpen);

      if (typeof callBack === 'function') {
        callBack();
      }
    });
  }

  /**
   * Serial port disconnect
   */
  public disconnect(callBack: any) {
    this.Serial.close(error => {
      this.opened = !!(typeof this.Serial.isOpen === 'function'
        ? this.Serial.isOpen()
        : this.Serial.isOpen);

      if (typeof callBack === 'function') {
        callBack();
      }
    });
  }

  /**
   *
   * Serial data drain
   *
   * @param data
   * @param callBack
   */
  public drain(data: string, callBack?: any) {
    // Serial is opened
    if (this.opened) {
      // Try write data
      try {
        this.emit('write', data);
        this.Serial.write(data, error => {
          if (typeof callBack === 'function') {
            this.Serial.drain(callBack);
          }
        });
      } catch (exceptionError) {
        debug('Error while writing, connection is probably lost.');
        debug(exceptionError);
      }
    }
  }

  /**
   * Serial data write
   *
   * @param data
   * @param callBack
   */
  public write(data: string, callBack: any) {
    // Serial is opened
    if (this.opened) {
      // Try write data
      try {
        this.emit('write', data);
        this.Serial.write(data, error => {
          if (typeof callBack === 'function') {
            callBack();
          }
        });
      } catch (exceptionError) {
        debug('Error while writing, connection is probably lost.');
        debug(exceptionError);
      }
    }
  }

  /**
   * Serial port instance set
   *
   * @param serial
   */
  public setSerial(serial: any): void {
    this.Serial = serial;
    this._eventHandlers();
  }

  /**
   * Serial port instance get
   *
   * @returns {any}
   */
  public getSerial(): any {
    return this.Serial;
  }

  /**
   * Set serial port
   *
   * @param port
   */
  public setPort(port: string): void {
    this.port = port;
  }

  /**
   * Get serial port
   *
   * @returns {string}
   */
  public getPort(): string {
    return this.port;
  }

  /**
   * Set serial options
   *
   * @param options
   */
  public setOptions(options: any): void {
    this.options = options;
  }

  /**
   * Get serial options
   *
   * @returns {any}
   */
  public getOptions(): any {
    return this.options;
  }

  /**
   * Get serial port is opened
   *
   * @returns {boolean}
   */
  public isOpen(): boolean {
    return this.opened;
  }

  /**
   * Shared events handling
   *
   * @private
   */
  public _eventHandlers() {
    this.Serial.on('ready', () => {
      debug('Serial port ready');
    });

    this.Serial.on('open', port => {
      debug('Serial port open : ' + port);
    });

    this.Serial.on('close', port => {
      debug('Serial port close: ' + port);
    });

    this.Serial.on('error', (error, port) => {
      debug('Serial port error: ' + port);
    });

    this.Serial.on('data', data => {
      this.emit('data', data);

      data = String(data).replace(/(?:\r\n|\r|\n)/g, '');

      debug('Serial port data : ' + data);
    });

    this.on('write', data => {
      data = String(data).replace(/(?:\r\n|\r|\n)/g, '');

      debug('Serial port write: ' + data);
    });
  }
}