Ruakij/rfmon-to-influx
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Revert "Move catch into then-onRejected to fix resolving then anyways."

Browse Source 
This reverts commit 2356040572922cfbaa7384a43eb2b7a2ae17f809.
This commit is contained in:
Ruakij 2021-11-26 19:14:01 +01:00
parent 2356040572
commit e18de63d7c
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/helper/influx-checks.js
View File

@ -40,7 +40,12 @@ 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()
.then((res) => { .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"); logger.debug("Writing ok");
// Delete the connection-text-point // Delete the connection-text-point
@ -59,11 +64,6 @@ 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();
}); });
}); });
} }