mirror of
https://github.com/EchoVault/SugarDB.git
synced 2025-10-06 00:16:53 +08:00
Created test for LLEN API function
This commit is contained in:
File diff suppressed because it is too large
Load Diff
0
pkg/echovault/aof/log.aof
Executable file
0
pkg/echovault/aof/log.aof
Executable file
0
pkg/echovault/aof/preamble.bin
Executable file
0
pkg/echovault/aof/preamble.bin
Executable file
@@ -15,12 +15,14 @@
|
|||||||
package echovault
|
package echovault
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"github.com/echovault/echovault/internal"
|
"github.com/echovault/echovault/internal"
|
||||||
"strconv"
|
"strconv"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (server *EchoVault) LLEN(key string) (int, error) {
|
func (server *EchoVault) LLEN(key string) (int, error) {
|
||||||
b, err := server.handleCommand(server.context, internal.EncodeCommand([]string{"LLEN", key}), nil, false)
|
b, err := server.handleCommand(server.context, internal.EncodeCommand([]string{"LLEN", key}), nil, false)
|
||||||
|
fmt.Println(key, string(b), err)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return 0, err
|
return 0, err
|
||||||
}
|
}
|
||||||
|
64
pkg/echovault/api_list_test.go
Normal file
64
pkg/echovault/api_list_test.go
Normal file
@@ -0,0 +1,64 @@
|
|||||||
|
package echovault
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/echovault/echovault/pkg/commands"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func presetValue(server *EchoVault, key string, value interface{}) {
|
||||||
|
_, _ = server.CreateKeyAndLock(server.context, key)
|
||||||
|
_ = server.SetValue(server.context, key, value)
|
||||||
|
server.KeyUnlock(server.context, key)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestEchoVault_LLEN(t *testing.T) {
|
||||||
|
server := NewEchoVault(
|
||||||
|
WithCommands(commands.All()),
|
||||||
|
)
|
||||||
|
|
||||||
|
tests := []struct {
|
||||||
|
preset bool
|
||||||
|
presetValue interface{}
|
||||||
|
name string
|
||||||
|
key string
|
||||||
|
want int
|
||||||
|
wantErr bool
|
||||||
|
}{
|
||||||
|
{ // If key exists and is a list, return the lists length
|
||||||
|
preset: true,
|
||||||
|
key: "key1",
|
||||||
|
presetValue: []interface{}{"value1", "value2", "value3", "value4"},
|
||||||
|
want: 4,
|
||||||
|
wantErr: false,
|
||||||
|
},
|
||||||
|
{ // If key does not exist, return 0
|
||||||
|
preset: false,
|
||||||
|
key: "key2",
|
||||||
|
presetValue: nil,
|
||||||
|
want: 0,
|
||||||
|
wantErr: false,
|
||||||
|
},
|
||||||
|
{ // Trying to get lengths on a non-list returns error
|
||||||
|
preset: true,
|
||||||
|
key: "key5",
|
||||||
|
presetValue: "Default value",
|
||||||
|
want: 0,
|
||||||
|
wantErr: true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
if tt.preset {
|
||||||
|
presetValue(server, tt.key, tt.presetValue)
|
||||||
|
}
|
||||||
|
got, err := server.LLEN(tt.key)
|
||||||
|
if (err != nil) != tt.wantErr {
|
||||||
|
t.Errorf("LLEN() error = %v, wantErr %v", err, tt.wantErr)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("LLEN() got = %v, want %v", got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
Reference in New Issue
Block a user