Add read level support for queries and unit tests

RqliteDotnet.Test/UrlBuilderTests.cs

@@ -0,0 +1,28 @@
+using NUnit.Framework;
+
+namespace RqliteDotnet.Test;
+
+public class UrlBuilderTests
+{
+    [Test]
+    public void UrlBuilder_BuildsCorrectUrl()
+    {
+        var query = "select * from foo";
+        var baseUrl = "/db/query?timings";
+        var url = UrlBuilder.Build(baseUrl, query, ReadLevel.Default);
+
+        Assert.That(url.StartsWith(baseUrl));
+        Assert.That(url, Is.EqualTo("/db/query?timings&q=select%20%2A%20from%20foo"));
+    }
+
+    [Test]
+    public void UrlBuilder_BuildsCorrectUrlWithReadLevel()
+    {
+        var query = "select * from foo";
+        var baseUrl = "/db/query?timings";
+        var url = UrlBuilder.Build(baseUrl, query, ReadLevel.Strong);
+
+        Assert.That(url.StartsWith(baseUrl));
+        Assert.That(url, Is.EqualTo("/db/query?timings&q=select%20%2A%20from%20foo&level=strong"));
+    }
+}

RqliteDotnet/IRqliteClient.cs

@@ -14,9 +14,10 @@ public interface IRqliteClient
     /// Query DB and return result
     /// </summary>
     /// <param name="query">Query to run</param>
+    /// <param name="level"></param>
     /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    Task<QueryResults> Query(string query, CancellationToken cancellationToken);
+    Task<QueryResults> Query(string query, ReadLevel level, CancellationToken cancellationToken);
 
     /// <summary>
     /// Execute command and return result

RqliteDotnet/ReadLevel.cs

@@ -0,0 +1,11 @@
+namespace RqliteDotnet;
+
+public enum ReadLevel
+{
+    Default = 1,
+    Weak,
+    Linearizable,
+    Strong,
+    None,
+    Auto
+}

RqliteDotnet/RqliteClient.cs

@@ -33,16 +33,15 @@
     }
 
     /// <inheritdoc />
-    public async Task<QueryResults> Query(string query, CancellationToken cancellationToken = default)
+    public async Task<QueryResults> Query(string query, ReadLevel level = ReadLevel.Default, CancellationToken cancellationToken = default)
     {
-        var data = "&q=" + Uri.EscapeDataString(query);
-        var baseUrl = "/db/query?timings";
+        var url = UrlBuilder.Build("/db/query?timings", query, level);
 
-        var r = await _httpClient.GetAsync($"{baseUrl}&{data}", cancellationToken);
+        var r = await _httpClient.GetAsync(url, cancellationToken);
         var str = await r.Content.ReadAsStringAsync(cancellationToken);
 
         var result = JsonSerializer.Deserialize<QueryResults>(str, new JsonSerializerOptions() { PropertyNameCaseInsensitive = true });
         return result;
     }
 
     /// <inheritdoc />

RqliteDotnet/UrlBuilder.cs

@@ -0,0 +1,26 @@
+namespace RqliteDotnet;
+
+public static class UrlBuilder
+{
+    public static string Build(string baseUrl, string query, ReadLevel level)
+    {
+        var data = "&q=" + Uri.EscapeDataString(query);
+        var readLevelParam = GetReadLevel(level);
+
+        return $"{baseUrl}{data}{readLevelParam}";
+    }
+
+    private static string GetReadLevel(ReadLevel level)
+    {
+        var result = level switch
+        {
+            ReadLevel.Default => "",
+            ReadLevel.Weak => "&level=weak",
+            ReadLevel.Linearizable => "&level=linearizable",
+            ReadLevel.Strong => "&level=strong",
+            ReadLevel.None => "&level=none",
+            ReadLevel.Auto => "&level=auto"
+        };
+        return result;
+    }
+}