fix: parsing infinite numbers (influxdata#221)

Author: bednar

CHANGELOG.md

@@ -1,5 +1,8 @@
 ## 2.1.0 [unreleased]
 
+### Bug Fixes
+1. [#221](https://github.com/influxdata/influxdb-client-csharp/pull/221): Parsing infinite numbers
+
 ### Dependencies
 1. [#222](https://github.com/influxdata/influxdb-client-csharp/pull/222): Update dependencies:
  - RestSharp to 106.12.0

Client.Core/Flux/Exceptions/FluxCsvParserException.cs

@@ -1,3 +1,4 @@
+using System;
 using InfluxDB.Client.Core.Exceptions;
 using InfluxDB.Client.Core.Flux.Domain;
 
@@ -11,5 +12,9 @@ public class FluxCsvParserException : InfluxException
  public FluxCsvParserException(string message) : base(message)
  {
  }
+
+ public FluxCsvParserException(string message, Exception exception = null) : base(message, exception)
+ {
+ }
  }
 }

Client.Core/Flux/Internal/FluxCsvParser.cs

@@ -209,9 +209,9 @@ private class ParseFluxResponseState
  {
  currentId = Convert.ToInt32(state.csv[1 + 1]);
  }
- catch (Exception)
+ catch (Exception e)
  {
- throw new FluxCsvParserException("Unable to parse CSV response.");
+ throw new FluxCsvParserException("Unable to parse CSV response.", e);
  }
  if (state.tableId == -1)
  {
@@ -273,7 +273,12 @@ private Object ToValue(string strValue, FluxColumn column)
  case "long":
  return Convert.ToInt64(strValue);
  case "double":
- return Convert.ToDouble(strValue, CultureInfo.InvariantCulture);
+ return strValue switch
+ {
+ "+Inf" => double.PositiveInfinity,
+ "-Inf" => double.NegativeInfinity,
+ _ => Convert.ToDouble(strValue, CultureInfo.InvariantCulture)
+ };
  case "base64Binary":
  return Convert.FromBase64String(strValue);
  case "dateTime:RFC3339":
@@ -285,9 +290,9 @@ private Object ToValue(string strValue, FluxColumn column)
  return strValue;
  }
  }
- catch (Exception)
+ catch (Exception e)
  {
- throw new FluxCsvParserException("Unable to parse CSV response.");
+ throw new FluxCsvParserException("Unable to parse CSV response.", e);
  }
  }
 

Client.Legacy.Test/FluxCsvParserTest.cs

@@ -705,6 +705,35 @@ public void ResponseWithError()
  }
  }
 
+ [Test]
+ public void ParseInfinite()
+ {
+ const string data = @"#group,false,false,true,true,true,true,true,true,true,true,false,false
+#datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,string,string,string,string,string,string,double,double
+#default,_result,,,,,,,,,,,
+,result,table,_start,_stop,_field,_measurement,language,license,name,owner,le,_value
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,0,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,10,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,20,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,30,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,40,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,50,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,60,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,70,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,80,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,90,0
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,+Inf,15
+,,0,2021-06-23T06:50:11.897825012Z,2021-06-25T06:50:11.897825012Z,stars,github_repository,C#,MIT License,influxdb-client-csharp,influxdata,-Inf,15
+
+";
+ 
+ var tables = ParseFluxResponse(data);
+ Assert.AreEqual(1, tables.Count);
+ Assert.AreEqual(12, tables[0].Records.Count);
+ Assert.AreEqual(double.PositiveInfinity, tables[0].Records[10].GetValueByKey("le"));
+ Assert.AreEqual(double.NegativeInfinity, tables[0].Records[11].GetValueByKey("le"));
+ }
+
  private List<FluxTable> ParseFluxResponse(string data)
  {
  var consumer = new FluxCsvParser.FluxResponseConsumerTable();