ichnaea/server/actions/influx_actions.js

const {Point} = require('@influxdata/influxdb-client');
const chalk = require('chalk')

const {writeApi, queryApi} = require('../connections/influx_conn')

iWrite = (pointName, uuid, measurement) => {
    const point = new Point(pointName)
        .tag('client', uuid)
        .floatField('value', measurement);
    writeApi.writePoint(point);
    writeApi.flush().then(() => {
    });
}

closeWrite = () => {
    writeApi
        .close()
        .then(() => {
            console.log(chalk.magenta('Write finished'));
        })
        .catch((e) => {
            console.error(e);
            console.log(chalk.red('Write ERROR'));
        });
}

iQuery = (query) => {
    return queryApi
        .collectRows(query)
        .then((result) => {
            return result;
        })
        .catch((err) => {
            return [{Error: 'Error occurred'}];
        });
}

module.exports = {iWrite, closeWrite, iQuery}