mirror of https://github.com/tidwall/tile38.git
313 lines
8.2 KiB
Go
313 lines
8.2 KiB
Go
package redcon
|
|
|
|
import (
|
|
"strconv"
|
|
"strings"
|
|
)
|
|
|
|
// Kind is the kind of command
|
|
type Kind int
|
|
|
|
const (
|
|
// Redis is returned for Redis protocol commands
|
|
Redis Kind = iota
|
|
// Tile38 is returnd for Tile38 native protocol commands
|
|
Tile38
|
|
// Telnet is returnd for plain telnet commands
|
|
Telnet
|
|
)
|
|
|
|
var errInvalidMessage = &errProtocol{"invalid message"}
|
|
|
|
// ReadNextCommand reads the next command from the provided packet. It's
|
|
// possible that the packet contains multiple commands, or zero commands
|
|
// when the packet is incomplete.
|
|
// 'argsbuf' is an optional reusable buffer and it can be nil.
|
|
// 'complete' indicates that a command was read. false means no more commands.
|
|
// 'args' are the output arguments for the command.
|
|
// 'kind' is the type of command that was read.
|
|
// 'leftover' is any remaining unused bytes which belong to the next command.
|
|
// 'err' is returned when a protocol error was encountered.
|
|
func ReadNextCommand(packet []byte, argsbuf [][]byte) (
|
|
complete bool, args [][]byte, kind Kind, leftover []byte, err error,
|
|
) {
|
|
args = argsbuf[:0]
|
|
if len(packet) > 0 {
|
|
if packet[0] != '*' {
|
|
if packet[0] == '$' {
|
|
return readTile38Command(packet, args)
|
|
}
|
|
return readTelnetCommand(packet, args)
|
|
}
|
|
// standard redis command
|
|
for s, i := 1, 1; i < len(packet); i++ {
|
|
if packet[i] == '\n' {
|
|
if packet[i-1] != '\r' {
|
|
return false, args[:0], Redis, packet, errInvalidMultiBulkLength
|
|
}
|
|
count, ok := parseInt(packet[s : i-1])
|
|
if !ok || count < 0 {
|
|
return false, args[:0], Redis, packet, errInvalidMultiBulkLength
|
|
}
|
|
i++
|
|
if count == 0 {
|
|
return true, args[:0], Redis, packet[i:], nil
|
|
}
|
|
nextArg:
|
|
for j := 0; j < count; j++ {
|
|
if i == len(packet) {
|
|
break
|
|
}
|
|
if packet[i] != '$' {
|
|
return false, args[:0], Redis, packet,
|
|
&errProtocol{"expected '$', got '" +
|
|
string(packet[i]) + "'"}
|
|
}
|
|
for s := i + 1; i < len(packet); i++ {
|
|
if packet[i] == '\n' {
|
|
if packet[i-1] != '\r' {
|
|
return false, args[:0], Redis, packet, errInvalidBulkLength
|
|
}
|
|
n, ok := parseInt(packet[s : i-1])
|
|
if !ok || count <= 0 {
|
|
return false, args[:0], Redis, packet, errInvalidBulkLength
|
|
}
|
|
i++
|
|
if len(packet)-i >= n+2 {
|
|
if packet[i+n] != '\r' || packet[i+n+1] != '\n' {
|
|
return false, args[:0], Redis, packet, errInvalidBulkLength
|
|
}
|
|
args = append(args, packet[i:i+n])
|
|
i += n + 2
|
|
if j == count-1 {
|
|
// done reading
|
|
return true, args, Redis, packet[i:], nil
|
|
}
|
|
continue nextArg
|
|
}
|
|
break
|
|
}
|
|
}
|
|
break
|
|
}
|
|
break
|
|
}
|
|
}
|
|
}
|
|
return false, args[:0], Redis, packet, nil
|
|
}
|
|
|
|
func readTile38Command(packet []byte, argsbuf [][]byte) (
|
|
complete bool, args [][]byte, kind Kind, leftover []byte, err error,
|
|
) {
|
|
for i := 1; i < len(packet); i++ {
|
|
if packet[i] == ' ' {
|
|
n, ok := parseInt(packet[1:i])
|
|
if !ok || n < 0 {
|
|
return false, args[:0], Tile38, packet, errInvalidMessage
|
|
}
|
|
i++
|
|
if len(packet) >= i+n+2 {
|
|
if packet[i+n] != '\r' || packet[i+n+1] != '\n' {
|
|
return false, args[:0], Tile38, packet, errInvalidMessage
|
|
}
|
|
line := packet[i : i+n]
|
|
reading:
|
|
for len(line) != 0 {
|
|
if line[0] == '{' {
|
|
// The native protocol cannot understand json boundaries so it assumes that
|
|
// a json element must be at the end of the line.
|
|
args = append(args, line)
|
|
break
|
|
}
|
|
if line[0] == '"' && line[len(line)-1] == '"' {
|
|
if len(args) > 0 &&
|
|
strings.ToLower(string(args[0])) == "set" &&
|
|
strings.ToLower(string(args[len(args)-1])) == "string" {
|
|
// Setting a string value that is contained inside double quotes.
|
|
// This is only because of the boundary issues of the native protocol.
|
|
args = append(args, line[1:len(line)-1])
|
|
break
|
|
}
|
|
}
|
|
i := 0
|
|
for ; i < len(line); i++ {
|
|
if line[i] == ' ' {
|
|
value := line[:i]
|
|
if len(value) > 0 {
|
|
args = append(args, value)
|
|
}
|
|
line = line[i+1:]
|
|
continue reading
|
|
}
|
|
}
|
|
args = append(args, line)
|
|
break
|
|
}
|
|
return true, args, Tile38, packet[i+n+2:], nil
|
|
}
|
|
break
|
|
}
|
|
}
|
|
return false, args[:0], Tile38, packet, nil
|
|
}
|
|
func readTelnetCommand(packet []byte, argsbuf [][]byte) (
|
|
complete bool, args [][]byte, kind Kind, leftover []byte, err error,
|
|
) {
|
|
// just a plain text command
|
|
for i := 0; i < len(packet); i++ {
|
|
if packet[i] == '\n' {
|
|
var line []byte
|
|
if i > 0 && packet[i-1] == '\r' {
|
|
line = packet[:i-1]
|
|
} else {
|
|
line = packet[:i]
|
|
}
|
|
var quote bool
|
|
var quotech byte
|
|
var escape bool
|
|
outer:
|
|
for {
|
|
nline := make([]byte, 0, len(line))
|
|
for i := 0; i < len(line); i++ {
|
|
c := line[i]
|
|
if !quote {
|
|
if c == ' ' {
|
|
if len(nline) > 0 {
|
|
args = append(args, nline)
|
|
}
|
|
line = line[i+1:]
|
|
continue outer
|
|
}
|
|
if c == '"' || c == '\'' {
|
|
if i != 0 {
|
|
return false, args[:0], Telnet, packet, errUnbalancedQuotes
|
|
}
|
|
quotech = c
|
|
quote = true
|
|
line = line[i+1:]
|
|
continue outer
|
|
}
|
|
} else {
|
|
if escape {
|
|
escape = false
|
|
switch c {
|
|
case 'n':
|
|
c = '\n'
|
|
case 'r':
|
|
c = '\r'
|
|
case 't':
|
|
c = '\t'
|
|
}
|
|
} else if c == quotech {
|
|
quote = false
|
|
quotech = 0
|
|
args = append(args, nline)
|
|
line = line[i+1:]
|
|
if len(line) > 0 && line[0] != ' ' {
|
|
return false, args[:0], Telnet, packet, errUnbalancedQuotes
|
|
}
|
|
continue outer
|
|
} else if c == '\\' {
|
|
escape = true
|
|
continue
|
|
}
|
|
}
|
|
nline = append(nline, c)
|
|
}
|
|
if quote {
|
|
return false, args[:0], Telnet, packet, errUnbalancedQuotes
|
|
}
|
|
if len(line) > 0 {
|
|
args = append(args, line)
|
|
}
|
|
break
|
|
}
|
|
return true, args, Telnet, packet[i+1:], nil
|
|
}
|
|
}
|
|
return false, args[:0], Telnet, packet, nil
|
|
}
|
|
|
|
// AppendUint appends a Redis protocol uint64 to the input bytes.
|
|
func AppendUint(b []byte, n uint64) []byte {
|
|
b = append(b, ':')
|
|
b = strconv.AppendUint(b, n, 10)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendInt appends a Redis protocol int64 to the input bytes.
|
|
func AppendInt(b []byte, n int64) []byte {
|
|
b = append(b, ':')
|
|
b = strconv.AppendInt(b, n, 10)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendArray appends a Redis protocol array to the input bytes.
|
|
func AppendArray(b []byte, n int) []byte {
|
|
b = append(b, '*')
|
|
b = strconv.AppendInt(b, int64(n), 10)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendBulk appends a Redis protocol bulk byte slice to the input bytes.
|
|
func AppendBulk(b []byte, bulk []byte) []byte {
|
|
b = append(b, '$')
|
|
b = strconv.AppendInt(b, int64(len(bulk)), 10)
|
|
b = append(b, '\r', '\n')
|
|
b = append(b, bulk...)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendBulkString appends a Redis protocol bulk string to the input bytes.
|
|
func AppendBulkString(b []byte, bulk string) []byte {
|
|
b = append(b, '$')
|
|
b = strconv.AppendInt(b, int64(len(bulk)), 10)
|
|
b = append(b, '\r', '\n')
|
|
b = append(b, bulk...)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendString appends a Redis protocol string to the input bytes.
|
|
func AppendString(b []byte, s string) []byte {
|
|
b = append(b, '+')
|
|
b = append(b, stripNewlines(s)...)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendError appends a Redis protocol error to the input bytes.
|
|
func AppendError(b []byte, s string) []byte {
|
|
b = append(b, '-')
|
|
b = append(b, stripNewlines(s)...)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendOK appends a Redis protocol OK to the input bytes.
|
|
func AppendOK(b []byte) []byte {
|
|
return append(b, '+', 'O', 'K', '\r', '\n')
|
|
}
|
|
func stripNewlines(s string) string {
|
|
for i := 0; i < len(s); i++ {
|
|
if s[i] == '\r' || s[i] == '\n' {
|
|
s = strings.Replace(s, "\r", " ", -1)
|
|
s = strings.Replace(s, "\n", " ", -1)
|
|
break
|
|
}
|
|
}
|
|
return s
|
|
}
|
|
|
|
// AppendTile38 appends a Tile38 message to the input bytes.
|
|
func AppendTile38(b []byte, data []byte) []byte {
|
|
b = append(b, '$')
|
|
b = strconv.AppendInt(b, int64(len(data)), 10)
|
|
b = append(b, ' ')
|
|
b = append(b, data...)
|
|
return append(b, '\r', '\n')
|
|
}
|
|
|
|
// AppendNull appends a Redis protocol null to the input bytes.
|
|
func AppendNull(b []byte) []byte {
|
|
return append(b, '$', '-', '1', '\r', '\n')
|
|
}
|