Compare commits

...

3 Commits

2 changed files with 7 additions and 7 deletions

View File

@ -40,12 +40,7 @@ function checkWriteApi(influxDb, options){
const writeApi = influxDb.getWriteApi(options.org, options.bucket); // Get WriteAPI 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.writePoint(new Point("test").tag("ConnectionTest", true).intField("value", 0).timestamp(0)) // Write dummy-point
writeApi.close() writeApi.close()
.catch((err) => { .then((res) => {
logger.error("Could not get writeApi:");
logger.error(`Error [${err.code}]:`, err.message);
if(err.code == "not found") logger.fatal("No write-permission?");
reject();
}).then((res) => {
logger.debug("Writing ok"); logger.debug("Writing ok");
// Delete the connection-text-point // Delete the connection-text-point
@ -64,6 +59,11 @@ function checkWriteApi(influxDb, options){
reject(); reject();
}) })
.then(resolve()) .then(resolve())
},
(err) => {
logger.error("Could not get writeApi:");
logger.error(`Error [${err.code}]:`, err.message);
reject();
}); });
}); });
} }

View File

@ -33,7 +33,7 @@ if(errorMsg){
})}) })})
.then((res) => {return InfluxChecks.checkWriteApi(influxDb, { .then((res) => {return InfluxChecks.checkWriteApi(influxDb, {
org: env.INFLUX_ORG, org: env.INFLUX_ORG,
name: env.INFLUX_BUCKET bucket: env.INFLUX_BUCKET
})}) })})
.catch((err) => { .catch((err) => {
if(err) { if(err) {