diff --git a/rueidiscompat/adapter.go b/rueidiscompat/adapter.go index abb6f42e..4de9dbf9 100644 --- a/rueidiscompat/adapter.go +++ b/rueidiscompat/adapter.go @@ -5355,7 +5355,6 @@ func (c *Compat) FTExplainWithArgs(ctx context.Context, index string, query stri // see go-redis v9.7.0 https://github.com/redis/go-redis/blob/v9.7.0/search_commands.go#L1393 func (c *Compat) FTInfo(ctx context.Context, index string) *FTInfoCmd { cmd := c.client.B().FtInfo().Index(index).Build() - fmt.Println(cmd.Commands()) return newFTInfoCmd(c.client.Do(ctx, cmd)) } @@ -5566,7 +5565,6 @@ func (c *Compat) FTSearchWithArgs(ctx context.Context, index string, query strin } } cmd := cmds.FtSearchQuery(_cmd).Build() - fmt.Print(cmd.Commands()) return newFTSearchCmd(c.client.Do(ctx, cmd), options) } diff --git a/rueidiscompat/command.go b/rueidiscompat/command.go index 9925af4a..79514734 100644 --- a/rueidiscompat/command.go +++ b/rueidiscompat/command.go @@ -3482,11 +3482,16 @@ func (cmd *AggregateCmd) from(res rueidis.RedisResult) { return } cmd.SetRawVal(anyRes) - if !(res.IsMap() || res.IsArray()) { + msg, err := res.ToMessage() + if err != nil { + cmd.SetErr(err) + return + } + if !(msg.IsMap() || msg.IsArray()) { panic("res should be either map(RESP3) or array(RESP2)") } - if res.IsMap() { - total, docs, err := res.AsFtAggregate() + if msg.IsMap() { + total, docs, err := msg.AsFtAggregate() if err != nil { cmd.SetErr(err) return @@ -3503,7 +3508,7 @@ func (cmd *AggregateCmd) from(res rueidis.RedisResult) { return } // is RESP2 array - rows, err := res.ToArray() + rows, err := msg.ToArray() if err != nil { cmd.SetErr(err) return @@ -4095,16 +4100,22 @@ func (cmd *FTSpellCheckCmd) from(res rueidis.RedisResult) { cmd.SetErr(err) return } - if !(res.IsMap() || res.IsArray()) { + msg, err := res.ToMessage() + if err != nil { + cmd.SetErr(err) + return + } + if !(msg.IsMap() || msg.IsArray()) { panic("res should be either map(RESP3) or array(RESP2)") } - if res.IsMap() { + if msg.IsMap() { // is RESP3 map - m, err := res.ToMap() + m, err := msg.ToMap() if err != nil { cmd.SetErr(err) + return } - anyM, err := res.ToAny() + anyM, err := msg.ToAny() if err != nil { cmd.SetErr(err) return @@ -4147,12 +4158,12 @@ func (cmd *FTSpellCheckCmd) from(res rueidis.RedisResult) { return } // is RESP2 array - arr, err := res.ToArray() + arr, err := msg.ToArray() if err != nil { cmd.SetErr(err) return } - anyRes, err := res.ToAny() + anyRes, err := msg.ToAny() if err != nil { cmd.SetErr(err) return @@ -4294,12 +4305,17 @@ func (cmd *FTSearchCmd) from(res rueidis.RedisResult) { return } cmd.SetRawVal(anyRes) - if !(res.IsMap() || res.IsArray()) { + msg, err := res.ToMessage() + if err != nil { + cmd.SetErr(err) + return + } + if !(msg.IsMap() || msg.IsArray()) { panic("res should be either map(RESP3) or array(RESP2)") } - if res.IsMap() { + if msg.IsMap() { // is RESP3 map - m, err := res.ToMap() + m, err := msg.ToMap() if err != nil { cmd.SetErr(err) return @@ -4381,7 +4397,7 @@ func (cmd *FTSearchCmd) from(res rueidis.RedisResult) { return } // is RESP2 array - data, err := res.ToArray() + data, err := msg.ToArray() if err != nil { cmd.SetErr(err) return @@ -4499,12 +4515,17 @@ func (cmd *FTSynDumpCmd) from(res rueidis.RedisResult) { return } cmd.SetRawVal(anyRes) - if !(res.IsMap() || res.IsArray()) { + msg, err := res.ToMessage() + if err != nil { + cmd.SetErr(err) + return + } + if !(msg.IsMap() || msg.IsArray()) { panic("res should be either map(RESP3) or array(RESP2)") } - if res.IsMap() { + if msg.IsMap() { // is RESP3 map - m, err := res.ToMap() + m, err := msg.ToMap() if err != nil { cmd.SetErr(err) return @@ -4522,7 +4543,7 @@ func (cmd *FTSynDumpCmd) from(res rueidis.RedisResult) { return } // is RESP2 array - arr, err := res.ToArray() + arr, err := msg.ToArray() if err != nil { cmd.SetErr(err) return