Typo in command fix

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "deno.enable": true
+}

scripts/all_commands.txt → examples/all_commands.txt

@@ -25,8 +25,6 @@ SMEMBERS myset   # returns x,z
 KEYS
 INFO
 FLUSHDB
-KEYS
-INFO
 
 # Ping
 PING

examples/crud_demo.go

@@ -0,0 +1,58 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"net"
+	"strings"
+)
+
+func sendCommand(conn net.Conn, cmd string) string {
+	fmt.Fprintf(conn, "%s\n", cmd)
+	reader := bufio.NewReader(conn)
+	resp, _ := reader.ReadString('\n')
+	return strings.TrimSpace(resp)
+}
+
+func main() {
+	conn, err := net.Dial("tcp", "127.0.0.1:7070")
+	if err != nil {
+		fmt.Println("Error connecting:", err)
+		return
+	}
+	defer conn.Close()
+
+	fmt.Println("Connected to FurrDB")
+
+	// CREATE
+	fmt.Println("[CREATE] Set user:1 name and email")
+	fmt.Println(sendCommand(conn, "SET user:1:name Alice"))
+	fmt.Println(sendCommand(conn, "SET user:1:email alice@example.com"))
+
+	// READ
+	fmt.Println("\n[READ] Get user:1 name and email")
+	fmt.Println("Name:", sendCommand(conn, "GET user:1:name"))
+	fmt.Println("Email:", sendCommand(conn, "GET user:1:email"))
+
+	// UPDATE
+	fmt.Println("\n[UPDATE] Update user:1 name")
+	fmt.Println(sendCommand(conn, "SET user:1:name Alicia"))
+	fmt.Println("Updated Name:", sendCommand(conn, "GET user:1:name"))
+
+	// EXISTS
+	fmt.Println("\n[EXISTS] Check if user:1:email exists")
+	fmt.Println("Exists:", sendCommand(conn, "EXISTS user:1:email"))
+
+	// DELETE
+	fmt.Println("\n[DELETE] Delete user:1:email")
+	fmt.Println(sendCommand(conn, "DEL user:1:email"))
+	fmt.Println("Email after delete:", sendCommand(conn, "GET user:1:email"))
+
+	// KEYS
+	fmt.Println("\n[KEYS] List all keys")
+	fmt.Println(sendCommand(conn, "KEYS"))
+
+	// EXIT
+	sendCommand(conn, "EXIT")
+	fmt.Println("\nConnection closed")
+}

examples/crud_demo.py

@@ -0,0 +1,49 @@
+import socket
+
+HOST = '127.0.0.1'
+PORT = 7070
+
+def send_command(sock, cmd):
+    sock.sendall((cmd + '\n').encode())
+    resp = b''
+    while not resp.endswith(b'\n'):
+        chunk = sock.recv(4096)
+        if not chunk:
+            break
+        resp += chunk
+    return resp.decode().strip()
+
+with socket.create_connection((HOST, PORT)) as s:
+    print('Connected to FurrDB\n')
+
+    # CREATE
+    print('[CREATE] Set user:1 name and email')
+    print(send_command(s, 'SET user:1:name Alice'))
+    print(send_command(s, 'SET user:1:email alice@example.com'))
+
+    # READ
+    print('\n[READ] Get user:1 name and email')
+    print('Name:', send_command(s, 'GET user:1:name'))
+    print('Email:', send_command(s, 'GET user:1:email'))
+
+    # UPDATE
+    print('\n[UPDATE] Update user:1 name')
+    print(send_command(s, 'SET user:1:name Alicia'))
+    print('Updated Name:', send_command(s, 'GET user:1:name'))
+
+    # EXISTS
+    print('\n[EXISTS] Check if user:1:email exists')
+    print('Exists:', send_command(s, 'EXISTS user:1:email'))
+
+    # DELETE
+    print('\n[DELETE] Delete user:1:email')
+    print(send_command(s, 'DEL user:1:email'))
+    print('Email after delete:', send_command(s, 'GET user:1:email'))
+
+    # KEYS
+    print('\n[KEYS] List all keys')
+    print(send_command(s, 'KEYS'))
+
+    # EXIT
+    send_command(s, 'EXIT')
+    print('\nConnection closed')

examples/crud_demo.ts

@@ -0,0 +1,59 @@
+// FurrDB CRUD Demo (Deno TypeScript)
+// Demonstrates basic CRUD operations for a user profile
+
+const HOST = "127.0.0.1";
+const PORT = 7070;
+
+// Helper to send a command and receive a response
+async function sendCommand(conn: Deno.Conn, cmd: string): Promise<string> {
+  const encoder = new TextEncoder();
+  const decoder = new TextDecoder();
+  await conn.write(encoder.encode(cmd + "\n"));
+  let resp = "";
+  while (!resp.endsWith("\n")) {
+    const buf = new Uint8Array(1024);
+    const n = await conn.read(buf);
+    if (n === null) break;
+    resp += decoder.decode(buf.subarray(0, n));
+  }
+  return resp.trim();
+}
+
+// Main demo logic
+const conn = await Deno.connect({ hostname: HOST, port: PORT });
+console.log("Connected to FurrDB\n");
+
+// Create (SET user:1 name and email)
+console.log("[CREATE] Set user:1 name and email");
+console.log(await sendCommand(conn, 'SET user:1:name Alice'));
+console.log(await sendCommand(conn, 'SET user:1:email alice@example.com'));
+
+// Read (GET user:1 name and email)
+console.log("\n[READ] Get user:1 name and email");
+console.log('Name:', await sendCommand(conn, 'GET user:1:name'));
+console.log('Email:', await sendCommand(conn, 'GET user:1:email'));
+
+// Update (SET user:1 name)
+console.log("\n[UPDATE] Update user:1 name");
+console.log(await sendCommand(conn, 'SET user:1:name Alicia'));
+console.log('Updated Name:', await sendCommand(conn, 'GET user:1:name'));
+
+// Exists
+console.log("\n[EXISTS] Check if user:1:email exists");
+console.log('Exists:', await sendCommand(conn, 'EXISTS user:1:email'));
+
+// Delete (DEL user:1 email)
+console.log("\n[DELETE] Delete user:1:email");
+console.log(await sendCommand(conn, 'DEL user:1:email'));
+console.log('Email after delete:', await sendCommand(conn, 'GET user:1:email'));
+
+// List all keys
+console.log("\n[KEYS] List all keys");
+console.log(await sendCommand(conn, 'KEYS'));
+
+// Exit
+await sendCommand(conn, 'EXIT');
+conn.close();
+console.log("\nConnection closed");
+
+export {};

internal/db/db.go

@@ -13,19 +13,19 @@
 type valueType int
 
 const (
 	StringType valueType = iota
 	ListType
 	SetType
 )
 
 type Store struct {
 	mu    sync.RWMutex
 	data  map[string]any
 	types map[string]valueType
 	ttl   map[string]int64 // key -> unix expiration, 0 means no expiry
 }
 
 func NewStore() *Store {
 	store := &Store{
 		data:  make(map[string]any),
 		types: make(map[string]valueType),
@@ -35,11 +35,11 @@
 	return store
 }
 
 var DefaultStore = NewStore()
 
 type HandlerFunc func(args []string) (string, error)
 
 var Commands = map[string]HandlerFunc{
 	"SET":      setHandler,
 	"GET":      getHandler,
 	"DEL":      delHandler,
@@ -57,7 +57,7 @@
 	"INFO":     infoHandler,
 	"EXPIRE":   expireHandler,
 	"TTL":      ttlHandler,
-	"SNAPSHOT": snapshotHandler,
+	"SAVE":     snapshotHandler,
 }
 
 func (s *Store) ttlCleaner() {
@@ -400,7 +400,7 @@
 	return fmt.Sprintf("%d", rem), nil
 }
 
 func SaveSnapshot(filename string) error {
 	DefaultStore.mu.RLock()
 	defer DefaultStore.mu.RUnlock()
 	f, err := os.Create(filename)
@@ -416,7 +416,7 @@
 	}{DefaultStore.data, DefaultStore.types, DefaultStore.ttl})
 }
 
 func LoadSnapshot(filename string) error {
 	f, err := os.Open(filename)
 	if err != nil {
 		return err

internal/db/db_test.go

@@ -7,6 +7,10 @@
 	"time"
 )
 
+const (
+	TEST_FILE = "test_dump.rdb"
+)
+
 func TestStoreBasicOps(t *testing.T) {
 	db := NewStore()
 	db.mu.Lock()
@@ -127,7 +131,7 @@
 	_, _ = saddHandler([]string{"snapset", "a", "b"})
 	_, _ = expireHandler([]string{"snapkey", "10"})
 
-	err := SaveSnapshot("test_dump.rdb")
+	err := SaveSnapshot(TEST_FILE)
 	if err != nil {
 		t.Fatalf("SaveSnapshot failed: %v", err)
 	}
@@ -139,7 +143,7 @@
 		t.Errorf("expected empty after clear, got %s", val)
 	}
 
-	err = LoadSnapshot("test_dump.rdb")
+	err = LoadSnapshot(TEST_FILE)
 	if err != nil {
 		t.Fatalf("LoadSnapshot failed: %v", err)
 	}
@@ -151,5 +155,5 @@
 	if !(strings.Contains(members, "a") && strings.Contains(members, "b")) {
 		t.Errorf("expected set members a and b, got %s", members)
 	}
-	_ = os.Remove("test_dump.rdb")
+	_ = os.Remove(TEST_FILE)
 }

internal/engine/test_aof.log

@@ -9,3 +9,7 @@ SET testkey testval
 SET testkey testval
 SET testkey testval
 SET testkey testval
+SET testkey testval
+SET testkey testval
+SET testkey testval
+SET testkey testval

internal/handlers/script_handlers.go

@@ -30,7 +30,7 @@ func evalHandler(args []string) (string, error) {
 		return "", fmt.Errorf("missing argument for EVAL")
 	}
 	scriptStr := strings.Join(args, " ")
-	return script.EvalScript(scriptStr, nil)
+	return script.EvalScript(scriptStr)
 }
 
 func init() {

internal/repl/repl.go

@@ -4,13 +4,12 @@
 	"bufio"
 	"fmt"
 	"os"
-	"runtime"
 	"strings"
 
 	"furr/internal/db"
 )
 
 func Start() {
 	fmt.Println("🦊 FurrDB REPL (type HELP for commands, EXIT to quit)")
 	r := bufio.NewReader(os.Stdin)
 	for {
@@ -30,39 +29,32 @@
 		}
 		cmd := strings.ToUpper(tokens[0])
 		args := tokens[1:]
-		if cmd == "EXIT" {
+		switch cmd {
+		case "EXIT":
 			fmt.Println("bye!")
 			return
-		}
-		if cmd == "HELP" {
+		case "HELP":
 			printHelp()
-			continue
-		}
-		if cmd == "CLEAR" {
+		case "CLEAR":
 			clearScreen()
-			continue
-		}
-		handler, ok := db.Commands[cmd]
-		if !ok {
-			fmt.Println("ERR unknown command")
-			continue
+		default:
+			handler, ok := db.Commands[cmd]
+			if !ok {
+				fmt.Println("ERR unknown command")
+				continue
+			}
+			result, err := handler(args)
+			if err != nil {
+				fmt.Println("ERR", err)
+				continue
+			}
+			fmt.Println(result)
 		}
-		result, err := handler(args)
-		if err != nil {
-			fmt.Println("ERR", err)
-			continue
-		}
-		fmt.Println(result)
 	}
 }
 
 func clearScreen() {
-	if runtime.GOOS == "windows" {
-		fmt.Print("\033[2J\033[H") // ANSI clear for modern Windows terminals
-		// Optionally, use syscall for legacy cmd.exe, but most support ANSI now
-	} else {
-		fmt.Print("\033[2J\033[H") // ANSI escape codes for Unix
-	}
+	fmt.Print("\033[2J\033[H") // ANSI escape code
 }
 
 func printHelp() {