Updated PostValuesAsync, added test

Author: mvadu

AdysTech.InfluxDB.Client.Net.Test/InfluxDBClientTest.cs

@@ -3,6 +3,7 @@
 
 using AdysTech.InfluxDB.Client.Net;
 using System.Threading.Tasks;
+using System.Collections.Generic;
 
 namespace InfluxDB.Client.Test
 {
@@ -120,7 +121,7 @@ public async Task TestPostValueAsync()
             try
             {
                 var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
-                var r = await client.PostValueAsync (dbName, measurementName, DateTime.Now.ToEpoch(TimePrecision.Seconds),TimePrecision.Seconds,"testTag=testTagValue","Temp",33.05);
+                var r = await client.PostValueAsync (dbName, measurementName, DateTime.UtcNow.ToEpoch(TimePrecision.Seconds),TimePrecision.Seconds,"testTag=testTagValue","Temp",33.05);
                 Assert.IsTrue (r, "PostValueAsync retunred false");
             }
             catch ( Exception e )
@@ -132,5 +133,24 @@ public async Task TestPostValueAsync()
             }
         }
 
+        [TestMethod]
+        public async Task TestPostValuesAsync()
+        {
+            try
+            {
+                var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
+                var val = new Random ();
+                var values = new Dictionary<string, double> () { { "filed1", val.NextDouble () * 10 }, { "filed2", val.NextDouble () * 10 }, { "filed3", val.NextDouble () * 10 } };
+                var r = await client.PostValuesAsync (dbName, measurementName, DateTime.UtcNow.ToEpoch (TimePrecision.Seconds), TimePrecision.Seconds, "testTag=testTagValue",values);
+                Assert.IsTrue (r, "PostValuesAsync retunred false");
+            }
+            catch ( Exception e )
+            {
+
+                Assert.Fail ("Unexpected exception of type {0} caught: {1}",
+                            e.GetType (), e.Message);
+                return;
+            }
+        }
     }
 }

AdysTech.InfluxDB.Client.Net/IInfluxDBClient.cs

@@ -12,7 +12,7 @@ public interface IInfluxDBClient
         Task<Dictionary<string, List<String>>> GetInfluxDBStructureAsync(string dbName);
         Task<bool> CreateDatabaseAsync(string dbName);
         Task<bool> PostValueAsync(string dbName, string measurement, long timestamp, TimePrecision precision, string tags, string field, double value);
-        Task<bool> PostValuesAsync(string dbName, string measurement, long timestamp, TimePrecision precision, string tags, IEnumerable<string> values);
+        Task<bool> PostValuesAsync(string dbName, string measurement, long timestamp, TimePrecision precision, string tags, IDictionary<string,double> values);
         Task<bool> PostRawValueAsync(string dbName, TimePrecision precision, string content);
     }
 }

AdysTech.InfluxDB.Client.Net/InfluxDB.Client.csproj

@@ -19,7 +19,8 @@ public enum TimePrecision
         Seconds = 3,
         Milliseconds = 4,
         Microseconds = 5,
-        Nanoseconds = 6
+        Nanoseconds = 6,
+        H=1
     }
 
     public class InfluxDBClient : IInfluxDBClient
@@ -253,7 +254,7 @@ public async Task<bool> PostValueAsync(string dbName, string measurement, long t
                     new KeyValuePair<string, string>("precision", precisionLiterals[(int) precision])
                     }).ReadAsStringAsync ();
 
-            var content = String.Format ("{0},{1} {2}={3:0.00} {4}", measurement, tags, field, value, timestamp);
+            var content = String.Format ("{0},{1} {2}={3} {4}", measurement, tags, field, value, timestamp);
             ByteArrayContent requestContent = new ByteArrayContent (Encoding.UTF8.GetBytes (content));
             HttpResponseMessage response = await PostAsync (builder, requestContent);
 
@@ -280,7 +281,7 @@ public async Task<bool> PostValueAsync(string dbName, string measurement, long t
         /// <returns>True:Success, False:Failure</returns>
         ///<exception cref="UnauthorizedAccessException">When Influx needs authentication, and no user name password is supplied or auth fails</exception>
         ///<exception cref="HttpRequestException">all other HTTP exceptions</exception>   
-        public async Task<bool> PostValuesAsync(string dbName, string measurement, long timestamp, TimePrecision precision, string tags, IEnumerable<string> values)
+        public async Task<bool> PostValuesAsync(string dbName, string measurement, long timestamp, TimePrecision precision, string tags, IDictionary<string,double> values)
         {
             var influxAddress = new Uri (String.Format ("{0}/write?", InfluxUrl));
             var builder = new UriBuilder (influxAddress);
@@ -289,11 +290,13 @@ public async Task<bool> PostValuesAsync(string dbName, string measurement, long
                     new KeyValuePair<string, string>("precision", precisionLiterals[(int) precision])
                     }).ReadAsStringAsync ();
 
-            var content = new StringBuilder ();
-            foreach ( var value in values )
-                content.AppendFormat ("{0},{1} {2} {3}\n", measurement, tags, value, timestamp);
-            //remove last \n
-            content.Remove (content.Length - 1, 1);
+            //var content = new StringBuilder ();
+            //foreach ( var value in values )
+            //    content.AppendFormat ("{0},{1} {2} {3}\n", measurement, tags, value, timestamp);
+            ////remove last \n
+            //content.Remove (content.Length - 1, 1);
+            var valuesTxt=String.Join (",", values.Select (v => String.Format ("{0}={1}", v.Key, v.Value)));
+            var content = String.Format ("{0},{1} {2} {3}", measurement, tags, valuesTxt, timestamp);
 
             ByteArrayContent requestContent = new ByteArrayContent (Encoding.UTF8.GetBytes (content.ToString ()));
             HttpResponseMessage response = await PostAsync (builder, requestContent);
@@ -337,6 +340,8 @@ public async Task<bool> PostRawValueAsync(string dbName, TimePrecision precision
             else
                 return false;
         }
+
+
     }
 
 }