From aac1dd50b61090461cefc0263f065140be4bf50b Mon Sep 17 00:00:00 2001
From: alex <alexander.vrabel@proton.me>
Date: Wed, 8 Jul 2026 21:04:46 +0200
Subject: added ExecuteMulti method and refactored del to work with shards

---
 handlers.go | 27 +++++++++++++++------------
 1 file changed, 15 insertions(+), 12 deletions(-)

(limited to 'handlers.go')

diff --git a/handlers.go b/handlers.go
index 1a04db9..980e805 100644
--- a/handlers.go
+++ b/handlers.go
@@ -74,28 +74,31 @@ func handleSet(conn net.Conn, args []string) {
 
 	conn.Write(serializeRESP(result))
 }
-/*
+
 func handleDel(conn net.Conn, args []string) {
-	db.mu.Lock()
-	defer db.mu.Unlock()
 
 	if len(args) < 2 {
         err := errors.New("wrong number of arguments for 'DEL'")
         conn.Write(serializeRESP(err))
 		return
     }
-
-	deletedKeys := 0
-	for i := 1; i<len(args);i++{
-		_, exists := db.data[args[i]]
-		if exists {
-			delete(db.data, args[i])
-			deletedKeys += 1
-		} 
-	}
+	keys := args[:1]
+	deletedKeys := db.ExecuteMulti(keys, func(shards []*Shard) interface{}{
+		count := 0
+		for _, key := range keys{
+			shard := db.getShard(key)
+					_, exists := shard.data[key]
+			if exists {
+				delete(shard.data, key)
+				count += 1
+			} 
+		}
+		return count
+	})
 	conn.Write(serializeRESP(deletedKeys))
 }
 
+/*
 func handleIncr(conn net.Conn, args []string) {
 	db.mu.Lock()
 	defer db.mu.Unlock()
-- 
cgit v1.2.3