Code refactoring

RqliteDotnet/IRqliteClient.cs

@@ -17,7 +17,7 @@ public interface IRqliteClient
     /// <param name="level"></param>
     /// <param name="cancellationToken"></param>
     /// <returns></returns>
-    Task<QueryResults> Query(string query, ReadLevel level, CancellationToken cancellationToken);
+    Task<QueryResults?> Query(string query, ReadLevel level, CancellationToken cancellationToken);
 
     /// <summary>
     /// Execute command and return result

RqliteDotnet/IRqliteOrmClient.cs

@@ -0,0 +1,18 @@
+using RqliteDotnet.Dto;
+
+namespace RqliteDotnet;
+
+public interface IRqliteOrmClient : IRqliteClient
+{
+    /// <summary>
+    /// Query Rqlite DB and return result as an instance of T
+    /// </summary>
+    /// <param name="query">Query to execute</param>
+    /// <typeparam name="T">Type of result object</typeparam>
+    /// <returns></returns>
+    Task<List<T>> Query<T>(string query) where T: new();
+
+    Task<List<U>> QueryParams<T, U>(string query, CancellationToken cancellationToken, params T[] qps) 
+        where T: QueryParameter 
+        where U : new();
+}

RqliteDotnet/RqliteClient.cs

@@ -1,12 +1,6 @@
 using RqliteDotnet.Dto;
-using System;
-using System.Collections.Generic;
-using System.Data;
-using System.Linq;
-using System.Net.Http;
 using System.Text;
 using System.Text.Json;
-using System.Threading.Tasks;
 
 namespace RqliteDotnet;
 
@@ -33,7 +27,7 @@ public async Task<string> Ping(CancellationToken cancellationToken = default)
     }
 
     /// <inheritdoc />
-    public async Task<QueryResults> Query(string query, ReadLevel level = ReadLevel.Default, CancellationToken cancellationToken = default)
+    public async Task<QueryResults?> Query(string query, ReadLevel level = ReadLevel.Default, CancellationToken cancellationToken = default)
     {
         var url = UrlBuilder.Build("/db/query?timings", query, level);
 

RqliteDotnet/RqliteOrmClient.cs

@@ -3,37 +3,17 @@
 
 namespace RqliteDotnet;
 
-public interface IRqliteOrmClient : IRqliteClient
-{
-    /// <summary>
-    /// Query Rqlite DB and return result as an instance of T
-    /// </summary>
-    /// <param name="query">Query to execute</param>
-    /// <typeparam name="T">Type of result object</typeparam>
-    /// <returns></returns>
-    Task<List<T>> Query<T>(string query) where T: new();
-
-    Task<List<U>> QueryParams<T, U>(string query, CancellationToken cancellationToken, params T[] qps) 
-        where T: QueryParameter 
-        where U : new();
-}
-
 public class RqliteOrmClient : RqliteClient, IRqliteOrmClient
 {
     public RqliteOrmClient(HttpClient client) : base(client) { }
 
     public RqliteOrmClient(string uri, HttpClient? client = null) : base(uri, client) {}
 
-    /// <summary>
-    /// Query Rqlite DB and return result as an instance of T
-    /// </summary>
-    /// <param name="query">Query to execute</param>
-    /// <typeparam name="T">Type of result object</typeparam>
-    /// <returns></returns>
+    /// <inheritdoc />
     public async Task<List<T>> Query<T>(string query) where T : new()
     {
         var response = await Query(query);
         if (response.Results!.Count > 1)
             throw new DataException("Query returned more than 1 result. At the moment only 1 result supported");
         var res = response.Results[0];
 
@@ -47,8 +27,8 @@
 
             foreach (var prop in typeof(T).GetProperties())
             {
                 var index = res.Columns.FindIndex(c => c.ToLower() == prop.Name.ToLower());
                 var val = GetValue(res.Types[index], res.Values[i][index]);
 
                 prop.SetValue(dto, val);
             }
@@ -78,8 +58,8 @@
 
             foreach (var prop in typeof(U).GetProperties())
             {
                 var index = res.Columns.FindIndex(c => c.ToLower() == prop.Name.ToLower());
                 var val = GetValue(res.Types[index], res.Values[i][index]);
 
                 prop.SetValue(dto, val);
             }