fix(storage/redis): add check for empty values

TykTechnologies · Jan 16, 2024 · e23cc7f · e23cc7f
1 parent 35e1e74
commit e23cc7f
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/storage/redis.go b/storage/redis.go
@@ -271,13 +271,26 @@ func (r *RedisClusterStorageManager) GetAndDeleteSet(keyName string, chunkSize i
 		log.WithFields(logrus.Fields{
 			"prefix": redisLogPrefix,
 		}).Error("Multi command failed: ", err)
+		log.WithFields(logrus.Fields{
+			"prefix": redisLogPrefix,
+		}).Error("Records lost: ", len(lrange.Val()))
 		r.Connect()
 	}
 
 	vals := lrange.Val()
 
 	result := make([]interface{}, len(vals))
-	for i, v := range vals {
+unpacking:
+	for i := 0; i < len(result); i++ {
+		v := ""
+		for v == "" {
+			if len(vals) == 0 {
+				result = result[:i]
+				break unpacking
+			}
+			v = vals[0]
+			vals = vals[1:]
+		}
 		result[i] = v
 	}