[Compatibility] Added BZMPOP, BZPOPMAX and BZPOPMIN commands

libs/resources/RespCommandsDocs.json

@@ -773,6 +773,110 @@
       }
     ]
   },
+  {
+    "Command": "BZMPOP",
+    "Name": "BZMPOP",
+    "Summary": "Removes and returns a member by score from one or more sorted sets. Blocks until a member is available otherwise. Deletes the sorted set if the last element was popped.",
+    "Group": "SortedSet",
+    "Complexity": "O(K) \u002B O(M*log(N)) where K is the number of provided keys, N being the number of elements in the sorted set, and M being the number of elements popped.",
+    "Arguments": [
+      {
+        "TypeDiscriminator": "RespCommandBasicArgument",
+        "Name": "TIMEOUT",
+        "DisplayText": "timeout",
+        "Type": "Double"
+      },
+      {
+        "TypeDiscriminator": "RespCommandBasicArgument",
+        "Name": "NUMKEYS",
+        "DisplayText": "numkeys",
+        "Type": "Integer"
+      },
+      {
+        "TypeDiscriminator": "RespCommandKeyArgument",
+        "Name": "KEY",
+        "DisplayText": "key",
+        "Type": "Key",
+        "ArgumentFlags": "Multiple",
+        "KeySpecIndex": 0
+      },
+      {
+        "TypeDiscriminator": "RespCommandContainerArgument",
+        "Name": "WHERE",
+        "Type": "OneOf",
+        "Arguments": [
+          {
+            "TypeDiscriminator": "RespCommandBasicArgument",
+            "Name": "MIN",
+            "DisplayText": "min",
+            "Type": "PureToken",
+            "Token": "MIN"
+          },
+          {
+            "TypeDiscriminator": "RespCommandBasicArgument",
+            "Name": "MAX",
+            "DisplayText": "max",
+            "Type": "PureToken",
+            "Token": "MAX"
+          }
+        ]
+      },
+      {
+        "TypeDiscriminator": "RespCommandBasicArgument",
+        "Name": "COUNT",
+        "DisplayText": "count",
+        "Type": "Integer",
+        "Token": "COUNT",
+        "ArgumentFlags": "Optional"
+      }
+    ]
+  },
+  {
+    "Command": "BZPOPMAX",
+    "Name": "BZPOPMAX",
+    "Summary": "Removes and returns the member with the highest score from one or more sorted sets. Blocks until a member available otherwise.  Deletes the sorted set if the last element was popped.",
+    "Group": "SortedSet",
+    "Complexity": "O(log(N)) with N being the number of elements in the sorted set.",
+    "Arguments": [
+      {
+        "TypeDiscriminator": "RespCommandKeyArgument",
+        "Name": "KEY",
+        "DisplayText": "key",
+        "Type": "Key",
+        "ArgumentFlags": "Multiple",
+        "KeySpecIndex": 0
+      },
+      {
+        "TypeDiscriminator": "RespCommandBasicArgument",
+        "Name": "TIMEOUT",
+        "DisplayText": "timeout",
+        "Type": "Double"
+      }
+    ]
+  },
+  {
+    "Command": "BZPOPMIN",
+    "Name": "BZPOPMIN",
+    "Summary": "Removes and returns the member with the lowest score from one or more sorted sets. Blocks until a member is available otherwise. Deletes the sorted set if the last element was popped.",
+    "Group": "SortedSet",
+    "Complexity": "O(log(N)) with N being the number of elements in the sorted set.",
+    "Arguments": [
+      {
+        "TypeDiscriminator": "RespCommandKeyArgument",
+        "Name": "KEY",
+        "DisplayText": "key",
+        "Type": "Key",
+        "ArgumentFlags": "Multiple",
+        "KeySpecIndex": 0
+      },
+      {
+        "TypeDiscriminator": "RespCommandBasicArgument",
+        "Name": "TIMEOUT",
+        "DisplayText": "timeout",
+        "Type": "Double"
+      }
+    ]
+  },
   {
     "Command": "CLIENT",
     "Name": "CLIENT",

libs/resources/RespCommandsInfo.json

@@ -415,6 +415,78 @@
       }
     ]
   },
+  {
+    "Command": "BZMPOP",
+    "Name": "BZMPOP",
+    "Arity": -5,
+    "Flags": "Blocking, MovableKeys, Write",
+    "AclCategories": "Blocking, SortedSet, Slow, Write",
+    "KeySpecifications": [
+      {
+        "BeginSearch": {
+          "TypeDiscriminator": "BeginSearchIndex",
+          "Index": 2
+        },
+        "FindKeys": {
+          "TypeDiscriminator": "FindKeysKeyNum",
+          "KeyNumIdx": 0,
+          "FirstKey": 1,
+          "KeyStep": 1
+        },
+        "Flags": "RW, Access, Delete"
+      }
+    ]
+  },
+  {
+    "Command": "BZPOPMAX",
+    "Name": "BZPOPMAX",
+    "Arity": -3,
+    "Flags": "Blocking, Fast, Write",
+    "FirstKey": 1,
+    "LastKey": -2,
+    "Step": 1,
+    "AclCategories": "Blocking, Fast, SortedSet, Write",
+    "KeySpecifications": [
+      {
+        "BeginSearch": {
+          "TypeDiscriminator": "BeginSearchIndex",
+          "Index": 1
+        },
+        "FindKeys": {
+          "TypeDiscriminator": "FindKeysRange",
+          "LastKey": -2,
+          "KeyStep": 1,
+          "Limit": 0
+        },
+        "Flags": "RW, Access, Delete"
+      }
+    ]
+  },
+  {
+    "Command": "BZPOPMIN",
+    "Name": "BZPOPMIN",
+    "Arity": -3,
+    "Flags": "Blocking, Fast, Write",
+    "FirstKey": 1,
+    "LastKey": -2,
+    "Step": 1,
+    "AclCategories": "Blocking, Fast, SortedSet, Write",
+    "KeySpecifications": [
+      {
+        "BeginSearch": {
+          "TypeDiscriminator": "BeginSearchIndex",
+          "Index": 1
+        },
+        "FindKeys": {
+          "TypeDiscriminator": "FindKeysRange",
+          "LastKey": -2,
+          "KeyStep": 1,
+          "Limit": 0
+        },
+        "Flags": "RW, Access, Delete"
+      }
+    ]
+  },
   {
     "Command": "CLIENT",
     "Name": "CLIENT",

libs/server/Objects/ItemBroker/CollectionItemBroker.cs

@@ -383,37 +383,44 @@ private static bool TryMoveNextListItem(ListObject srcListObj, ListObject dstLis
         }
 
         /// <summary>
-        /// Try to get next available item from sorted set object
+        /// Try to get next available item from sorted set object based on command type
+        /// BZPOPMIN and BZPOPMAX share same implementation since Dictionary.First() and Last() 
+        /// handle the ordering automatically based on sorted set scores
         /// </summary>
-        /// <param name="sortedSetObj">Sorted set object</param>
-        /// <param name="command">RESP command</param>
-        /// <param name="nextItem">Item retrieved</param>
-        /// <returns>True if found available item</returns>
-        private static bool TryGetNextSetObject(SortedSetObject sortedSetObj, RespCommand command, out byte[] nextItem)
+        private static unsafe bool TryGetNextSetObjects(byte[] key, SortedSetObject sortedSetObj, RespCommand command, ArgSlice[] cmdArgs, out CollectionItemResult result)
         {
-            nextItem = default;
+            result = default;
 
-            // If object has no items, return
             if (sortedSetObj.Dictionary.Count == 0) return false;
 
-            // Get the next object according to operation type
             switch (command)
             {
+                case RespCommand.BZPOPMIN:
+                case RespCommand.BZPOPMAX:
+                    var element = sortedSetObj.Pop(command == RespCommand.BZPOPMAX);
+                    result = new CollectionItemResult(key, [element]);
+                    return true;
+
+                case RespCommand.BZMPOP:
+                    var lowScoresFirst = *(bool*)cmdArgs[0].ptr;
+                    var popCount = *(int*)cmdArgs[1].ptr;
+                    popCount = Math.Min(popCount, sortedSetObj.Dictionary.Count);
+
+                    var scoredItems = new (double Score, byte[] Element)[popCount];
+
+                    for (int i = 0; i < popCount; i++)
+                    {
+                        scoredItems[i] = sortedSetObj.Pop(!lowScoresFirst);
+                    }
+
+                    result = new CollectionItemResult(key, scoredItems);
+                    return true;
+
                 default:
                     return false;
             }
         }
 
-        /// <summary>
-        /// Try to get next available item from object
-        /// </summary>
-        /// <param name="key">Key of object</param>
-        /// <param name="storageSession">Current storage session</param>
-        /// <param name="command">RESP command</param>
-        /// <param name="cmdArgs">Additional command arguments</param>
-        /// <param name="currCount">Collection size</param>
-        /// <param name="result">Result of command</param>
-        /// <returns>True if found available item</returns>
         private unsafe bool TryGetResult(byte[] key, StorageSession storageSession, RespCommand command, ArgSlice[] cmdArgs, out int currCount, out CollectionItemResult result)
         {
             currCount = default;
@@ -423,6 +430,7 @@ private unsafe bool TryGetResult(byte[] key, StorageSession storageSession, Resp
             var objectType = command switch
             {
                 RespCommand.BLPOP or RespCommand.BRPOP or RespCommand.BLMOVE or RespCommand.BLMPOP => GarnetObjectType.List,
+                RespCommand.BZPOPMIN or RespCommand.BZPOPMAX or RespCommand.BZMPOP => GarnetObjectType.SortedSet,
                 _ => throw new NotSupportedException()
             };
 
@@ -524,11 +532,13 @@ private unsafe bool TryGetResult(byte[] key, StorageSession storageSession, Resp
                         }
                     case SortedSetObject setObj:
                         currCount = setObj.Dictionary.Count;
-                        if (objectType != GarnetObjectType.SortedSet) return false;
+                        if (objectType != GarnetObjectType.SortedSet)
+                            return false;
+                        if (currCount == 0)
+                            return false;
+
+                        return TryGetNextSetObjects(key, setObj, command, cmdArgs, out result);
 
-                        var hasValue = TryGetNextSetObject(setObj, command, out var sortedSetNextItem);
-                        result = new CollectionItemResult(key, sortedSetNextItem);
-                        return hasValue;
                     default:
                         return false;
                 }

libs/server/Objects/ItemBroker/CollectionItemResult.cs

@@ -20,6 +20,12 @@ public CollectionItemResult(byte[] key, byte[][] items)
             Items = items;
         }
 
+        public CollectionItemResult(byte[] key, (double Score, byte[] Element)[] scoredItems)
+        {
+            Key = key;
+            ScoredItems = scoredItems;
+        }
+
         /// <summary>
         /// True if item was found
         /// </summary>
@@ -40,6 +46,11 @@ public CollectionItemResult(byte[] key, byte[][] items)
         /// </summary>
         internal byte[][] Items { get; }
 
+        /// <summary>
+        /// Scored items retrieved from collection, where each item has an associated score.
+        /// </summary>
+        internal (double Score, byte[] Element)[] ScoredItems { get; }
+
         /// <summary>
         /// Instance of empty result
         /// </summary>

libs/server/Objects/SortedSet/SortedSetObjectImpl.cs

@@ -6,6 +6,7 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
+using System.Runtime.Intrinsics.X86;
 using System.Text;
 using Garnet.common;
 using Tsavorite.core;
@@ -886,6 +887,19 @@ private void SortedSetRank(ref ObjectInput input, ref SpanByteAndMemory output,
             }
         }
 
+        public (double Score, byte[] Element) Pop(bool popMaxScoreElement = false)
+        {
+            if (sortedSet.Count == 0)
+                return default;
+
+            var element = popMaxScoreElement ? sortedSet.Max : sortedSet.Min;
+            sortedSet.Remove(element);
+            sortedSetDict.Remove(element.Element);
+            this.UpdateSize(element.Element, false);
+
+            return element;
+        }
+
         /// <summary>
         /// Removes and returns up to COUNT members with the low or high score
         /// </summary>