fix: mapping long type into AST (#236)

Author: bednar

CHANGELOG.md

@@ -7,6 +7,9 @@ Adds a `Type` overload for POCOs to `QueryAsync`. This will add `object ConvertT
 1. [#232](https://github.com/influxdata/influxdb-client-csharp/pull/232): Add a `Type` overload for POCOs to `QueryAsync`.
 1. [#233](https://github.com/influxdata/influxdb-client-csharp/pull/233): Add possibility to follow HTTP redirects
 
+### Bug Fixes
+1. [#236](https://github.com/influxdata/influxdb-client-csharp/pull/236): Mapping `long` type into Flux AST [LINQ]
+
 ## 2.1.0 [2021-08-20]
 
 ### Bug Fixes

Client.Linq.Test/DomainObjects.cs

@@ -69,4 +69,9 @@ class TagIsNotDefinedAsString
         [Column(IsTimestamp = true)]
         public DateTime Timestamp { get; set; }
     }
+    
+    public class DataEntityWithLong
+    {
+        public long EndWithTicks { get; set; }
+    }
 }

Client.Linq.Test/InfluxDBQueryVisitorTest.cs

@@ -805,6 +805,35 @@ from s in InfluxDBQueryable<TagIsNotDefinedAsString>.Queryable("my-bucket", "my-
                 Assert.AreEqual("123456", GetLiteral<StringLiteral>(ast, 3).Value);
             }
         }
+        
+        [Test]
+        public void FilterByLong()
+        {
+            var query = from s in InfluxDBQueryable<DataEntityWithLong>.Queryable("my-bucket", "my-org", _queryApi)
+                where s.EndWithTicks <= 637656739543829486
+                select s;
+            var visitor = BuildQueryVisitor(query);
+
+            Assert.AreEqual(FluxStart + " |> filter(fn: (r) => (r[\"EndWithTicks\"] <= p3))", visitor.BuildFluxQuery());
+            
+            var ast = visitor.BuildFluxAST();
+
+            Assert.NotNull(ast);
+            Assert.NotNull(ast.Body);
+            Assert.AreEqual(3, ast.Body.Count);
+
+            var bucketAssignment = ((OptionStatement) ast.Body[0]).Assignment as VariableAssignment;
+            Assert.AreEqual("p1", bucketAssignment?.Id.Name);
+            Assert.AreEqual("my-bucket", (bucketAssignment?.Init as StringLiteral)?.Value);
+
+            var rangeAssignment = ((OptionStatement) ast.Body[1]).Assignment as VariableAssignment;
+            Assert.AreEqual("p2", rangeAssignment?.Id.Name);
+            Assert.AreEqual("0", (rangeAssignment?.Init as IntegerLiteral)?.Value);
+
+            var endWithTicksAssignment = ((OptionStatement) ast.Body[2]).Assignment as VariableAssignment;
+            Assert.AreEqual("p3", endWithTicksAssignment?.Id.Name);
+            Assert.AreEqual("637656739543829486", (endWithTicksAssignment?.Init as IntegerLiteral)?.Value);
+        }
 
         private InfluxDBQueryVisitor BuildQueryVisitor(IQueryable queryable, Expression expression = null)
         {

Client.Linq/Internal/VariableAggregator.cs

@@ -46,6 +46,10 @@ internal List<Statement> GetStatements()
                 {
                     literal = new IntegerLiteral("IntegerLiteral", Convert.ToString(i));
                 }
+                else if (variable.Value is long l)
+                {
+                    literal = new IntegerLiteral("IntegerLiteral", Convert.ToString(l));
+                }
                 else if (variable.Value is bool b)
                 {
                     literal = new BooleanLiteral("BooleanLiteral", b);