influxdb-v1 - npm Package Compare versions

Comparing version 1.0.2 to 1.0.3

package.json

 {
   "name": "influxdb-v1",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "description": "A light-weight library to write data to InfluxDB v1",
@@ -37,5 +37,5 @@ "main": "./src/index.js",
     "c8": "^7.3.0",
-    "pactum": "^2.0.7",
+    "pactum": "^3.1.3",
     "uvu": "^0.3.3"
   }
 }

README.md

@@ -47,2 +47,8 @@ # influxdb-v1
 });
+
+// query
+
+const db = influx.db({ url: 'http://influx.url', db: 'database name', username: 'user', password: 'pass' });
+await db.query('SELECT * FROM measurement');
+await db.flux('from(bucket:"telegraf")');
 ```
@@ -49,0 +55,0 @@

src/index.d.ts

 export interface InfluxOptions {
   url: string;
   db: string;
+  username?: string;
+  password?: string;
 }
@@ -27,2 +29,8 @@
   write(metrics: Metrics[]): Promise<any>;
+
+  /**
+   * queries data from influx db
+   */
+  query(value: String): Promise<any>;
+  flux(value: String): Promise<any>;
 }
@@ -40,2 +48,9 @@
 export function write(options: InfluxOptions, metrics: Metrics[]): Promise<any>;
+
+/**
+ * queries data from influx db
+ */
+export function query(options: InfluxOptions, value: String): Promise<any>;
+export function flux(options: InfluxOptions, value: String): Promise<any>;
+
 export namespace influx { }

src/index.js

@@ -41,3 +41,3 @@ const rp = require('phin-retry');
     }
-    return rp.post({
+    const req = {
       url: `${this.options.url}/write`,
@@ -48,5 +48,39 @@ qs: {
       body: payloads.join('\n')
-    });
+    }
+    if (this.options.username) {
+      req.auth = { user: this.options.username, pass: this.options.password };
+    }
+    return rp.post(req);
   }
 
+  query(value) {
+    if (!value) throw new Error('`query` is required');
+    const req = {
+      url: `${this.options.url}/query`,
+      qs: {
+        db: this.options.db,
+        q: value
+      }
+    };
+    if (this.options.username) {
+      req.auth = { user: this.options.username, pass: this.options.password };
+    }
+    return rp.get(req);
+  }
+
+  flux(query) {
+    const req = {
+      url: `${this.options.url}/api/v2/query`,
+      headers: {
+        'Accept': 'application',
+        'Content-type': 'application/vnd.flux'
+      },
+      body: query
+    };
+    if (this.options.username) {
+      req.headers['Authorization'] = `Token ${this.options.username}:${this.options.password}`;
+    }
+    return rp.post(req);
+  }
+
 }
@@ -62,2 +96,10 @@
     return new DB(options).write(metrics);
+  },
+
+  query(options, value) {
+    return new DB(options).query(value);
+  },
+
+  flux(options, query) {
+    return new DB(options).flux(query);
   }
@@ -64,0 +106,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

6809

increased by24.94%

Lines of code

134

increased by59.52%

Number of lines in readme file

57

increased by11.76%

No dependency changes