port FLUSHDB command to IronHawk

internal/cmd/cmd_flushdb.go

@@ -0,0 +1,41 @@
+package cmd
+
+import (
+	"github.com/dicedb/dice/internal/store"
+	dstore "github.com/dicedb/dice/internal/store"
+)
+
+const (
+	SYNC  string = "sync"
+	ASYNC string = "async"
+)
+
+var cFLUSHDB = &DiceDBCommand{
+	Name:      "FLUSHDB",
+	HelpShort: "FLUSHDB deletes all keys.",
+	Eval:      evalFLUSHDB,
+}
+
+func init() {
+	commandRegistry.AddCommand(cFLUSHDB)
+}
+
+// FLUSHDB deletes all keys.
+// The function expects no arguments
+//
+// Parameters:
+//   - c *Cmd: The command context containing the arguments
+//   - s *dstore.Store: The data store instance
+//
+// Returns:
+//   - *CmdRes: OK or nil
+//   - error: Error if wrong number of arguments
+func evalFLUSHDB(c *Cmd, s *dstore.Store) (*CmdRes, error) {
+	if len(c.C.Args) != 0 {
+		return cmdResNil, errWrongArgumentCount("FLUSHDB")
+	}
+
+	store.Reset(s)
+
+	return cmdResOK, nil
+}

internal/eval/commands.go

@@ -1379,7 +1379,7 @@ func init() {
 	DiceCmds["EXPIRE"] = expireCmdMeta
 	DiceCmds["EXPIREAT"] = expireatCmdMeta
 	DiceCmds["EXPIRETIME"] = expiretimeCmdMeta
-	DiceCmds["FLUSHDB"] = flushdbCmdMeta
+	DiceCmds["FLUSHDB"] = flushdbCmdMeta // moved to ironhawk
 	DiceCmds["GEOADD"] = geoAddCmdMeta
 	DiceCmds["GEODIST"] = geoDistCmdMeta
 	DiceCmds["GEOPOS"] = geoPosCmdMeta

internal/eval/eval_test.go

@@ -47,7 +47,7 @@ type evalMultiShardTestCase struct {
 }
 
 func setupTest(store *dstore.Store) *dstore.Store {
-	dstore.ResetStore(store)
+	dstore.Reset(store)
 	return store
 }
 
@@ -7576,7 +7576,7 @@ func BenchmarkEvalZPOPMIN(b *testing.B) {
 
 			for i := 0; i < b.N; i++ {
 				// Reset the store before each run to avoid contamination
-				dstore.ResetStore(store)
+				dstore.Reset(store)
 				bm.setup(store)
 				evalZPOPMIN(bm.input, store)
 			}
@@ -8649,7 +8649,7 @@ func BenchmarkEvalZPOPMAX(b *testing.B) {
 
 			for i := 0; i < b.N; i++ {
 				// Reset the store before each run to avoid contamination
-				dstore.ResetStore(store)
+				dstore.Reset(store)
 				bm.setup(store)
 				evalZPOPMAX(bm.input, store)
 			}

internal/store/store.go

@@ -71,7 +71,7 @@ func NewStore(cmdWatchChan chan CmdWatchEvent, evictionStrategy EvictionStrategy
 	return store
 }
 
-func ResetStore(store *Store) *Store {
+func Reset(store *Store) *Store {
 	store.numKeys = 0
 	store.store = NewStoreMap()
 	store.expires = NewExpireMap()