Merge pull request #3 from shacharPash/AddModuls

Add basic command in each module & Arrange the files in folders

Author: shacharPash

src/NRedisStack.Core/Bloom/RedisBloomCommands.cs

@@ -0,0 +1,24 @@
+namespace NRedisStack.Core.RedisStackCommands
+{
+    public static class TS
+    {
+        
+        //TODO: INFO, CREATE, ALTER
+        /*public static string CREATE => "TS.CREATE";
+        public static string ALTER => "TS.ALTER";
+        public static string ADD => "TS.ADD";
+        public static string MADD => "TS.MADD";
+        public static string INCRBY => "TS.INCRBY";
+        public static string DECRBY => "TS.DECRBY";
+        public static string CREATERULE => "TS.CREATERULE";
+        public static string DELETERULE => "TS.DELETERULE";
+        public static string RANGE => "TS.RANGE";
+        public static string REVRANGE => "TS.REVRANGE";
+        public static string MRANGE => "TS.MRANGE";
+        public static string MREVRANGE => "TS.MREVRANGE";
+        public static string GET => "TS.GET";
+        public static string MGET => "TS.MGET";
+        public static string INFO => "TS.INFO";
+        public static string QUERYINDEX => "TS.QUERYINDEX";*/
+    }
+}

src/NRedisStack.Core/RedisStackCommands/ TimeSeries.cs

@@ -0,0 +1,24 @@
+using StackExchange.Redis;
+namespace NRedisStack.Core.RedisStackCommands
+{
+    public static class RedisBloomCommands
+    {
+        public static RedisResult BfAdd(this IDatabase db, RedisKey key, string item)
+        {
+            return db.Execute("BF.ADD", key, item);
+        }
+        public static RedisResult BfExists(this IDatabase db, RedisKey key, string item)
+        {
+            return db.Execute("BF.EXISTS", key, item);
+        }
+        /*public static string ADD => "BF.ADD";
+        public static string EXISTS => "BF.EXISTS";
+        public static string INFO => "BF.INFO";
+        public static string INSERT => "BF.INSERT";
+        public static string LOADCHUNK => "BF.LOADCHUNK";
+        public static string MADD => "BF.MADD";
+        public static string MEXISTS => "BF.MEXISTS";
+        public static string RESERVE => "BF.RESERVE";
+        public static string SCANDUMP => "BF.SCANDUMP";*/
+    }
+}

src/NRedisStack.Core/RedisStackCommands/Bloom.cs

@@ -1,9 +1,10 @@
 using StackExchange.Redis;
 using System.Text.Json;
 using System.Text.Json.Serialization;
+
 namespace NRedisStack.Core.Json;
 
-public static class RedisJsonCommands
+public static class JSON
 {
     private static readonly JsonSerializerOptions Options = new()
     {
@@ -17,7 +18,7 @@ public static RedisResult JsonSet(this IDatabase db, RedisKey key, string path,
 
     public static RedisResult JsonSet(this IDatabase db, RedisKey key, string path, string json, When when = When.Always)
     {
-        switch(when)
+        switch (when)
         {
             case When.Exists:
                 return db.Execute("JSON.SET", key, path, json, "XX");
@@ -28,8 +29,33 @@ public static RedisResult JsonSet(this IDatabase db, RedisKey key, string path,
         }
     }
 
-    public static RedisResult JsonGet(this IDatabase db, RedisKey key)
+    public static RedisResult JsonGet(this IDatabase db, RedisKey key, string indent = "",
+                                      string newLine = "", string space = "", string path = "")
     {
-        return db.Execute("JSON.GET", key);
+        List<object> subcommands = new List<object>();
+        subcommands.Add(key);
+        if (indent != "")
+        {
+            subcommands.Add("INDENT");
+            subcommands.Add(indent);
+        }
+
+        if (newLine != "")
+        {
+            subcommands.Add("NEWLINE");
+            subcommands.Add(newLine);
+        }
+
+        if (space != "")
+        {
+            subcommands.Add("SPACE");
+            subcommands.Add(space);
+        }
+
+        if (path != "")
+        {
+            subcommands.Add(path);
+        }
+        return db.Execute("JSON.GET", subcommands.ToArray());
     }
 }

src/NRedisStack.Core/Json/RedisJsonCommands.cs renamed to src/NRedisStack.Core/RedisStackCommands/Json.cs

@@ -0,0 +1,11 @@
+using StackExchange.Redis;
+namespace NRedisStack.Core.Search
+{
+    public static class FT
+    {
+        public static RedisResult FtInfo(this IDatabase db, string index)
+        {
+            return db.Execute("FT.INFO", index);
+        }
+    }
+}

src/NRedisStack.Core/RedisStackCommands/Search.cs

@@ -0,0 +1,45 @@
+using Xunit;
+using System;
+using System.Collections.Generic;
+using StackExchange.Redis;
+using System.Linq;
+using System.IO;
+using NRedisStack.Core;
+using NRedisStack.Core.RedisStackCommands;
+using Moq;
+
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+
+namespace NRedisStack.Tests.Bloom;
+
+public class BloomTests : AbstractNRedisStackTest, IDisposable
+{
+    Mock<IDatabase> _mock = new Mock<IDatabase>();
+    private readonly string key = "BLOOM_TESTS";
+    public BloomTests(RedisFixture redisFixture) : base(redisFixture) { }
+
+    public void Dispose()
+    {
+        redisFixture.Redis.GetDatabase().KeyDelete(key);
+    }
+
+    [Fact]
+    public void TestBfAddWhenExist()
+    {
+        IDatabase db = redisFixture.Redis.GetDatabase();
+
+        Assert.True(db.BfAdd(key, "item1").ToString() == "1"); // first time
+        Assert.True(db.BfAdd(key, "item1").ToString() == "0"); // second time
+    }
+
+    [Fact]
+    public void TestBfAddExists()
+    {
+        IDatabase db = redisFixture.Redis.GetDatabase();
+
+        db.BfAdd(key, "item1");
+        Assert.True(db.BfExists(key, "item1").ToString() == "1");
+    }
+}

src/NRedisStack.Core/Search/RedisSearchCommands.cs

@@ -25,12 +25,6 @@ public void Dispose()
         redisFixture.Redis.GetDatabase().KeyDelete(key);
     }
 
-    public class Person
-    {
-        public string Name { get; set; }
-        public int Age { get; set; }
-    }
-
     [Fact]
     public void TestJsonSet()
     {
@@ -48,7 +42,7 @@ public void TestJsonSetNotExist()
     }
 
     [Fact]
-    public void TestJsonGet()
+    public void TestSimpleJsonGet()
     {
         var obj = new Person { Name = "Shachar", Age = 23 };
         IDatabase db = redisFixture.Redis.GetDatabase();
@@ -57,4 +51,16 @@ public void TestJsonGet()
         string expected = "{\"Name\":\"Shachar\",\"Age\":23}";
         Assert.Equal(db.JsonGet(key).ToString(), expected);
     }
+
+    [Fact]
+    public void TestJsonGet()
+    {
+        var obj = new Person { Name = "Shachar", Age = 23 };
+        IDatabase db = redisFixture.Redis.GetDatabase();
+
+        db.JsonSet(key, "$", obj);
+
+        string expected = "[222111\"Shachar\"222]";
+        Assert.Equal(db.JsonGet(key, "111", "222", "333", "$.Name").ToString(), expected);
+    }
 }

src/NRedisStack.Core/TimeSeries/TimeSeriesCommands.cs

@@ -0,0 +1,8 @@
+namespace NRedisStack.Tests
+{
+    public class Person
+    {
+        public string Name { get; set; }
+        public int Age { get; set; }
+    }
+}