Add support for MODULE LOADEX command

commands.go

@@ -495,6 +495,8 @@ type Cmdable interface {
 	GeoHash(ctx context.Context, key string, members ...string) *StringSliceCmd
 
 	ACLDryRun(ctx context.Context, username string, command ...interface{}) *StringCmd
+
+	ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd
 }
 
 type StatefulCmdable interface {
@@ -3873,3 +3875,10 @@ func (c cmdable) ACLDryRun(ctx context.Context, username string, command ...inte
 	_ = c(ctx, cmd)
 	return cmd
 }
+
+// ModuleLoadex Redis `MODULE LOADEX path [CONFIG name value [CONFIG name value ...]] [ARGS args [args ...]]` command.
+func (c cmdable) ModuleLoadex(ctx context.Context, conf *ModuleLoadexConfig) *StringCmd {
+	cmd := NewStringCmd(ctx, conf.ToArgs()...)
+	_ = c(ctx, cmd)
+	return cmd
+}

commands_test.go

@@ -1926,11 +1926,25 @@ var _ = Describe("Commands", func() {
 			Expect(replace.Val()).To(Equal(int64(1)))
 		})
 
-		It("should acl dryryn", func() {
+		It("should acl dryrun", func() {
 			dryRun := client.ACLDryRun(ctx, "default", "get", "randomKey")
 			Expect(dryRun.Err()).NotTo(HaveOccurred())
 			Expect(dryRun.Val()).To(Equal("OK"))
 		})
+
+		It("should fail module loadex", func() {
+			dryRun := client.ModuleLoadex(ctx, &redis.ModuleLoadexConfig{
+				Path: "/path/to/non-existent-library.so",
+				Conf: map[string]interface{}{
+					"param1": "value1",
+				},
+				Args: []interface{}{
+					"arg1",
+				},
+			})
+			Expect(dryRun.Err()).To(HaveOccurred())
+			Expect(dryRun.Err().Error()).To(Equal("ERR Error loading the extension. Please check the server logs."))
+		})
 	})
 
 	Describe("hashes", func() {

main_test.go

@@ -314,7 +314,7 @@ func startRedis(port string, args ...string) (*redisProcess, error) {
 		return nil, err
 	}
 
-	baseArgs := []string{filepath.Join(dir, "redis.conf"), "--port", port, "--dir", dir}
+	baseArgs := []string{filepath.Join(dir, "redis.conf"), "--port", port, "--dir", dir, "--enable-module-command", "yes"}
 	process, err := execCmd(redisServerBin, append(baseArgs, args...)...)
 	if err != nil {
 		return nil, err

module_loadex.go

@@ -0,0 +1,23 @@
+package redis
+
+// ModuleLoadexConfig struct is used to specify the arguments for the MODULE LOADEX command of redis.
+// `MODULE LOADEX path [CONFIG name value [CONFIG name value ...]] [ARGS args [args ...]]`
+type ModuleLoadexConfig struct {
+	Path string
+	Conf map[string]interface{}
+	Args []interface{}
+}
+
+func (c *ModuleLoadexConfig) ToArgs() []interface{} {
+	var args = make([]interface{}, 3, len(c.Conf)*2+len(c.Args)+3)
+	args[0] = "MODULE"
+	args[1] = "LOADEX"
+	args[2] = c.Path
+	for k, v := range c.Conf {
+		args = append(args, "CONFIG", k, v)
+	}
+	for _, arg := range c.Args {
+		args = append(args, "ARGS", arg)
+	}
+	return args
+}

module_loadex_test.go

@@ -0,0 +1,52 @@
+package redis_test
+
+import (
+	. "github.com/bsm/ginkgo/v2"
+	. "github.com/bsm/gomega"
+
+	"github.com/redis/go-redis/v9"
+)
+
+var _ = Describe("Loadex Config", func() {
+	It("converts the configuration to a slice of arguments correctly", func() {
+		conf := &redis.ModuleLoadexConfig{
+			Path: "/path/to/your/module.so",
+			Conf: map[string]interface{}{
+				"param1": "value1",
+				"param2": "value2",
+				"param3": 3,
+			},
+			Args: []interface{}{
+				"arg1",
+				"arg2",
+				3,
+			},
+		}
+
+		args := conf.ToArgs()
+
+		// Test if the arguments are in the correct order
+		expectedArgs := []interface{}{
+			"MODULE",
+			"LOADEX",
+			"/path/to/your/module.so",
+			"CONFIG",
+			"param1",
+			"value1",
+			"CONFIG",
+			"param2",
+			"value2",
+			"CONFIG",
+			"param3",
+			3,
+			"ARGS",
+			"arg1",
+			"ARGS",
+			"arg2",
+			"ARGS",
+			3,
+		}
+
+		Expect(args).To(Equal(expectedArgs))
+	})
+})