feat: add possibility to authenticate requests (#65)

Author: bednar

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ### Features
 1. [#61](https://github.com/influxdata/influxdb-client-csharp/issues/61): Set User-Agent to influxdb-client-csharp/VERSION for all requests
+1. [#64](https://github.com/influxdata/influxdb-client-csharp/issues/64): Add authentication with Username and Password for Client.Legacy
 
 ### Bugs
 1. [#63](https://github.com/influxdata/influxdb-client-csharp/pull/63): Correctly parse CSV where multiple results include multiple tables

Client.Legacy.Test/FluxClientPingTest.cs

@@ -1,5 +1,7 @@
 using System.Threading.Tasks;
+using InfluxDB.Client.Flux;
 using NUnit.Framework;
+using WireMock.Matchers;
 using WireMock.RequestBuilders;
 using WireMock.ResponseBuilders;
 
@@ -32,5 +34,20 @@ public async Task NotRunningServer()
 
             Assert.IsFalse(await FluxClient.PingAsync());
         }
+
+        [Test]
+        public async Task WithAuthentication()
+        {
+            FluxClient = FluxClientFactory.Create(new FluxConnectionOptions(MockServerUrl, "my-user", "my-password".ToCharArray()));
+            
+            MockServer.Given(Request.Create()
+                    .WithPath("/ping")
+                    .WithParam("u", new ExactMatcher("my-user"))
+                    .WithParam("p", new ExactMatcher("my-password"))
+                    .UsingGet())
+                .RespondWith(Response.Create().WithStatusCode(204));
+                
+            Assert.IsTrue(await FluxClient.PingAsync());
+        }
     }
 }

Client.Legacy.Test/FluxClientQueryTest.cs

@@ -6,7 +6,9 @@
 using InfluxDB.Client.Core.Exceptions;
 using InfluxDB.Client.Core.Flux.Domain;
 using InfluxDB.Client.Core.Flux.Exceptions;
+using InfluxDB.Client.Flux;
 using NUnit.Framework;
+using WireMock.Matchers;
 using WireMock.RequestBuilders;
 
 namespace Client.Legacy.Test
@@ -195,6 +197,23 @@ public async Task UserAgentHeader()
             StringAssert.EndsWith(".0.0", request.RequestMessage.Headers["User-Agent"].First());
         }
 
+        [Test]
+        public async Task WithAuthentication()
+        {
+            FluxClient = FluxClientFactory.Create(new FluxConnectionOptions(MockServerUrl, "my-user", "my-password".ToCharArray()));
+            
+            MockServer.Given(Request.Create()
+                    .WithPath("/api/v2/query")
+                    .WithParam("u", new ExactMatcher("my-user"))
+                    .WithParam("p", new ExactMatcher("my-password"))
+                    .UsingPost())
+                .RespondWith(CreateResponse());
+                
+            var result = await FluxClient.QueryAsync("from(bucket:\"telegraf\")");
+
+            AssertSuccessResult(result);
+        }
+
         private void AssertSuccessResult(List<FluxTable> tables)
         {
             Assert.IsNotNull(tables);

Client.Legacy/FluxClient.cs

@@ -25,6 +25,11 @@ public FluxClient(FluxConnectionOptions options) : base(new RestClient())
             RestClient.BaseUrl = new Uri(options.Url);
             RestClient.Timeout = options.Timeout.Milliseconds;
             RestClient.AddDefaultHeader("Accept", "application/json");
+            if (!string.IsNullOrEmpty(options.Username))
+            {
+                RestClient.AddDefaultQueryParameter("u", options.Username);
+                RestClient.AddDefaultQueryParameter("p", new string(options.Password));   
+            }
             RestClient.UserAgent = $"influxdb-client-csharp/{version}";
         }
 

Client.Legacy/FluxConnectionOptions.cs

@@ -1,4 +1,3 @@
-
 using System;
 
 namespace InfluxDB.Client.Flux
@@ -8,15 +7,25 @@ public class FluxConnectionOptions
         public string Url { get; private set; }
 
         public TimeSpan Timeout { get; private set; }
-        
+
+        public string Username { get; }
+        public char[] Password { get; }
+
         public FluxConnectionOptions(string url) : this(url, TimeSpan.FromSeconds(60))
         {
         }
 
-        public FluxConnectionOptions(string url, TimeSpan timeout) 
+        public FluxConnectionOptions(string url, string username = "", char[] password = null) : this(url,
+            TimeSpan.FromSeconds(60), username, password)
+        {
+        }
+
+        public FluxConnectionOptions(string url, TimeSpan timeout, string username = "", char[] password = null)
         {
             Url = url;
             Timeout = timeout;
+            Username = username;
+            Password = password;
         }
     }
 }

Client.Legacy/README.md

@@ -14,13 +14,26 @@ The `FluxClientFactory` creates an instance of a `FluxClient` client that can be
 
 - `url` -  the url to connect to InfluxDB 
 - `okHttpClient` - custom HTTP client to use for communications with InfluxDB (optional)
+- `username` - name of your InfluxDB user (optional)
+- `password` - password of your InfluxDB user (optional)
 
 ```c#
 // client creation
 var options = new FluxConnectionOptions("http://127.0.0.1:8086");
 
 var fluxClient = FluxClientFactory.Create(options);
 
+fluxClient.QueryAsync(...)
+...
+```
+#### Authenticate requests
+
+```c#
+// client creation
+var options = new FluxConnectionOptions("http://127.0.0.1:8086", "my-user", "my-password".ToCharArray());
+
+var fluxClient = FluxClientFactory.Create(options);
+
 fluxClient.QueryAsync(...)
 ...
 ```