Merge pull request #347 from influxdata/fix/parsing-inf

fix: parsing infinite numbers

CHANGELOG.md

@@ -4,6 +4,10 @@
 
 1. [#346](https://github.com/influxdata/influxdb-client-js/pull/346): Make QueryApi compatible with rxjs7.
 
+### Bug Fixes
+
+1. [#347](https://github.com/influxdata/influxdb-client-js/pull/347): Parsing infinite numbers
+
 ## 1.15.0 [2021-07-09]
 
 ### Features

packages/core/src/results/FluxTableMetaData.ts

@@ -10,7 +10,18 @@ export const typeSerializers: Record<ColumnType, (val: string) => any> = {
   boolean: (x: string): any => x === 'true',
   unsignedLong: (x: string): any => (x === '' ? null : +x),
   long: (x: string): any => (x === '' ? null : +x),
-  double: (x: string): any => (x === '' ? null : +x),
+  double(x: string): any {
+    switch (x) {
+      case '':
+        return null
+      case '+Inf':
+        return Number.POSITIVE_INFINITY
+      case '-Inf':
+        return Number.NEGATIVE_INFINITY
+      default:
+        return +x
+    }
+  },
   string: identity,
   base64Binary: identity,
   duration: (x: string): any => (x === '' ? null : x),

packages/core/test/unit/results/FluxTableMetaData.test.ts

@@ -58,6 +58,8 @@ describe('FluxTableMetaData', () => {
     ['long', '', null],
     ['double', '1', 1],
     ['double', '', null],
+    ['double', '+Inf', Number.POSITIVE_INFINITY],
+    ['double', '-Inf', -Number.POSITIVE_INFINITY],
     ['string', '1', '1'],
     ['base64Binary', '1', '1'],
     ['dateTime', '1', '1'],
@@ -75,7 +77,9 @@ describe('FluxTableMetaData', () => {
         }),
       ]
       const subject = createFluxTableMetaData(columns)
-      expect(subject.toObject([entry[1]])).to.deep.equal({a: entry[2]})
+      const val = subject.toObject([entry[1]])
+      const entryElement = entry[2]
+      expect(val).to.deep.equal({a: entryElement})
     })
   }
   describe('custom serialization', () => {