Method handle

IceFireDB-PubSub/proxy/handle.go:33–77

(conn bareneter.Conn)

)

func (p *Proxy) handle(conn bareneter.Conn) {
	defer func() {
		_ = conn.Close()
	}()
	localConn := conn.NetConn()
	localWriteHandle := RESPHandle.NewWriterHandle(localConn)
	decoder := credis.NewDecoderSize(localConn, 1024)
	for {
		resp, err := decoder.Decode()
		if err != nil {
			return
		}
		if resp.Type != credis.TypeArray {
			_ = router.WriteError(localWriteHandle, fmt.Errorf(router.ErrUnknownCommand, "cmd"))
			return
		}

		respCount := len(resp.Array)

		if respCount < 1 {
			_ = router.WriteError(localWriteHandle, fmt.Errorf(router.ErrArguments, "cmd"))
			return
		}

		if resp.Array[0].Type != credis.TypeBulkBytes {
			_ = router.WriteError(localWriteHandle, router.ErrCmdTypeWrong)
			return
		}

		commandArgs := make([]interface{}, respCount)
		for i := 0; i < respCount; i++ {
			commandArgs[i] = resp.Array[i].Value
		}
		err = p.router.Handle(localWriteHandle, commandArgs)

		if err != nil {
			if errors.Is(err, router.ErrLocalWriter) || errors.Is(err, router.ErrLocalFlush) {
				return
			}
			_ = router.WriteError(localWriteHandle, err)
			logrus.Errorf("redis command exec fail:%s , %v", commandArgs, err)
			return
		}
	}
}