@cubejs-client/core - npm Package Compare versions

Comparing version 0.33.47 to 0.33.55

dist/cubejs-client-core.esm.js

@@ -1501,15 +1501,39 @@ import { v4 } from 'uuid';
 
-  loadResponseInternal(response) {
-    if (response.results.length && response.results[0].query.responseFormat && response.results[0].query.responseFormat === ResultType.COMPACT) {
-      response.results.forEach((result, j) => {
-        const data = [];
-        result.data.dataset.forEach(r => {
-          const row = {};
-          result.data.members.forEach((m, i) => {
-            row[m] = r[i];
+  loadResponseInternal(response, options = {}) {
+    if (response.results.length) {
+      if (options.castNumerics) {
+        response.results.forEach(result => {
+          const numericMembers = Object.entries({ ...result.annotation.measures,
+            ...result.annotation.dimensions
+          }).map(([k, v]) => {
+            if (v.type === 'number') {
+              return k;
+            }
+
+            return undefined;
+          }).filter(Boolean);
+          result.data = result.data.map(row => {
+            numericMembers.forEach(key => {
+              if (row[key] != null) {
+                row[key] = Number(row[key]);
+              }
+            });
+            return row;
           });
-          data.push(row);
         });
-        response.results[j].data = data;
-      });
+      }
+
+      if (response.results[0].query.responseFormat && response.results[0].query.responseFormat === ResultType.COMPACT) {
+        response.results.forEach((result, j) => {
+          const data = [];
+          result.data.dataset.forEach(r => {
+            const row = {};
+            result.data.members.forEach((m, i) => {
+              row[m] = r[i];
+            });
+            data.push(row);
+          });
+          response.results[j].data = data;
+        });
+      }
     }
@@ -1534,3 +1558,3 @@
       queryType: 'multi'
-    }), this.loadResponseInternal.bind(this), options, callback);
+    }), response => this.loadResponseInternal(response, options), options, callback);
   }
@@ -1550,3 +1574,3 @@
       queryType: 'multi'
-    }), this.loadResponseInternal.bind(this), { ...options,
+    }), response => this.loadResponseInternal(response, options), { ...options,
       subscribe: true
@@ -1553,0 +1577,0 @@ }, callback);

index.d.ts

@@ -99,6 +99,10 @@ /**
     /**
-     * A Cube.js API instance. If not provided will be taken from `CubeProvider`
+     * A Cube API instance. If not provided will be taken from `CubeProvider`
      */
     cubejsApi?: CubejsApi;
     /**
+     * If enabled, all members of the 'number' type will be automatically converted to numerical values on the client side
+     */
+    castNumerics?: boolean;
+    /**
      * Function that receives `ProgressResult` on each `Continue wait` message.
@@ -105,0 +109,0 @@ */

package.json

 {
   "name": "@cubejs-client/core",
-  "version": "0.33.47",
+  "version": "0.33.55",
   "engines": {},
@@ -48,3 +48,3 @@ "repository": {
   },
-  "gitHead": "56fdafca61e135266bc19d2c34497f7affcdb4da"
+  "gitHead": "7cb9ace521ab59474e54e4f7cbfb98acb91c9008"
 }

src/index.js

@@ -260,20 +260,47 @@ import { v4 as uuidv4 } from 'uuid';
    */
-  loadResponseInternal(response) {
+  loadResponseInternal(response, options = {}) {
     if (
-      response.results.length &&
-      response.results[0].query.responseFormat &&
-      response.results[0].query.responseFormat === ResultType.COMPACT
+      response.results.length
     ) {
-      response.results.forEach((result, j) => {
-        const data = [];
-        result.data.dataset.forEach((r) => {
-          const row = {};
-          result.data.members.forEach((m, i) => {
-            row[m] = r[i];
+      if (options.castNumerics) {
+        response.results.forEach((result) => {
+          const numericMembers = Object.entries({
+            ...result.annotation.measures,
+            ...result.annotation.dimensions,
+          }).map(([k, v]) => {
+            if (v.type === 'number') {
+              return k;
+            }
+            
+            return undefined;
+          }).filter(Boolean);
+          
+          result.data = result.data.map((row) => {
+            numericMembers.forEach((key) => {
+              if (row[key] != null) {
+                row[key] = Number(row[key]);
+              }
+            });
+            
+            return row;
           });
-          data.push(row);
         });
-        response.results[j].data = data;
-      });
+      }
+      
+      if (response.results[0].query.responseFormat &&
+        response.results[0].query.responseFormat === ResultType.COMPACT) {
+        response.results.forEach((result, j) => {
+          const data = [];
+          result.data.dataset.forEach((r) => {
+            const row = {};
+            result.data.members.forEach((m, i) => {
+              row[m] = r[i];
+            });
+            data.push(row);
+          });
+          response.results[j].data = data;
+        });
+      }
     }
+    
     return new ResultSet(response, {
@@ -297,3 +324,3 @@ parseDateMeasures: this.parseDateMeasures
       }),
-      this.loadResponseInternal.bind(this),
+      (response) => this.loadResponseInternal(response, options),
       options,
@@ -317,3 +344,3 @@ callback
       }),
-      this.loadResponseInternal.bind(this),
+      (response) => this.loadResponseInternal(response, options),
       { ...options, subscribe: true },
@@ -320,0 +347,0 @@ callback

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

1822645

increased by0.47%

Lines of code

21348

increased by0.46%

No dependency changes