Send group name as arg

cschleiden · cschleiden · commit 757c73a0d5b3 · 2024-05-16T21:24:19.000Z
diff --git a/backend/redis/queue.go b/backend/redis/queue.go
@@ -64,7 +64,7 @@ func newTaskQueue[T any](rdb redis.UniversalClient, keyPrefix string, tasktype s
 	}
 
 	// Create the consumer group
-	err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey, tq.groupName}).Err()
+	err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey}, tq.groupName).Err()
 	if err != nil {
 		return nil, fmt.Errorf("creating task queue: %w", err)
 	}
@@ -99,7 +99,7 @@ var enqueueCmd = redis.NewScript(
 
 var createGroupCmd = redis.NewScript(`
     local streamKey = KEYS[1]
-    local groupName = KEYS[2]
+    local groupName = ARGV[1]
     local exists = false
     local res = redis.pcall('XINFO', 'GROUPS', streamKey)
 

Original file line number	Diff line number	Diff line change
`@@ -64,7 +64,7 @@ func newTaskQueue[T any](rdb redis.UniversalClient, keyPrefix string, tasktype s`
`64`	`64`	`}`
`65`	`65`
`66`	`66`	`// Create the consumer group`
`67`		`- err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey, tq.groupName}).Err()`
	`67`	`+ err := createGroupCmd.Run(context.Background(), rdb, []string{tq.streamKey}, tq.groupName).Err()`
`68`	`68`	`if err != nil {`
`69`	`69`	`return nil, fmt.Errorf("creating task queue: %w", err)`
`70`	`70`	`}`
`@@ -99,7 +99,7 @@ var enqueueCmd = redis.NewScript(`
`99`	`99`
`100`	`100`	var createGroupCmd = redis.NewScript(`
`101`	`101`	`local streamKey = KEYS[1]`
`102`		`- local groupName = KEYS[2]`
	`102`	`+ local groupName = ARGV[1]`
`103`	`103`	`local exists = false`
`104`	`104`	`local res = redis.pcall('XINFO', 'GROUPS', streamKey)`
`105`	`105`