Compare commits

...

4 Commits

Author SHA1 Message Date
Bel LaPointe
1d6fb9652e arrays, maps, sets 2026-02-04 09:02:55 -07:00
Bel LaPointe
eedb785634 peek at reply 2026-02-04 09:02:41 -07:00
Bel LaPointe
9e0754d92f hashkey from inspecting raw 2026-02-04 09:02:28 -07:00
Bel LaPointe
dd64e959c3 do not parse input, just read all 2026-02-04 08:48:53 -07:00
2 changed files with 63 additions and 51 deletions

View File

@@ -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
} }

View File

@@ -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