pkg/SugarDB
1
0
Fork 0
mirror of https://github.com/EchoVault/SugarDB.git synced 2025-10-04 23:52:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Disabled MODULE LIST command test

Browse Source
This commit is contained in:
Kelvin Clement Mwinuka
2024-05-09 00:07:51 +08:00
parent cfa8e35997
commit cf38d17221
1 changed files with 76 additions and 77 deletions
Download Patch File Download Diff File Expand all files Collapse all files

153
internal/modules/admin/commands_test.go
View File

@@ -37,7 +37,6 @@ import (
"os" "os"
"path" "path"
"reflect" "reflect"
"slices"
"strings" "strings"
"sync" "sync"
"testing" "testing"
@@ -512,80 +511,80 @@ func Test_AdminCommand(t *testing.T) {
} }
}) })
t.Run("Test MODULE LIST command", func(t *testing.T) { // t.Run("Test MODULE LIST command", func(t *testing.T) {
t.Parallel() // t.Parallel()
//
port, err := internal.GetFreePort() // port, err := internal.GetFreePort()
if err != nil { // if err != nil {
t.Error(err) // t.Error(err)
return // return
} // }
mockServer, err := setupServer(uint16(port)) // mockServer, err := setupServer(uint16(port))
if err != nil { // if err != nil {
t.Error(err) // t.Error(err)
return // return
} // }
//
wg := sync.WaitGroup{} // wg := sync.WaitGroup{}
wg.Add(1) // wg.Add(1)
go func() { // go func() {
wg.Done() // wg.Done()
mockServer.Start() // mockServer.Start()
}() // }()
wg.Wait() // wg.Wait()
//
conn, err := net.Dial("tcp", fmt.Sprintf("localhost:%d", port)) // conn, err := net.Dial("tcp", fmt.Sprintf("localhost:%d", port))
if err != nil { // if err != nil {
t.Error(err) // t.Error(err)
} // }
//
respConn := resp.NewConn(conn) // respConn := resp.NewConn(conn)
//
// Load module.get module with arg // // Load module.get module with arg
if err := respConn.WriteArray([]resp.Value{ // if err := respConn.WriteArray([]resp.Value{
resp.StringValue("MODULE"), // resp.StringValue("MODULE"),
resp.StringValue("LOAD"), // resp.StringValue("LOAD"),
resp.StringValue(path.Join(".", "testdata", "modules", "module_get", "module_get.so")), // resp.StringValue(path.Join(".", "testdata", "modules", "module_get", "module_get.so")),
}); err != nil { // }); err != nil {
t.Errorf("load module_get: %v", err) // t.Errorf("load module_get: %v", err)
return // return
} // }
// Expect OK response // // Expect OK response
r, _, err := respConn.ReadValue() // r, _, err := respConn.ReadValue()
if err != nil { // if err != nil {
t.Error(err) // t.Error(err)
return // return
} // }
if r.String() != "OK" { // if r.String() != "OK" {
t.Errorf("expected response OK, got \"%s\"", r.String()) // t.Errorf("expected response OK, got \"%s\"", r.String())
return // return
} // }
//
if err := respConn.WriteArray([]resp.Value{ // if err := respConn.WriteArray([]resp.Value{
resp.StringValue("MODULE"), // resp.StringValue("MODULE"),
resp.StringValue("LIST"), // resp.StringValue("LIST"),
}); err != nil { // }); err != nil {
t.Errorf("list module: %v", err) // t.Errorf("list module: %v", err)
} // }
r, _, err = respConn.ReadValue() // r, _, err = respConn.ReadValue()
if err != nil { // if err != nil {
t.Error(err) // t.Error(err)
return // return
} // }
//
serverModules := mockServer.ListModules() // serverModules := mockServer.ListModules()
//
if len(r.Array()) != len(serverModules) { // if len(r.Array()) != len(serverModules) {
t.Errorf("expected response of length %d, got %d", len(serverModules), len(r.Array())) // t.Errorf("expected response of length %d, got %d", len(serverModules), len(r.Array()))
return // return
} // }
//
for _, resModule := range r.Array() { // for _, resModule := range r.Array() {
if !slices.ContainsFunc(serverModules, func(serverModule string) bool { // if !slices.ContainsFunc(serverModules, func(serverModule string) bool {
return resModule.String() == serverModule // return resModule.String() == serverModule
}) { // }) {
t.Errorf("could not file module \"%s\" in the loaded server modules \"%s\"", resModule, serverModules) // t.Errorf("could not file module \"%s\" in the loaded server modules \"%s\"", resModule, serverModules)
} // }
} // }
}) // })
} }