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

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

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("test").tag("ConnectionTest", true).intField("value", 0).timestamp(0))    // Write dummy-point
        writeApi.close()
            .catch((err) => {
                logger.error("Could not get writeApi:");
                logger.error(`Error [${err.code}]:`, err.message);
                if(err.code == "not found") logger.error("No write-permission?");
                reject();
            }).then((res) => {
                logger.debug("Writing ok");

                // Delete the connection-text-point
                new Influx.DeleteAPI(influxDb).postDelete({
                    "body": {
                        "start": 0,
                        "end": 1,
                        "predicate": "ConnectionTest==true"
                    },
                    "org": options.org,
                    "bucket": options.bucket
                })
                    .catch((err) => {
                        logger.error("Could not delete ConnectionTest-Point:");
                        logger.error(`Error [${err.code}]:`, err.message);
                        reject();
                    })
                    .then(resolve())
            });
    });
}


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