mirror of https://github.com/tidwall/tile38.git
parent
0659e0c705
commit
2e7003bc31
|
@ -223,28 +223,29 @@ moreData:
|
||||||
if !complete {
|
if !complete {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
if len(args) > 0 {
|
if kind == kindHTTP {
|
||||||
if kind != kindHTTP {
|
if len(msg.Values) == 0 {
|
||||||
msg.Command = strings.ToLower(string(args[0]))
|
|
||||||
for i := 0; i < len(args); i++ {
|
|
||||||
args[i] = append([]byte{}, args[i]...)
|
|
||||||
msg.Values = append(msg.Values, resp.BytesValue(args[i]))
|
|
||||||
}
|
|
||||||
switch kind {
|
|
||||||
case redcon.Redis:
|
|
||||||
msg.ConnType = RESP
|
|
||||||
msg.OutputType = RESP
|
|
||||||
case redcon.Tile38:
|
|
||||||
msg.ConnType = Native
|
|
||||||
msg.OutputType = JSON
|
|
||||||
case redcon.Telnet:
|
|
||||||
msg.ConnType = RESP
|
|
||||||
msg.OutputType = RESP
|
|
||||||
}
|
|
||||||
} else if len(msg.Values) == 0 {
|
|
||||||
return nil, errInvalidHTTP
|
return nil, errInvalidHTTP
|
||||||
}
|
}
|
||||||
msgs = append(msgs, msg)
|
msgs = append(msgs, msg)
|
||||||
|
} else if len(args) > 0 {
|
||||||
|
msg.Command = strings.ToLower(string(args[0]))
|
||||||
|
for i := 0; i < len(args); i++ {
|
||||||
|
args[i] = append([]byte{}, args[i]...)
|
||||||
|
msg.Values = append(msg.Values, resp.BytesValue(args[i]))
|
||||||
|
}
|
||||||
|
switch kind {
|
||||||
|
case redcon.Redis:
|
||||||
|
msg.ConnType = RESP
|
||||||
|
msg.OutputType = RESP
|
||||||
|
case redcon.Tile38:
|
||||||
|
msg.ConnType = Native
|
||||||
|
msg.OutputType = JSON
|
||||||
|
case redcon.Telnet:
|
||||||
|
msg.ConnType = RESP
|
||||||
|
msg.OutputType = RESP
|
||||||
|
}
|
||||||
|
msgs = append(msgs, msg)
|
||||||
}
|
}
|
||||||
data = leftover
|
data = leftover
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue