Compare commits
4 Commits
60241736c6
...
1d6fb9652e
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1d6fb9652e | ||
|
|
eedb785634 | ||
|
|
9e0754d92f | ||
|
|
dd64e959c3 |
112
src/adapt.go
112
src/adapt.go
@@ -8,33 +8,45 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"log"
|
"log"
|
||||||
"net"
|
"net"
|
||||||
|
"regexp"
|
||||||
"strconv"
|
"strconv"
|
||||||
)
|
)
|
||||||
|
|
||||||
func adapt(ctx context.Context, config Config, conn net.Conn) error {
|
func adapt(ctx context.Context, config Config, conn net.Conn) error {
|
||||||
reader := bufio.NewReader(conn)
|
reader := bufio.NewReader(conn)
|
||||||
|
|
||||||
|
alpha := regexp.MustCompile(`[a-zA-Z]`)
|
||||||
|
parts := regexp.MustCompile(`(.*?)\r\n*`)
|
||||||
|
|
||||||
for ctx.Err() == nil {
|
for ctx.Err() == nil {
|
||||||
if done, err := func() (bool, error) {
|
if done, err := func() (bool, error) {
|
||||||
raw, message, err := readMessage(reader)
|
raw, err := readMessage(reader)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if err == io.EOF {
|
if err == io.EOF {
|
||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
return true, err
|
return true, err
|
||||||
}
|
}
|
||||||
log.Printf("routing: %q (%+v)", raw, message)
|
log.Printf("routing: %q", raw)
|
||||||
|
|
||||||
if len(message) > 0 && message[0].(string) == "COMMAND" {
|
if len(raw) > 0 {
|
||||||
fmt.Fprintf(conn, "*0\r\n")
|
hashKey := ""
|
||||||
} else if len(raw) > 0 && len(message) > 0 {
|
if matches := parts.FindAllSubmatch(raw, 5); len(matches) > 0 {
|
||||||
hashKey := message[0].(string)
|
for i := range matches {
|
||||||
if len(message) > 1 {
|
if isTheCommand := alpha.Match(matches[i][0]); isTheCommand {
|
||||||
hashKey = message[1].(string)
|
for j := i + 1; j < len(matches); j++ {
|
||||||
|
if matches[j][0][0] == byte('$') {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
hashKey = string(matches[j][1])
|
||||||
|
break
|
||||||
|
}
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
log.Printf("hashkey %q", hashKey)
|
||||||
if err := config.WithConn(hashKey, func(forwardConn net.Conn) error {
|
if err := config.WithConn(hashKey, func(forwardConn net.Conn) error {
|
||||||
//log.Printf("forwarding %q", raw)
|
|
||||||
|
|
||||||
written := 0
|
written := 0
|
||||||
for written < len(raw) {
|
for written < len(raw) {
|
||||||
more, err := forwardConn.Write(raw[written:])
|
more, err := forwardConn.Write(raw[written:])
|
||||||
@@ -44,11 +56,16 @@ func adapt(ctx context.Context, config Config, conn net.Conn) error {
|
|||||||
written += more
|
written += more
|
||||||
}
|
}
|
||||||
|
|
||||||
replyer := bufio.NewReader(forwardConn)
|
peekW := bytes.NewBuffer(nil)
|
||||||
//log.Printf("reading reply to %q", raw)
|
peek := io.TeeReader(forwardConn, peekW)
|
||||||
_, err = readMessageTo(conn, replyer)
|
defer func() {
|
||||||
//log.Printf("read reply %q", raw)
|
replied := peekW.Bytes()
|
||||||
return err
|
if len(replied) > 100 {
|
||||||
|
replied = []byte(fmt.Sprintf("%s...%s", replied[:50], replied[len(replied)-50:]))
|
||||||
|
}
|
||||||
|
log.Printf("replied %q", replied)
|
||||||
|
}()
|
||||||
|
return readMessageTo(conn, bufio.NewReader(peek))
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
return true, err
|
return true, err
|
||||||
}
|
}
|
||||||
@@ -65,90 +82,85 @@ func adapt(ctx context.Context, config Config, conn net.Conn) error {
|
|||||||
return io.EOF
|
return io.EOF
|
||||||
}
|
}
|
||||||
|
|
||||||
func readMessage(reader *bufio.Reader) ([]byte, []any, error) {
|
func readMessage(reader *bufio.Reader) ([]byte, error) {
|
||||||
w := bytes.NewBuffer(nil)
|
w := bytes.NewBuffer(nil)
|
||||||
arr, err := readMessageTo(w, reader)
|
err := readMessageTo(w, reader)
|
||||||
return w.Bytes(), arr, err
|
return w.Bytes(), err
|
||||||
}
|
}
|
||||||
|
|
||||||
func readMessageTo(w io.Writer, reader *bufio.Reader) ([]any, error) {
|
func readMessageTo(w io.Writer, reader *bufio.Reader) error {
|
||||||
w2 := bufio.NewWriter(w)
|
w2 := bufio.NewWriter(w)
|
||||||
defer w2.Flush()
|
defer w2.Flush()
|
||||||
arr, err := _readMessageTo(w2, reader)
|
err := _readMessageTo(w2, reader)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return err
|
||||||
}
|
}
|
||||||
return arr, w2.Flush()
|
return w2.Flush()
|
||||||
}
|
}
|
||||||
|
|
||||||
func _readMessageTo(w io.Writer, reader *bufio.Reader) ([]any, error) {
|
func _readMessageTo(w io.Writer, reader *bufio.Reader) error {
|
||||||
firstLine, _, err := reader.ReadLine()
|
firstLine, _, err := reader.ReadLine()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return err
|
||||||
}
|
}
|
||||||
firstLine = bytes.TrimSuffix(firstLine, []byte("\r\n"))
|
firstLine = bytes.TrimSuffix(firstLine, []byte("\r\n"))
|
||||||
if len(firstLine) == 0 {
|
if len(firstLine) == 0 {
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
fmt.Fprintf(w, "%s\r\n", firstLine)
|
fmt.Fprintf(w, "%s\r\n", firstLine)
|
||||||
|
|
||||||
switch firstLine[0] {
|
switch firstLine[0] {
|
||||||
case '+': // simple string, like +OK
|
case '+': // simple string, like +OK
|
||||||
return []any{string(firstLine[1:])}, nil
|
return nil
|
||||||
case '-': // simple error, like -message
|
case '-': // simple error, like -message
|
||||||
return []any{string(firstLine)}, nil
|
return nil
|
||||||
case ':': // number, like /[+-][0-9]+/
|
case ':': // number, like /[+-][0-9]+/
|
||||||
firstLine = bytes.TrimPrefix(firstLine[1:], []byte("+"))
|
return err
|
||||||
n, err := strconv.Atoi(string(firstLine))
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("num not a num: %q: %w", firstLine, err)
|
|
||||||
}
|
|
||||||
return []any{n}, err
|
|
||||||
case '$': // long string, like $-1 for nil, like $LEN\r\nSTRING\r\n
|
case '$': // long string, like $-1 for nil, like $LEN\r\nSTRING\r\n
|
||||||
if firstLine[1] == '-' {
|
if firstLine[1] == '-' {
|
||||||
return []any{nil}, nil
|
return nil
|
||||||
}
|
}
|
||||||
firstLine = bytes.TrimPrefix(firstLine[1:], []byte("+"))
|
firstLine = bytes.TrimPrefix(firstLine[1:], []byte("+"))
|
||||||
n, err := strconv.Atoi(string(firstLine))
|
n, err := strconv.Atoi(string(firstLine))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("num not a num: %q: %w", firstLine, err)
|
return fmt.Errorf("num not a num: %q: %w", firstLine, err)
|
||||||
}
|
}
|
||||||
//log.Printf("reading %v+2 bytes for bulk string", n)
|
|
||||||
nextLine := make([]byte, n+2)
|
nextLine := make([]byte, n+2)
|
||||||
nAt := 0
|
nAt := 0
|
||||||
for nAt < n+2 {
|
for nAt < n+2 {
|
||||||
nMore, err := reader.Read(nextLine[nAt:])
|
nMore, err := reader.Read(nextLine[nAt:])
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("couldnt read %v more/%v bytes for long string: %w", n+2-nAt, n+2, err)
|
return fmt.Errorf("couldnt read %v more/%v bytes for long string: %w", n+2-nAt, n+2, err)
|
||||||
}
|
}
|
||||||
nAt += nMore
|
nAt += nMore
|
||||||
}
|
}
|
||||||
fmt.Fprintf(w, "%s", nextLine)
|
fmt.Fprintf(w, "%s", nextLine)
|
||||||
return []any{string(nextLine)}, err
|
return err
|
||||||
case '*': // array, like *-1 for nil, like *4 for [1,2,3,4]
|
case '*', '~', '%': // *=array %=map, like *-1 for nil, like *4 for [1,2,3,4]
|
||||||
n, err := strconv.Atoi(string(firstLine[1:]))
|
n, err := strconv.Atoi(string(firstLine[1:]))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("arr not a num: %q: %w", firstLine, err)
|
return fmt.Errorf("arr not a num: %q: %w", firstLine, err)
|
||||||
} else if n == -1 {
|
} else if n == -1 {
|
||||||
return nil, nil
|
return nil
|
||||||
|
}
|
||||||
|
if isMap := firstLine[0] == '%'; isMap {
|
||||||
|
n *= 2
|
||||||
}
|
}
|
||||||
var result []any
|
|
||||||
for i := 0; i < n; i++ {
|
for i := 0; i < n; i++ {
|
||||||
more, err := _readMessageTo(w, reader)
|
err := _readMessageTo(w, reader)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return err
|
||||||
}
|
}
|
||||||
result = append(result, more...)
|
|
||||||
}
|
}
|
||||||
return result, nil
|
return nil
|
||||||
case '_': // nil
|
case '_': // nil
|
||||||
return nil, nil
|
return nil
|
||||||
case '#': // boolean, like #t or #f
|
case '#': // boolean, like #t or #f
|
||||||
return []any{firstLine[1] == 't'}, nil
|
return nil
|
||||||
case ',': // double
|
case ',': // double
|
||||||
log.Fatal("not impl")
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Fatalf("not impl: %q", firstLine)
|
log.Fatalf("not impl: %q", firstLine)
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -73,7 +73,7 @@ func NewConfig(ctx context.Context) (Config, error) {
|
|||||||
v.Close()
|
v.Close()
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
if raw, _, err := readMessage(bufio.NewReader(v)); err != nil {
|
if raw, err := readMessage(bufio.NewReader(v)); err != nil {
|
||||||
log.Printf("! failed read hello %q: %v", forward, err)
|
log.Printf("! failed read hello %q: %v", forward, err)
|
||||||
v.Close()
|
v.Close()
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
Reference in New Issue
Block a user