// import Influx from 'influx';
const Influx = require('influx');

export default class InfluxDB {

  protected influx: any;

  constructor(config: any) {

    // const fields {};
    // config.data.ttn.forEach(item => {
    //   fields[item] = Influx.FieldType.INTEGER
    // });
    this.influx = new Influx.InfluxDB({
      host: 'influxdb',
      database: 'dingjs',
      // schema: [
      //   {
      //     measurement: 'ttn',
      //     fields: {
      //       path: Influx.FieldType.STRING,
      //       duration: Influx.FieldType.INTEGER
      //     },
      //     tags: [
      //       'id'
      //     ]
      //   }
      // ]
    });
    this.influx.createDatabase('dingjs');
  }

  /**
   * writeMeasurement
   */
  public writeMeasurement(data: any) {
    console.log("Write data to influxdb;")
    const id = data.id;
    delete data.id;
    this.influx.writeMeasurement('ttn', [
      {
        tags: { id },
        fields: data,
      }
    ]);
  }
}