Update influx api to use writeMeasurement for v5

mvantassel · Feb 12, 2017 · 93acaad · 93acaad
1 parent 934dd23
commit 93acaad
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/nzb2influx.js b/nzb2influx.js
@@ -20,8 +20,16 @@ const nzbgetConfig = {
     password: process.env.NZBGET_PASSWORD || ''
 };
 
-function writeToInflux(seriesName, values, tags, callback) {
-    return influxClient.writePoint(seriesName, values, tags, callback);
+function writeToInflux(seriesName, values, tags) {
+    var payload = {
+        fields: values
+    };
+
+    if (tags) {
+        payload.tags = tags;
+    }
+
+    return influxClient.writeMeasurement(seriesName, [payload]);
 }
 
 const ng = new nzbget({
@@ -43,14 +51,14 @@ function onGetNZBData(data) {
             category: nzb.Category
         };
 
-        writeToInflux('nzb', value, tags, function() {
+        writeToInflux('nzb', value, tags).then(function() {
             console.dir(`wrote ${nzb.NZBName} nzb data to influx: ${new Date()}`);
         });
     });
 
     writeToInflux('nzbs', {
         count: nzbs.length
-    }, null, function() {
+    }, null).then(function() {
         console.dir(`wrote ${nzbs.length} nzbs data to influx: ${new Date()}`);
         restart();
     });

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "nzb2influx",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "private": true,
   "scripts": {
     "start": "node nzb2influx.js"