Added more tests

Author: mvadu

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

@@ -10,6 +10,7 @@ namespace InfluxDB.Client.Test
     public class InfluxDBClientTest
     {
         const string dbName = "testDB";
+        const string measurementName = "TestMeasurement";
         const string invalidDbName = "test DB";
         const string dbUName = "admin";
         const string dbpwd = "admin";
@@ -50,7 +51,7 @@ public async Task TestGetInfluxDBNamesAsync()
         {
             try
             {
-                //pass 8089, which is not influx port
+                
                 var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
                 var r = await client.GetInfluxDBNamesAsync ();
                 Assert.IsTrue (r != null && r.Count > 0, "GetInfluxDBNamesAsync retunred null or empty collection");
@@ -69,7 +70,7 @@ public async Task TestGetInfluxDBStructureAsync_InvalidDB()
         {
             try
             {
-                //pass 8089, which is not influx port
+                
                 var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
                 var r = await client.GetInfluxDBStructureAsync ("InvalidDB");
                 Assert.IsTrue (r != null && r.Count == 0, "GetInfluxDBNamesAsync retunred null or non empty collection");
@@ -82,12 +83,20 @@ public async Task TestGetInfluxDBStructureAsync_InvalidDB()
             }
         }
 
+        [TestMethod]
+        [ExpectedException (typeof (ArgumentException))]
+        public async Task TestCreateDatabaseAsync_InvalidName()
+        {
+            var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
+            var r = await client.CreateDatabaseAsync (invalidDbName);
+        }
+
         [TestMethod]
         public async Task TestCreateDatabaseAsync()
         {
             try
             {
-                //pass 8089, which is not influx port
+                
                 var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
                 var r = await client.CreateDatabaseAsync (dbName);
                 Assert.IsTrue (r, "CreateDatabaseAsync retunred false");
@@ -105,13 +114,23 @@ public async Task TestCreateDatabaseAsync()
             }
         }
 
-
         [TestMethod]
-        [ExpectedException (typeof (ArgumentException))]
-        public async Task TestCreateDatabaseAsync_InvalidName()
+        public async Task TestPostValueAsync()
         {
-            var client = new InfluxDBClient (influxUrl, dbUName, dbpwd);
-            var r = await client.CreateDatabaseAsync (invalidDbName);
+            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);
+                Assert.IsTrue (r, "PostValueAsync retunred false");
+            }
+            catch ( Exception e )
+            {
+
+                Assert.Fail ("Unexpected exception of type {0} caught: {1}",
+                            e.GetType (), e.Message);
+                return;
+            }
         }
+
     }
 }

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

@@ -40,6 +40,7 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="ExtensionMethods.cs" />
     <Compile Include="IInfluxDBClient.cs" />
     <Compile Include="InfluxDBClient.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />

AdysTech.InfluxDB.Client.Net/ExtensionMethods.cs

@@ -0,0 +1,28 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace AdysTech.InfluxDB.Client.Net
+{
+    public static class EpochHelper
+    {
+        private static readonly DateTime Origin = new DateTime (1970, 1, 1);
+
+        public static long ToEpoch(this DateTime time, TimePrecision precision)
+        {
+            TimeSpan t = time - Origin;
+            switch ( precision )
+            {
+                case TimePrecision.Hours: return (long) t.TotalHours;
+                case TimePrecision.Minutes: return (long) t.TotalMinutes;
+                case TimePrecision.Seconds: return (long) t.TotalSeconds;
+                case TimePrecision.Milliseconds: return (long) t.TotalMilliseconds;
+                case TimePrecision.Microseconds: return (long) t.TotalMilliseconds * 1000;
+                case TimePrecision.Nanoseconds: return (long) t.TotalMilliseconds * 1000 * 1000;
+            }
+            return 0;
+        }
+    }
+}