rfmon-to-influx/src/helper/influx-checks.js

const logger = require.main.require("./helper/logger.js")("influx-checks");

const Os = require("os");
const { InfluxDB, Point } = require('@influxdata/influxdb-client')
const Influx = require('@influxdata/influxdb-client-apis');


function checkHealth(influxDb){
    return new Promise((resolve, reject) => {
        new Influx.HealthAPI(influxDb)    // Check influx health
            .getHealth()
            .catch((err) => {
                logger.error("Could not communicate with Influx:");
                logger.error(`Error [${err.code}]:`, err.message);
                reject();
            })
            .then((res) => {
                logger.debug("Server healthy.", "Version: ", res.version);
                resolve(res);
            });
    });
}

function checkBucket(influxDb, options){
    return new Promise((resolve, reject) => {
        new Influx.BucketsAPI(influxDb).getBuckets(options)
            .catch((err) => {       // Weirdly the influx-Api returns 404 for searches of non-existing buckets
                logger.error("Could not get bucket:");
                logger.error(`Error [${err.code}]:`, err.message);
                reject();
            }).then((res) => {      // But an empty list when the bucket exists, but token does not have permission to get details
                logger.debug("Bucket found");
                resolve(res);
                // Now we know the bucket exists and we have some kind of permission.. but we still dont know if we are able to write to it..
            });
    });
}

function checkWriteApi(influxDb, options){
    return new Promise((resolve, reject) => {
        const writeApi = influxDb.getWriteApi(options.org, options.bucket);     // Get WriteAPI
        writeApi.writePoint(new Point("worker_connectionTest").tag("hostname", Os.hostname()))    // Write point
        writeApi.close()
            .catch((err) => {
                logger.error("Could not get writeApi:");
                logger.error(`Error [${err.code}]:`, err.message);
                reject();
            }).then((res) => {
                logger.debug("Writing ok");
                resolve();
            });
    });
}


// Specify exports
module.exports = {
    checkHealth,
    checkBucket,
    checkWriteApi,
};