handle ft.profile response processing with "ProfilingInformation"

Author: atakavci

src/NRedisStack/ResponseParser.cs

@@ -685,26 +685,26 @@ public static Dictionary<string, RedisResult> ToStringRedisResultDictionary(this
             return dict;
         }
 
-        public static Tuple<SearchResult, Dictionary<string, RedisResult>> ToProfileSearchResult(this RedisResult result, Query q)
+        public static Tuple<SearchResult, ProfilingInformation> ToProfileSearchResult(this RedisResult result, Query q)
         {
             var results = (RedisResult[])result!;
 
             var searchResult = results[0].ToSearchResult(q);
-            var profile = results[1].ToStringRedisResultDictionary();
-            return new Tuple<SearchResult, Dictionary<string, RedisResult>>(searchResult, profile);
+            var profile = new ProfilingInformation(results[1]);
+            return new Tuple<SearchResult, ProfilingInformation>(searchResult, profile);
         }
 
         public static SearchResult ToSearchResult(this RedisResult result, Query q)
         {
             return new SearchResult((RedisResult[])result!, !q.NoContent, q.WithScores, q.WithPayloads/*, q.ExplainScore*/);
         }
 
-        public static Tuple<AggregationResult, Dictionary<string, RedisResult>> ToProfileAggregateResult(this RedisResult result, AggregationRequest q)
+        public static Tuple<AggregationResult, ProfilingInformation> ToProfileAggregateResult(this RedisResult result, AggregationRequest q)
         {
             var results = (RedisResult[])result!;
             var aggregateResult = results[0].ToAggregationResult(q);
-            var profile = results[1].ToStringRedisResultDictionary();
-            return new Tuple<AggregationResult, Dictionary<string, RedisResult>>(aggregateResult, profile);
+            var profile = new ProfilingInformation(results[1]);
+            return new Tuple<AggregationResult, ProfilingInformation>(aggregateResult, profile);
         }
 
         public static AggregationResult ToAggregationResult(this RedisResult result, AggregationRequest query)

src/NRedisStack/Search/ISearchCommands.cs

@@ -177,7 +177,7 @@ public interface ISearchCommands
         /// <param name="q">The query string.</param>
         /// <param name="limited">Removes details of reader iterator.</param>
         /// <returns></returns>
-        Tuple<SearchResult, Dictionary<string, RedisResult>> ProfileSearch(string indexName, Query q, bool limited = false);
+        Tuple<SearchResult, ProfilingInformation> ProfileSearch(string indexName, Query q, bool limited = false);
 
         /// <summary>
         /// Apply FT.AGGREGATE command to collect performance details.
@@ -186,7 +186,7 @@ public interface ISearchCommands
         /// <param name="query">The query string.</param>
         /// <param name="limited">Removes details of reader iterator.</param>
         /// <returns></returns>
-        Tuple<AggregationResult, Dictionary<string, RedisResult>> ProfileAggregate(string indexName, AggregationRequest query, bool limited = false);
+        Tuple<AggregationResult, ProfilingInformation> ProfileAggregate(string indexName, AggregationRequest query, bool limited = false);
 
         /// <summary>
         /// Search the index

src/NRedisStack/Search/ISearchCommandsAsync.cs

@@ -177,7 +177,7 @@ public interface ISearchCommandsAsync
         /// <param name="q">The query string.</param>
         /// <param name="limited">Removes details of reader iterator.</param>
         /// <returns></returns>
-        Task<Tuple<SearchResult, Dictionary<string, RedisResult>>> ProfileSearchAsync(string indexName, Query q, bool limited = false);
+        Task<Tuple<SearchResult, ProfilingInformation>> ProfileSearchAsync(string indexName, Query q, bool limited = false);
 
 
         /// <summary>
@@ -187,7 +187,7 @@ public interface ISearchCommandsAsync
         /// <param name="query">The query string.</param>
         /// <param name="limited">Removes details of reader iterator.</param>
         /// <returns></returns>
-        Task<Tuple<AggregationResult, Dictionary<string, RedisResult>>> ProfileAggregateAsync(string indexName, AggregationRequest query, bool limited = false);
+        Task<Tuple<AggregationResult, ProfilingInformation>> ProfileAggregateAsync(string indexName, AggregationRequest query, bool limited = false);
 
         /// <summary>
         /// Search the index

src/NRedisStack/Search/ProfilingInformation.cs

@@ -0,0 +1,15 @@
+using StackExchange.Redis;
+
+namespace NRedisStack.Search
+{
+
+    public class ProfilingInformation
+    {
+        public RedisResult Info { get; private set; }
+        public ProfilingInformation(RedisResult info)
+        {
+            this.Info = info;
+        }
+
+    }
+}

src/NRedisStack/Search/SearchCommands.cs

@@ -131,13 +131,13 @@ public InfoResult Info(RedisValue index) =>
         new InfoResult(_db.Execute(SearchCommandBuilder.Info(index)));
 
         /// <inheritdoc/>
-        public Tuple<SearchResult, Dictionary<string, RedisResult>> ProfileSearch(string indexName, Query q, bool limited = false)
+        public Tuple<SearchResult, ProfilingInformation> ProfileSearch(string indexName, Query q, bool limited = false)
         {
             return _db.Execute(SearchCommandBuilder.ProfileSearch(indexName, q, limited))
                             .ToProfileSearchResult(q);
         }
         /// <inheritdoc/>
-        public Tuple<AggregationResult, Dictionary<string, RedisResult>> ProfileAggregate(string indexName, AggregationRequest query, bool limited = false)
+        public Tuple<AggregationResult, ProfilingInformation> ProfileAggregate(string indexName, AggregationRequest query, bool limited = false)
         {
             setDefaultDialectIfUnset(query);
             return _db.Execute(SearchCommandBuilder.ProfileAggregate(indexName, query, limited))

src/NRedisStack/Search/SearchCommandsAsync.cs

@@ -162,13 +162,13 @@ public async Task<InfoResult> InfoAsync(RedisValue index) =>
         new InfoResult(await _db.ExecuteAsync(SearchCommandBuilder.Info(index)));
 
         /// <inheritdoc/>
-        public async Task<Tuple<SearchResult, Dictionary<string, RedisResult>>> ProfileSearchAsync(string indexName, Query q, bool limited = false)
+        public async Task<Tuple<SearchResult, ProfilingInformation>> ProfileSearchAsync(string indexName, Query q, bool limited = false)
         {
             return (await _db.ExecuteAsync(SearchCommandBuilder.ProfileSearch(indexName, q, limited)))
                             .ToProfileSearchResult(q);
         }
         /// <inheritdoc/>
-        public async Task<Tuple<AggregationResult, Dictionary<string, RedisResult>>> ProfileAggregateAsync(string indexName, AggregationRequest query, bool limited = false)
+        public async Task<Tuple<AggregationResult, ProfilingInformation>> ProfileAggregateAsync(string indexName, AggregationRequest query, bool limited = false)
         {
             return (await _db.ExecuteAsync(SearchCommandBuilder.ProfileAggregate(indexName, query, limited)))
                             .ToProfileAggregateResult(query);

tests/NRedisStack.Tests/CustomAssertions.cs

@@ -0,0 +1,20 @@
+using Xunit;
+
+namespace NRedisStack.Tests;
+
+public static class CustomAssertions
+{
+    // Generic method to assert that 'actual' is greater than 'expected'
+    public static void GreaterThan<T>(T actual, T expected) where T : IComparable<T>
+    {
+        Assert.True(actual.CompareTo(expected) > 0, 
+            $"Failure: Expected value to be greater than {expected}, but found {actual}.");
+    }
+
+    // Generic method to assert that 'actual' is less than 'expected'
+    public static void LessThan<T>(T actual, T expected) where T : IComparable<T>
+    {
+        Assert.True(actual.CompareTo(expected) < 0, 
+            $"Failure: Expected value to be less than {expected}, but found {actual}.");
+    }
+}