@omotes/sdk - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

package.json

 {
   "name": "@omotes/sdk",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "repository": {
@@ -5,0 +5,0 @@ "type": "git",

src/lib/OmotesSDK.d.ts

@@ -10,3 +10,6 @@ import { Job } from './Job';
     createJob(type: JobTypeName, esdl: string): Promise<Job>;
-    getProfile(dbName: string, host: string, port: number, measurement: string, field: string): Promise<import("influx").IResults<unknown>>;
+    getProfile(dbName: string, host: string, port: number, measurement: string, field: string, filterId: string): Promise<import("influx").IResults<{
+        value: number;
+        time: import("influx").INanoDate;
+    }>>;
 }

src/lib/OmotesSDK.js

@@ -40,5 +40,5 @@ "use strict";
     }
-    getProfile(dbName, host, port, measurement, field) {
+    getProfile(dbName, host, port, measurement, field, filterId) {
         return tslib_1.__awaiter(this, void 0, void 0, function* () {
-            return (0, profiles_1.getProfile)(dbName, host, port, measurement, field, this.options.influxUser, this.options.influxPassword);
+            return (0, profiles_1.getProfile)(dbName, host, port, measurement, field, filterId, this.options.influxUser, this.options.influxPassword);
         });
@@ -45,0 +45,0 @@ }

src/lib/profiles.d.ts

@@ -1,1 +0,5 @@
-export declare function getProfile(dbName: string, host: string, port: number, measurement: string, field: string, username: string, password: string): Promise<import("influx").IResults<unknown>>;
+import { INanoDate } from 'influx';
+export declare function getProfile(dbName: string, host: string, port: number, measurement: string, field: string, filterId: string, username: string, password: string): Promise<import("influx").IResults<{
+    value: number;
+    time: INanoDate;
+}>>;

src/lib/profiles.js

@@ -6,3 +6,3 @@ "use strict";
 const influx_1 = require("influx");
-function getProfile(dbName, host, port, measurement, field, username, password) {
+function getProfile(dbName, host, port, measurement, field, filterId, username, password) {
     return tslib_1.__awaiter(this, void 0, void 0, function* () {
@@ -25,3 +25,4 @@ const db = new influx_1.InfluxDB({
         });
-        return db.query(`SELECT * FROM ${field}`);
+        const query = `select ${influx_1.escape.quoted(field)} as value, output_esdl_id from ${influx_1.escape.quoted(measurement)} where output_esdl_id = $filterId;`;
+        return db.query(query, { placeholders: { filterId } });
     });
@@ -28,0 +29,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

24957

increased by2.27%

Lines of code

360

increased by2.27%

No dependency changes