From 472f1e09be8d002e7db4837c5cf224808bdf1006 Mon Sep 17 00:00:00 2001 From: Xiaolong Lu Date: Fri, 13 May 2022 10:20:43 +0800 Subject: [PATCH] feat: middleware (#208) * feat: middleware * feat: dynamicly add query params func * feat: common params * update: go mod tidy * feat: batchExec --- app/utils/http.ts | 36 +-- config/webpack.prod.js | 2 +- server-v2/api/studio/etc/studio-api.yaml | 4 +- .../handler/gateway/batchexecngqlhandler.go | 33 +++ .../handler/gateway/disonnecthandler.go | 33 +++ .../api/studio/internal/handler/routes.go | 10 + .../logic/gateway/batchexecngqllogic.go | 29 +++ .../internal/logic/gateway/disonnectlogic.go | 29 +++ .../internal/logic/gateway/execngqllogic.go | 2 +- .../api/studio/internal/service/gateway.go | 83 +++---- server-v2/api/studio/internal/types/types.go | 14 +- server-v2/api/studio/pkg/auth/authorize.go | 213 +++++++++++------- server-v2/api/studio/pkg/base/types.go | 4 +- server-v2/api/studio/pkg/ecode/codes.go | 6 + server-v2/api/studio/pkg/utils/http.go | 164 ++++---------- server-v2/api/studio/pkg/utils/route.go | 58 ----- server-v2/api/studio/restapi/gateway.api | 21 +- server-v2/api/studio/studio.go | 16 +- server-v2/go.mod | 6 +- server-v2/go.sum | 22 +- 20 files changed, 440 insertions(+), 345 deletions(-) create mode 100644 server-v2/api/studio/internal/handler/gateway/batchexecngqlhandler.go create mode 100644 server-v2/api/studio/internal/handler/gateway/disonnecthandler.go create mode 100644 server-v2/api/studio/internal/logic/gateway/batchexecngqllogic.go create mode 100644 server-v2/api/studio/internal/logic/gateway/disonnectlogic.go delete mode 100644 server-v2/api/studio/pkg/utils/route.go diff --git a/app/utils/http.ts b/app/utils/http.ts index 2ca64362..eff4ee22 100644 --- a/app/utils/http.ts +++ b/app/utils/http.ts @@ -6,13 +6,17 @@ import intl from 'react-intl-universal'; import { getRootStore } from '@app/stores'; import { trackEvent } from './stat'; -const subErrMsgStr = [ - 'session expired', - 'connection refused', - 'broken pipe', - 'an existing connection was forcibly closed', - 'Token is expired', -]; +export enum HttpResCode { + ErrBadRequest = 40004000, + ErrParam = 40004001, + ErrUnauthorized = 40104000, + ErrSession = 40104001, + ErrForbidden = 40304000, + ErrNotFound = 40404000, + ErrInternalServer = 50004000, + ErrNotImplemented = 50104000, + ErrUnknown = 90004000, +} const service = axios.create({ transformResponse: [ @@ -39,24 +43,20 @@ service.interceptors.request.use(config => { service.interceptors.response.use( (response: any) => { - const { code, message: errMsg } = response.data; - const isConnectReq = /api-nebula\/db\/connect$/.test(response.config?.url); - // if connection refused, login again - if (code === -1 && new RegExp(subErrMsgStr.join('|')).test(errMsg)) { - message.warning(errMsg); - !isConnectReq && getRootStore().global.logout(); - } else if (code === -1 && errMsg) { - message.warning(errMsg); - } - return response.data; + const isExecReq = /api-nebula\/db\/(exec|batchExec)$/.test(response.config?.url); + return isExecReq ? response.data?.data : response.data; }, (error: any) => { - if (error.response && error.response.status) { + if (error.response?.status) { message.error( `${intl.get('common.requestError')}: ${error.response.status} ${ error.response.statusText }`, ); + // relogin + if (error.response.data?.code === HttpResCode.ErrSession) { + getRootStore().global.logout(); + } return error.response; } else { message.error(`${intl.get('common.requestError')}: ${error}`); diff --git a/config/webpack.prod.js b/config/webpack.prod.js index e0f19da4..2fe7b62f 100644 --- a/config/webpack.prod.js +++ b/config/webpack.prod.js @@ -13,7 +13,7 @@ const publicConfig = { path: path.join(__dirname, '../dist/'), filename: '[name].[chunkhash].js', chunkFilename: '[name].[contenthash].js', - publicPath: '/assets/', + publicPath: '/', }, module: { rules: [ diff --git a/server-v2/api/studio/etc/studio-api.yaml b/server-v2/api/studio/etc/studio-api.yaml index 002e4cd9..0d12cbb3 100644 --- a/server-v2/api/studio/etc/studio-api.yaml +++ b/server-v2/api/studio/etc/studio-api.yaml @@ -1,11 +1,11 @@ Name: studio-api Host: 0.0.0.0 -Port: 7002 +Port: 9000 MaxBytes: 1073741824 Debug: Enable: false Auth: AccessSecret: "login_secret" - AccessExpire: 7200 + AccessExpire: 1800 File: UploadDir: "./upload/" \ No newline at end of file diff --git a/server-v2/api/studio/internal/handler/gateway/batchexecngqlhandler.go b/server-v2/api/studio/internal/handler/gateway/batchexecngqlhandler.go new file mode 100644 index 00000000..56338b7f --- /dev/null +++ b/server-v2/api/studio/internal/handler/gateway/batchexecngqlhandler.go @@ -0,0 +1,33 @@ +// Code generated by goctl. DO NOT EDIT. +package gateway + +import ( + "net/http" + + "github.com/vesoft-inc/go-pkg/validator" + "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/ecode" + + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/logic/gateway" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types" + "github.com/zeromicro/go-zero/rest/httpx" +) + +func BatchExecNGQLHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + var req types.BatchExecNGQLParams + if err := httpx.Parse(r, &req); err != nil { + err = ecode.WithCode(ecode.ErrParam, err) + svcCtx.ResponseHandler.Handle(w, r, nil, err) + return + } + if err := validator.Struct(req); err != nil { + svcCtx.ResponseHandler.Handle(w, r, nil, err) + return + } + + l := gateway.NewBatchExecNGQLLogic(r.Context(), svcCtx) + data, err := l.BatchExecNGQL(req) + svcCtx.ResponseHandler.Handle(w, r, data, err) + } +} diff --git a/server-v2/api/studio/internal/handler/gateway/disonnecthandler.go b/server-v2/api/studio/internal/handler/gateway/disonnecthandler.go new file mode 100644 index 00000000..ef7418dd --- /dev/null +++ b/server-v2/api/studio/internal/handler/gateway/disonnecthandler.go @@ -0,0 +1,33 @@ +// Code generated by goctl. DO NOT EDIT. +package gateway + +import ( + "net/http" + + "github.com/vesoft-inc/go-pkg/validator" + "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/ecode" + + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/logic/gateway" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types" + "github.com/zeromicro/go-zero/rest/httpx" +) + +func DisonnectHandler(svcCtx *svc.ServiceContext) http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + var req types.DisconnectDBParams + if err := httpx.Parse(r, &req); err != nil { + err = ecode.WithCode(ecode.ErrParam, err) + svcCtx.ResponseHandler.Handle(w, r, nil, err) + return + } + if err := validator.Struct(req); err != nil { + svcCtx.ResponseHandler.Handle(w, r, nil, err) + return + } + + l := gateway.NewDisonnectLogic(r.Context(), svcCtx) + data, err := l.Disonnect(req) + svcCtx.ResponseHandler.Handle(w, r, data, err) + } +} diff --git a/server-v2/api/studio/internal/handler/routes.go b/server-v2/api/studio/internal/handler/routes.go index f47653c5..c6b5e76d 100644 --- a/server-v2/api/studio/internal/handler/routes.go +++ b/server-v2/api/studio/internal/handler/routes.go @@ -30,6 +30,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) { Path: "/exec", Handler: gateway.ExecNGQLHandler(serverCtx), }, + { + Method: http.MethodPost, + Path: "/batchExec", + Handler: gateway.BatchExecNGQLHandler(serverCtx), + }, }, rest.WithPrefix("/api-nebula/db"), ) @@ -41,6 +46,11 @@ func RegisterHandlers(server *rest.Server, serverCtx *svc.ServiceContext) { Path: "/connect", Handler: gateway.ConnectHandler(serverCtx), }, + { + Method: http.MethodPost, + Path: "/disconnect", + Handler: gateway.DisonnectHandler(serverCtx), + }, }, rest.WithPrefix("/api-nebula/db"), ) diff --git a/server-v2/api/studio/internal/logic/gateway/batchexecngqllogic.go b/server-v2/api/studio/internal/logic/gateway/batchexecngqllogic.go new file mode 100644 index 00000000..9d9d52f0 --- /dev/null +++ b/server-v2/api/studio/internal/logic/gateway/batchexecngqllogic.go @@ -0,0 +1,29 @@ +package gateway + +import ( + "context" + + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types" + + "github.com/zeromicro/go-zero/core/logx" +) + +type BatchExecNGQLLogic struct { + logx.Logger + ctx context.Context + svcCtx *svc.ServiceContext +} + +func NewBatchExecNGQLLogic(ctx context.Context, svcCtx *svc.ServiceContext) BatchExecNGQLLogic { + return BatchExecNGQLLogic{ + Logger: logx.WithContext(ctx), + ctx: ctx, + svcCtx: svcCtx, + } +} + +func (l *BatchExecNGQLLogic) BatchExecNGQL(req types.BatchExecNGQLParams) (*types.AnyResponse, error) { + return service.NewGatewayService(l.ctx, l.svcCtx).BatchExecNGQL(&req) +} diff --git a/server-v2/api/studio/internal/logic/gateway/disonnectlogic.go b/server-v2/api/studio/internal/logic/gateway/disonnectlogic.go new file mode 100644 index 00000000..a49cd1aa --- /dev/null +++ b/server-v2/api/studio/internal/logic/gateway/disonnectlogic.go @@ -0,0 +1,29 @@ +package gateway + +import ( + "context" + + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/service" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types" + + "github.com/zeromicro/go-zero/core/logx" +) + +type DisonnectLogic struct { + logx.Logger + ctx context.Context + svcCtx *svc.ServiceContext +} + +func NewDisonnectLogic(ctx context.Context, svcCtx *svc.ServiceContext) DisonnectLogic { + return DisonnectLogic{ + Logger: logx.WithContext(ctx), + ctx: ctx, + svcCtx: svcCtx, + } +} + +func (l *DisonnectLogic) Disonnect(req types.DisconnectDBParams) (*types.AnyResponse, error) { + return service.NewGatewayService(l.ctx, l.svcCtx).DisconnectDB(&req) +} diff --git a/server-v2/api/studio/internal/logic/gateway/execngqllogic.go b/server-v2/api/studio/internal/logic/gateway/execngqllogic.go index bc5244ee..f16f31b4 100644 --- a/server-v2/api/studio/internal/logic/gateway/execngqllogic.go +++ b/server-v2/api/studio/internal/logic/gateway/execngqllogic.go @@ -25,5 +25,5 @@ func NewExecNGQLLogic(ctx context.Context, svcCtx *svc.ServiceContext) ExecNGQLL } func (l *ExecNGQLLogic) ExecNGQL(req types.ExecNGQLParams) (resp *types.AnyResponse, err error) { - return service.NewGatewayService(l.ctx, l.svcCtx).GetExec(&req) + return service.NewGatewayService(l.ctx, l.svcCtx).ExecNGQL(&req) } diff --git a/server-v2/api/studio/internal/service/gateway.go b/server-v2/api/studio/internal/service/gateway.go index 87ee65cb..fdbc6218 100644 --- a/server-v2/api/studio/internal/service/gateway.go +++ b/server-v2/api/studio/internal/service/gateway.go @@ -2,14 +2,12 @@ package service import ( "context" - "encoding/base64" - "fmt" "strings" "github.com/vesoft-inc/nebula-http-gateway/ccore/nebula/gateway/dao" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types" - "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/auth" + "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/base" "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/ecode" "github.com/zeromicro/go-zero/core/logx" @@ -19,8 +17,10 @@ var _ GatewayService = (*gatewayService)(nil) type ( GatewayService interface { - GetExec(request *types.ExecNGQLParams) (*types.AnyResponse, error) + ExecNGQL(request *types.ExecNGQLParams) (*types.AnyResponse, error) + BatchExecNGQL(request *types.BatchExecNGQLParams) (*types.AnyResponse, error) ConnectDB(request *types.ConnectDBParams) (*types.ConnectDBResult, error) + DisconnectDB(request *types.DisconnectDBParams) (*types.AnyResponse, error) } gatewayService struct { @@ -38,50 +38,57 @@ func NewGatewayService(ctx context.Context, svcCtx *svc.ServiceContext) GatewayS } } -func (s *gatewayService) GetExec(request *types.ExecNGQLParams) (*types.AnyResponse, error) { - return &types.AnyResponse{ - Data: map[string]any{ - "message": "ok", - }, +func (s *gatewayService) ConnectDB(request *types.ConnectDBParams) (*types.ConnectDBResult, error) { + return &types.ConnectDBResult{ + Version: string(request.NebulaVersion), }, nil } -func (s *gatewayService) ConnectDB(request *types.ConnectDBParams) (*types.ConnectDBResult, error) { - fmt.Println("======request999", request) - tokenSplit := strings.Split(request.Authorization, " ") - if len(tokenSplit) != 2 { - return nil, ecode.WithCode(ecode.ErrParam, nil, "invalid authorization") +func (s *gatewayService) DisconnectDB(request *types.DisconnectDBParams) (*types.AnyResponse, error) { + if request.NSID != "" { + dao.Disconnect(request.NSID) } + return nil, nil +} - decode, err := base64.StdEncoding.DecodeString(tokenSplit[1]) +func (s *gatewayService) ExecNGQL(request *types.ExecNGQLParams) (*types.AnyResponse, error) { + execute, _, err := dao.Execute(request.NSID, request.Gql, request.ParamList) if err != nil { - return nil, ecode.WithCode(ecode.ErrParam, err) + return nil, ecode.WithCode(ecode.ErrInternalServer, err, "exec failed") } + return &types.AnyResponse{Data: execute}, nil +} - loginInfo := strings.Split(string(decode), ":") - if len(loginInfo) < 2 { - return nil, ecode.WithCode(ecode.ErrParam, nil, "len of account is less than two") +func (s *gatewayService) BatchExecNGQL(request *types.BatchExecNGQLParams) (*types.AnyResponse, error) { + data := make([]map[string]interface{}, 0) + + NSID := request.NSID + gqls := request.Gqls + paramList := request.ParamList + + for _, gql := range gqls { + execute, _, err := dao.Execute(NSID, gql, make([]string, 0)) + gqlRes := map[string]interface{}{"gql": gql, "data": execute} + if err != nil { + gqlRes["message"] = err.Error() + gqlRes["code"] = base.Error + } else { + gqlRes["code"] = base.Success + } + data = append(data, gqlRes) } - username, password := loginInfo[0], loginInfo[1] - clientInfo, err := dao.Connect(request.Address, request.Port, username, password) - - tokenString, err := auth.CreateToken( - &auth.AuthData{ - NebulaAddress: request.Address, - Username: username, - ClientID: clientInfo.ClientID, - }, - &s.svcCtx.Config, - ) - - fmt.Println("=====tokenString", tokenString) - - if err != nil { - return nil, ecode.WithInternalServer(err, "connect db failed") + if len(paramList) > 0 { + execute, _, err := dao.Execute(NSID, "", paramList) + gqlRes := map[string]interface{}{"gql": strings.Join(paramList, "; "), "data": execute} + if err != nil { + gqlRes["message"] = err.Error() + gqlRes["code"] = base.Error + } else { + gqlRes["code"] = base.Success + } + data = append(data, gqlRes) } - return &types.ConnectDBResult{ - Version: string(clientInfo.NebulaVersion), - }, nil + return &types.AnyResponse{Data: data}, nil } diff --git a/server-v2/api/studio/internal/types/types.go b/server-v2/api/studio/internal/types/types.go index 373f0ca5..ee697dba 100644 --- a/server-v2/api/studio/internal/types/types.go +++ b/server-v2/api/studio/internal/types/types.go @@ -7,12 +7,20 @@ type GetHealth struct { type ExecNGQLParams struct { Gql string `json:"gql"` - ParamList []string `json:"paramList"` + ParamList []string `json:"paramList,optional"` + NSID string `form:"NSID"` +} + +type BatchExecNGQLParams struct { + Gqls []string `json:"gqls"` + ParamList []string `json:"paramList,optional"` + NSID string `form:"NSID"` } type ConnectDBParams struct { Address string `json:"address"` Port int `json:"port"` + NebulaVersion string `form:"nebulaVersion,optional"` Authorization string `header:"Authorization"` } @@ -20,6 +28,10 @@ type ConnectDBResult struct { Version string `json:"version"` } +type DisconnectDBParams struct { + NSID string `form:"NSID,optional"` +} + type AnyResponse struct { Data interface{} `json:"data"` } diff --git a/server-v2/api/studio/pkg/auth/authorize.go b/server-v2/api/studio/pkg/auth/authorize.go index b75c27f9..6cc6bced 100644 --- a/server-v2/api/studio/pkg/auth/authorize.go +++ b/server-v2/api/studio/pkg/auth/authorize.go @@ -2,6 +2,7 @@ package auth import ( "encoding/base64" + "errors" "fmt" "net/http" "strings" @@ -9,8 +10,12 @@ import ( "github.com/golang-jwt/jwt/v4" "github.com/vesoft-inc/nebula-http-gateway/ccore/nebula/gateway/dao" + "github.com/vesoft-inc/nebula-http-gateway/ccore/nebula/gateway/pool" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/config" + "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/types" + "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/ecode" + "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/utils" "github.com/zeromicro/go-zero/rest" "github.com/zeromicro/go-zero/rest/httpx" ) @@ -19,18 +24,21 @@ type ( CtxKeyUserInfo struct{} AuthData struct { - NebulaAddress string `json:"nebulaAddress"` - Username string `json:"username"` - ClientID string `json:"clientID"` + Address string `json:"address"` + Port int `json:"port"` + Username string `json:"username"` } authClaims struct { *AuthData - jwt.StandardClaims + jwt.RegisteredClaims } ) -var globalConfig = new(config.Config) +var ( + tokenName = "explorer_token" + nsidName = "explorer_nsid" +) func CreateToken(authData *AuthData, config *config.Config) (string, error) { now := time.Now() @@ -39,117 +47,158 @@ func CreateToken(authData *AuthData, config *config.Config) (string, error) { token := jwt.NewWithClaims(jwt.SigningMethodHS256, authClaims{ AuthData: authData, - StandardClaims: jwt.StandardClaims{ - ExpiresAt: expiresAt, + RegisteredClaims: jwt.RegisteredClaims{ + ExpiresAt: &jwt.NumericDate{Time: time.Unix(expiresAt, 0)}, + // ExpiresAt: expiresAt, }, }) return token.SignedString([]byte(config.Auth.AccessSecret)) } -func AuthMiddlewareWithConfig(config *config.Config) rest.Middleware { - return func(next http.HandlerFunc) http.HandlerFunc { - return func(w http.ResponseWriter, r *http.Request) { - // login handler - if strings.HasSuffix(r.URL.Path, "/connect") { - fmt.Println("=====global middleware", r.URL.Path) - var req types.ConnectDBParams - err := httpx.Parse(r, &req) - if err != nil { - fmt.Println("=====req3333", req) - } - fmt.Println("=====err", err) - fmt.Println("=====req.Address", req.Address) - fmt.Println("=====req.Port", req.Port) - fmt.Println("=====req.Authorization", req.Authorization) - } - c1 := http.Cookie{ - Name: "access_token", - Value: "12333", - Path: "/", - HttpOnly: true, - MaxAge: 3600, - } - - var req1 types.ConnectDBParams - err1 := httpx.Parse(r, &req1) - fmt.Println("=====err1=====", err1) +func Decode(tokenString, secret string) (*AuthData, error) { + auth := authClaims{} + token, err := jwt.ParseWithClaims(tokenString, &auth, func(token *jwt.Token) (interface{}, error) { + if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok { + return nil, fmt.Errorf("unexpected signing method: %v", token.Header["alg"]) + } + return []byte(secret), nil + }) - w.Header().Set("Access-Control-Allow-Origin", "*") - w.Header().Set("Set-Cookie", c1.String()) - next(w, r) + if err != nil { + if ve, ok := err.(*jwt.ValidationError); ok { + if ve.Errors&jwt.ValidationErrorMalformed != 0 { + return nil, errors.New("that's not even a token") + } else if ve.Errors&jwt.ValidationErrorExpired != 0 { + return nil, errors.New("token is expired") + } else if ve.Errors&jwt.ValidationErrorNotValidYet != 0 { + return nil, errors.New("token not active yet") + } else { + return nil, errors.New("couldn't handle this token") + } } } -} -func AuthMiddleware(next http.HandlerFunc) http.HandlerFunc { - return func(w http.ResponseWriter, r *http.Request) { - // login handler - if strings.HasSuffix(r.URL.Path, "/connect") { - fmt.Println("=====global middleware", r.URL.Path) - } - c1 := http.Cookie{ - Name: "access_token", - Value: "12333", - Path: "/", - HttpOnly: true, - MaxAge: 3600, - } - w.Header().Set("Access-Control-Allow-Origin", "*") - w.Header().Set("Set-Cookie", c1.String()) - next(w, r) + if _, ok := token.Claims.(*authClaims); !ok || !token.Valid { + return nil, errors.New("couldn't handle this token") } + + return auth.AuthData, nil } -func GenerateLoginToken(address string, port int, authorization string, config *config.Config) (string, error) { - tokenSplit := strings.Split(authorization, " ") +func parseConnectDBParams(params *types.ConnectDBParams, config *config.Config) (string, *pool.ClientInfo, error) { + tokenSplit := strings.Split(params.Authorization, " ") if len(tokenSplit) != 2 { - return "", fmt.Errorf("invalid authorization") + return "", nil, ecode.WithCode(ecode.ErrParam, nil, "invalid authorization") } decode, err := base64.StdEncoding.DecodeString(tokenSplit[1]) if err != nil { - return "", err + return "", nil, ecode.WithCode(ecode.ErrParam, err) } loginInfo := strings.Split(string(decode), ":") if len(loginInfo) < 2 { - return "", fmt.Errorf("len of account is less than two") + return "", nil, ecode.WithCode(ecode.ErrParam, nil, "len of account is less than two") } username, password := loginInfo[0], loginInfo[1] - clientInfo, err := dao.Connect(address, port, username, password) - + clientInfo, err := dao.Connect(params.Address, params.Port, username, password) if err != nil { - return "", err + return "", nil, ecode.WithCode(ecode.ErrInternalServer, err) } - return CreateToken( + tokenString, err := CreateToken( &AuthData{ - NebulaAddress: address, - Username: username, - ClientID: clientInfo.ClientID, + Address: params.Address, + Port: params.Port, + Username: username, }, config, ) + return tokenString, clientInfo, err } -func (d *AuthData) Decode(tokenString, secret string) error { - token, err := jwt.ParseWithClaims(tokenString, &authClaims{ - AuthData: d, - }, func(token *jwt.Token) (interface{}, error) { - if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok { - return nil, fmt.Errorf("unexpected signing method: %v", token.Header["alg"]) - } - return []byte(secret), nil - }) - if err != nil { - return err - } +func AuthMiddlewareWithCtx(svcCtx *svc.ServiceContext) rest.Middleware { + return func(next http.HandlerFunc) http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + configAuth := svcCtx.Config.Auth - if _, ok := token.Claims.(*authClaims); !ok || !token.Valid { - return fmt.Errorf("jwt parse not valid") - } + // login handler + if strings.HasSuffix(r.URL.Path, "/connect") { + var req types.ConnectDBParams + rClone := utils.CopyHttpRequest(r) + err := httpx.Parse(rClone, &req) + if err != nil { + http.Error(w, err.Error(), http.StatusBadRequest) + return + } + + tokenString, clientInfo, err := parseConnectDBParams(&req, &svcCtx.Config) + if err != nil { + http.Error(w, err.Error(), http.StatusBadRequest) + return + } + + token := http.Cookie{ + Name: tokenName, + Value: tokenString, + Path: "/", + HttpOnly: true, + MaxAge: int(configAuth.AccessExpire), + } + NSID := http.Cookie{ + Name: nsidName, + Value: clientInfo.ClientID, + Path: "/", + HttpOnly: true, + MaxAge: int(configAuth.AccessExpire), + } + + utils.AddQueryParams(r, map[string]string{"nebulaVersion": string(clientInfo.NebulaVersion)}) - return nil + w.Header().Set("Set-Cookie", token.String()) + w.Header().Add("Set-Cookie", NSID.String()) + + next(w, r) + return + } + + NSIDCookie, NSIDErr := r.Cookie(nsidName) + if NSIDErr == nil { + // Add NSID to request query + utils.AddQueryParams(r, map[string]string{"NSID": NSIDCookie.Value}) + } + + if strings.HasSuffix(r.URL.Path, "/disconnect") { + w.Header().Set("Set-Cookie", utils.DisabledCookie(tokenName).String()) + w.Header().Add("Set-Cookie", utils.DisabledCookie(nsidName).String()) + next(w, r) + return + } + + tokenCookie, tokenErr := r.Cookie(tokenName) + if NSIDErr != nil || tokenErr != nil { + if NSIDErr != nil { + svcCtx.ResponseHandler.Handle(w, r, nil, ecode.WithSessionMessage(NSIDErr)) + return + } + } + + auth, authErr := Decode(tokenCookie.Value, configAuth.AccessSecret) + if authErr != nil { + svcCtx.ResponseHandler.Handle(w, r, nil, ecode.WithSessionMessage(authErr)) + return + } + + // Add address|port|username to request query + utils.AddQueryParams(r, map[string]string{ + "address": auth.Address, + "port": fmt.Sprintf("%d", auth.Port), + "username": auth.Username, + }) + + next(w, r) + } + } } diff --git a/server-v2/api/studio/pkg/base/types.go b/server-v2/api/studio/pkg/base/types.go index a1319637..de47fbb6 100644 --- a/server-v2/api/studio/pkg/base/types.go +++ b/server-v2/api/studio/pkg/base/types.go @@ -2,11 +2,9 @@ package base type StatusCode int -type Result any +type Result interface{} const ( Error StatusCode = -1 Success StatusCode = 0 - // TODO: need to del it - AuthorizationError StatusCode = 401 ) diff --git a/server-v2/api/studio/pkg/ecode/codes.go b/server-v2/api/studio/pkg/ecode/codes.go index 7b8770e4..37feb4ca 100644 --- a/server-v2/api/studio/pkg/ecode/codes.go +++ b/server-v2/api/studio/pkg/ecode/codes.go @@ -1,6 +1,7 @@ package ecode import ( + "fmt" "net/http" ) @@ -46,6 +47,11 @@ func WithUnauthorized(err error, formatWithArgs ...interface{}) error { return WithCode(ErrUnauthorized, err, formatWithArgs...) } +func WithSessionMessage(err error, formatWithArgs ...interface{}) error { + ErrSessionWithMessage := newErrCode(CCUnauthorized, PlatformCode, 1, fmt.Sprintf("ErrSession::%s", err.Error())) + return WithCode(ErrSessionWithMessage, err, formatWithArgs...) +} + func WithForbidden(err error, formatWithArgs ...interface{}) error { return WithCode(ErrForbidden, err, formatWithArgs...) } diff --git a/server-v2/api/studio/pkg/utils/http.go b/server-v2/api/studio/pkg/utils/http.go index f81d283f..0ad3b8cb 100644 --- a/server-v2/api/studio/pkg/utils/http.go +++ b/server-v2/api/studio/pkg/utils/http.go @@ -1,128 +1,56 @@ package utils +import ( + "bytes" + "io" + "io/ioutil" + "net/http" +) + const MIMEOctetStream = "application/octet-stream" -// GetMIME returns the content-type of a file extension -func GetMIME(extension string) (mime string) { - if len(extension) == 0 { - return mime +func CopyHttpRequest(r *http.Request) *http.Request { + reqCopy := new(http.Request) + + if r == nil { + return reqCopy } - if extension[0] == '.' { - mime = mimeExtensions[extension[1:]] - } else { - mime = mimeExtensions[extension] + + *reqCopy = *r + + if r.Body != nil { + defer r.Body.Close() + + // Buffer body data + var bodyBuffer bytes.Buffer + newBodyBuffer := new(bytes.Buffer) + + io.Copy(&bodyBuffer, r.Body) + *newBodyBuffer = bodyBuffer + + // Create new ReadClosers so we can split output + r.Body = ioutil.NopCloser(&bodyBuffer) + reqCopy.Body = ioutil.NopCloser(newBodyBuffer) } - if len(mime) == 0 { - return MIMEOctetStream + + return reqCopy +} + +func DisabledCookie(name string) *http.Cookie { + return &http.Cookie{ + Name: name, + Value: "", + Path: "/", + HttpOnly: true, + MaxAge: -1, } - return mime } -// MIME types were copied from https://github.com/nginx/nginx/blob/master/conf/mime.types -var mimeExtensions = map[string]string{ - "html": "text/html", - "htm": "text/html", - "shtml": "text/html", - "css": "text/css", - "gif": "image/gif", - "jpeg": "image/jpeg", - "jpg": "image/jpeg", - "xml": "application/xml", - "js": "application/javascript", - "atom": "application/atom+xml", - "rss": "application/rss+xml", - "mml": "text/mathml", - "txt": "text/plain", - "jad": "text/vnd.sun.j2me.app-descriptor", - "wml": "text/vnd.wap.wml", - "htc": "text/x-component", - "png": "image/png", - "svg": "image/svg+xml", - "svgz": "image/svg+xml", - "tif": "image/tiff", - "tiff": "image/tiff", - "wbmp": "image/vnd.wap.wbmp", - "webp": "image/webp", - "ico": "image/x-icon", - "jng": "image/x-jng", - "bmp": "image/x-ms-bmp", - "woff": "font/woff", - "woff2": "font/woff2", - "jar": "application/java-archive", - "war": "application/java-archive", - "ear": "application/java-archive", - "json": "application/json", - "hqx": "application/mac-binhex40", - "doc": "application/msword", - "pdf": "application/pdf", - "ps": "application/postscript", - "eps": "application/postscript", - "ai": "application/postscript", - "rtf": "application/rtf", - "m3u8": "application/vnd.apple.mpegurl", - "kml": "application/vnd.google-earth.kml+xml", - "kmz": "application/vnd.google-earth.kmz", - "xls": "application/vnd.ms-excel", - "eot": "application/vnd.ms-fontobject", - "ppt": "application/vnd.ms-powerpoint", - "odg": "application/vnd.oasis.opendocument.graphics", - "odp": "application/vnd.oasis.opendocument.presentation", - "ods": "application/vnd.oasis.opendocument.spreadsheet", - "odt": "application/vnd.oasis.opendocument.text", - "wmlc": "application/vnd.wap.wmlc", - "7z": "application/x-7z-compressed", - "cco": "application/x-cocoa", - "jardiff": "application/x-java-archive-diff", - "jnlp": "application/x-java-jnlp-file", - "run": "application/x-makeself", - "pl": "application/x-perl", - "pm": "application/x-perl", - "prc": "application/x-pilot", - "pdb": "application/x-pilot", - "rar": "application/x-rar-compressed", - "rpm": "application/x-redhat-package-manager", - "sea": "application/x-sea", - "swf": "application/x-shockwave-flash", - "sit": "application/x-stuffit", - "tcl": "application/x-tcl", - "tk": "application/x-tcl", - "der": "application/x-x509-ca-cert", - "pem": "application/x-x509-ca-cert", - "crt": "application/x-x509-ca-cert", - "xpi": "application/x-xpinstall", - "xhtml": "application/xhtml+xml", - "xspf": "application/xspf+xml", - "zip": "application/zip", - "bin": "application/octet-stream", - "exe": "application/octet-stream", - "dll": "application/octet-stream", - "deb": "application/octet-stream", - "dmg": "application/octet-stream", - "iso": "application/octet-stream", - "img": "application/octet-stream", - "msi": "application/octet-stream", - "msp": "application/octet-stream", - "msm": "application/octet-stream", - "mid": "audio/midi", - "midi": "audio/midi", - "kar": "audio/midi", - "mp3": "audio/mpeg", - "ogg": "audio/ogg", - "m4a": "audio/x-m4a", - "ra": "audio/x-realaudio", - "3gpp": "video/3gpp", - "3gp": "video/3gpp", - "ts": "video/mp2t", - "mp4": "video/mp4", - "mpeg": "video/mpeg", - "mpg": "video/mpeg", - "mov": "video/quicktime", - "webm": "video/webm", - "flv": "video/x-flv", - "m4v": "video/x-m4v", - "mng": "video/x-mng", - "asx": "video/x-ms-asf", - "asf": "video/x-ms-asf", - "wmv": "video/x-ms-wmv", - "avi": "video/x-msvideo", +// dynamicly add query params to the request +func AddQueryParams(r *http.Request, params map[string]string) { + query := r.URL.Query() + for k, v := range params { + query.Set(k, v) + } + r.URL, _ = r.URL.Parse(r.URL.Path + "?" + query.Encode()) } diff --git a/server-v2/api/studio/pkg/utils/route.go b/server-v2/api/studio/pkg/utils/route.go deleted file mode 100644 index 13ad7ef6..00000000 --- a/server-v2/api/studio/pkg/utils/route.go +++ /dev/null @@ -1,58 +0,0 @@ -package utils - -import ( - "embed" - "net/http" - "path" - "path/filepath" - "strconv" - "strings" - - "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" - "github.com/zeromicro/go-zero/core/logx" - "github.com/zeromicro/go-zero/rest" -) - -var embedAssetsFolder = "assets" - -func RegisterHandlers(engine *rest.Server, serverCtx *svc.ServiceContext, fs embed.FS) { - dirlevel := []string{"/:1", ":2", ":3", ":4", ":5", ":6", ":7", ":8"} - for i := 1; i < len(dirlevel); i++ { - pathname := strings.Join(dirlevel[:i], "/") - //最后生成 /asset - engine.AddRoute( - rest.Route{ - Method: http.MethodGet, - Path: pathname, - Handler: filehandler(fs), - }) - logx.Infof("register route %s", pathname) - } -} - -func filehandler(fs embed.FS) http.HandlerFunc { - return func(w http.ResponseWriter, req *http.Request) { - fileType := filepath.Ext(req.URL.Path) - // subpath default: index.html - if len(fileType) == 0 { - htmlFileData, _ := fs.ReadFile(path.Join(embedAssetsFolder, "index.html")) - w.Write(htmlFileData) - return - } - - // assets file: a/b/c.(js|css|png) - data, err := fs.ReadFile(path.Join(embedAssetsFolder, req.URL.Path)) - if err != nil { - logx.Errorf("open resource error %s", err.Error()) - http.NotFound(w, req) - return - } - - // set assets response header - w.Header().Set("Content-Type", GetMIME(fileType)+"; charset=utf-8") - w.Header().Set("Content-Length", strconv.Itoa(len(data))) - w.Header().Set("Cache-Control", "public, max-age=7200") - - w.Write(data) - } -} diff --git a/server-v2/api/studio/restapi/gateway.api b/server-v2/api/studio/restapi/gateway.api index 006dab1d..baee6de6 100644 --- a/server-v2/api/studio/restapi/gateway.api +++ b/server-v2/api/studio/restapi/gateway.api @@ -3,17 +3,26 @@ syntax = "v1" type ( ExecNGQLParams { Gql string `json:"gql"` - ParamList []string `json:"paramList"` + ParamList []string `json:"paramList,optional"` + NSID string `form:"NSID"` + } + BatchExecNGQLParams { + Gqls []string `json:"gqls"` + ParamList []string `json:"paramList,optional"` + NSID string `form:"NSID"` } ConnectDBParams { Address string `json:"address"` Port int `json:"port"` + NebulaVersion string `form:"nebulaVersion,optional"` Authorization string `header:"Authorization"` } ConnectDBResult { Version string `json:"version"` } - + DisconnectDBParams { + NSID string `form:"NSID,optional"` + } AnyResponse { Data interface{} `json:"data"` } @@ -28,6 +37,10 @@ service studio-api { @doc "Exec NGQL" @handler ExecNGQL post /exec(ExecNGQLParams) returns (AnyResponse) + + @doc "BatchExec NGQL" + @handler BatchExecNGQL + post /batchExec(BatchExecNGQLParams) returns (AnyResponse) } @server( @@ -39,4 +52,8 @@ service studio-api { @doc "Connect DB" @handler Connect post /connect(ConnectDBParams) returns (ConnectDBResult) + + @doc "Disonnect DB" + @handler Disonnect + post /disconnect(DisconnectDBParams) returns (AnyResponse) } \ No newline at end of file diff --git a/server-v2/api/studio/studio.go b/server-v2/api/studio/studio.go index 101e5787..55a1258e 100644 --- a/server-v2/api/studio/studio.go +++ b/server-v2/api/studio/studio.go @@ -4,12 +4,13 @@ import ( "embed" "flag" "fmt" + "net/http" + "github.com/vesoft-inc/go-pkg/middleware" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/config" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/handler" "github.com/vesoft-inc/nebula-studio/server/api/studio/internal/svc" "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/auth" - "github.com/vesoft-inc/nebula-studio/server/api/studio/pkg/utils" "github.com/zeromicro/go-zero/core/conf" "github.com/zeromicro/go-zero/rest" @@ -27,15 +28,16 @@ func main() { conf.MustLoad(*configFile, &c, conf.UseEnv()) svcCtx := svc.NewServiceContext(c) - server := rest.MustNewServer(c.RestConf) + server := rest.MustNewServer(c.RestConf, rest.WithNotFoundHandler(middleware.NewAssetsHandler(middleware.AssetsConfig{ + Root: "assets", + Filesystem: http.FS(embedAssets), + SPA: true, + }))) + defer server.Stop() // global middleware - // server.Use(auth.AuthMiddleware) - server.Use(auth.AuthMiddlewareWithConfig(&c)) - - // static assets handlers - utils.RegisterHandlers(server, svcCtx, embedAssets) + server.Use(auth.AuthMiddlewareWithCtx(svcCtx)) // api handlers handler.RegisterHandlers(server, svcCtx) diff --git a/server-v2/go.mod b/server-v2/go.mod index cf55c8de..1bafbe9b 100644 --- a/server-v2/go.mod +++ b/server-v2/go.mod @@ -1,9 +1,9 @@ module github.com/vesoft-inc/nebula-studio/server -go 1.18 +go 1.17 require ( - github.com/vesoft-inc/go-pkg v0.0.0-20220415101753-97328ddf3e40 + github.com/vesoft-inc/go-pkg v0.0.0-20220511092334-a180a9379d8d github.com/zeromicro/go-zero v1.3.3 ) @@ -16,6 +16,7 @@ require ( ) require ( + github.com/axgle/mahonia v0.0.0-20180208002826-3358181d7394 github.com/beorn7/perks v1.0.1 // indirect github.com/cespare/xxhash/v2 v2.1.2 // indirect github.com/go-logr/logr v1.2.2 // indirect @@ -36,6 +37,7 @@ require ( github.com/prometheus/client_model v0.2.0 // indirect github.com/prometheus/common v0.30.0 // indirect github.com/prometheus/procfs v0.7.3 // indirect + github.com/saintfish/chardet v0.0.0-20120816061221-3af4cd4741ca github.com/spaolacci/murmur3 v1.1.0 // indirect go.opentelemetry.io/otel v1.3.0 // indirect go.opentelemetry.io/otel/exporters/jaeger v1.3.0 // indirect diff --git a/server-v2/go.sum b/server-v2/go.sum index 94fe5128..f6c28bf6 100644 --- a/server-v2/go.sum +++ b/server-v2/go.sum @@ -58,6 +58,8 @@ github.com/alicebob/gopher-json v0.0.0-20200520072559-a9ecdc9d1d3a/go.mod h1:SGn github.com/alicebob/miniredis/v2 v2.17.0/go.mod h1:gquAfGbzn92jvtrSC69+6zZnwSODVXVpYDRaGhWaL6I= github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= github.com/asaskevich/govalidator v0.0.0-20190424111038-f61b66f89f4a/go.mod h1:lB+ZfQJz7igIIfQNfa7Ml4HSf2uFQQRzpGGRXenZAgY= +github.com/axgle/mahonia v0.0.0-20180208002826-3358181d7394 h1:OYA+5W64v3OgClL+IrOD63t4i/RW7RqrAVl9LTZ9UqQ= +github.com/axgle/mahonia v0.0.0-20180208002826-3358181d7394/go.mod h1:Q8n74mJTIgjX4RBBcHnJ05h//6/k6foqmgE45jTQtxg= github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8= github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q= @@ -330,6 +332,7 @@ github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINE github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/prashantv/gostub v1.1.0 h1:BTyx3RfQjRHnUWaGF9oQos79AlQ5k8WNktv7VGvVH4g= +github.com/prashantv/gostub v1.1.0/go.mod h1:A5zLQHz7ieHGG7is6LLXLz7I8+3LZzsrV0P1IAHhP5U= github.com/prometheus/client_golang v0.9.1/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw= github.com/prometheus/client_golang v1.0.0/go.mod h1:db9x61etRT2tGnBNRi70OPL5FsnadC4Ky3P0J6CfImo= github.com/prometheus/client_golang v1.7.1/go.mod h1:PY5Wy2awLA44sXw4AOSfFBetzPP4j5+D6mVACh+pe2M= @@ -360,6 +363,8 @@ github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTE github.com/rogpeppe/go-internal v1.8.0 h1:FCbCCtXNOY3UtUuHUYaghJg4y7Fd14rXifAYUAtL9R8= github.com/rogpeppe/go-internal v1.8.0/go.mod h1:WmiCO8CzOY8rg0OYDC4/i/2WRWAB6poM+XZ2dLUbcbE= github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM= +github.com/saintfish/chardet v0.0.0-20120816061221-3af4cd4741ca h1:NugYot0LIVPxTvN8n+Kvkn6TrbMyxQiuvKdEwFdR9vI= +github.com/saintfish/chardet v0.0.0-20120816061221-3af4cd4741ca/go.mod h1:uugorj2VCxiV1x+LzaIdVa9b4S4qGAcH6cbhh4qVxOU= github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b h1:gQZ0qzfKHQIybLANtM3mBXNUtOfsCFXeTsnBqCsx1KM= github.com/satori/go.uuid v1.2.1-0.20181028125025-b2ce2384e17b/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0= github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc= @@ -383,10 +388,11 @@ github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.7.1 h1:5TQK59W5E3v0r2duFAb7P95B6hEeOyEnHRa8MjYSMTY= +github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk= github.com/urfave/cli/v2 v2.3.0/go.mod h1:LJmUH05zAU44vOAcrfzZQKsZbVcdbOG8rtL3/XcUArI= -github.com/vesoft-inc/go-pkg v0.0.0-20220415101753-97328ddf3e40 h1:vBoIYZyRgxHFDaCc/4NfkH/rVjYNnDYqg8cMczWb7vU= -github.com/vesoft-inc/go-pkg v0.0.0-20220415101753-97328ddf3e40/go.mod h1:HCAXRhF2io+nPLQnl+RQ6XyVcp1Xdv6NgslXRBBCiEU= +github.com/vesoft-inc/go-pkg v0.0.0-20220511092334-a180a9379d8d h1:Q/eVc0H8CuQNmviD43vAxtJKyB3aFd9R8Z7pOdxokoA= +github.com/vesoft-inc/go-pkg v0.0.0-20220511092334-a180a9379d8d/go.mod h1:HCAXRhF2io+nPLQnl+RQ6XyVcp1Xdv6NgslXRBBCiEU= github.com/vesoft-inc/nebula-http-gateway/ccore v0.0.0-20220413113447-a3f4c56287d8 h1:iL92Uk6hAe4vUBK/L99wf5295HYOtnD4plctVA5xek0= github.com/vesoft-inc/nebula-http-gateway/ccore v0.0.0-20220413113447-a3f4c56287d8/go.mod h1:sFEvE+cY4TgwqWx6H6msOqAUzRhsEHHKaaMgIZENHuQ= github.com/xdg-go/pbkdf2 v1.0.0/go.mod h1:jrpuAogTd400dnrH08LKmI/xc1MbPOebTwRqcT5RDeI= @@ -399,8 +405,6 @@ github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9de github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k= github.com/yuin/gopher-lua v0.0.0-20200816102855-ee81675732da/go.mod h1:E1AXubJBdNmFERAOucpDIxNzeGfLzg0mYh+UfMWdChA= -github.com/zeromicro/go-zero v1.3.2 h1:2HcmceZDEGwZWvofCG+0GXyh+Gtz/wKCW4Fq8Mb7KIg= -github.com/zeromicro/go-zero v1.3.2/go.mod h1:DEj3Fwj1Ui1ltsgf6YqwTL9nD4+tYzIRX0c1pWtQo1E= github.com/zeromicro/go-zero v1.3.3 h1:6qv9PcfqfB1tMgp1FJlP1LfWSZ4XD+FwojvA2h5LL2k= github.com/zeromicro/go-zero v1.3.3/go.mod h1:LwuYc2V04ZHhWPWGJYQ+kJ5DT4QSkeaZGqXiQcpkfks= go.etcd.io/etcd/api/v3 v3.5.2/go.mod h1:5GB2vv4A4AOn3yk7MftYGHkUfGtDHnEraIjym4dYz5A= @@ -522,7 +526,6 @@ golang.org/x/net v0.0.0-20210525063256-abc453219eb5/go.mod h1:9nx3DQGgdP8bBQD5qx golang.org/x/net v0.0.0-20210917221730-978cfadd31cf/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20211029224645-99673261e6eb/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= -golang.org/x/net v0.0.0-20220225172249-27dd8689420f h1:oA4XRj0qtSt8Yo1Zms0CUlsT3KG69V2UGQWPBxujDmc= golang.org/x/net v0.0.0-20220225172249-27dd8689420f/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk= golang.org/x/net v0.0.0-20220421235706-1d1ef9303861 h1:yssD99+7tqHWO5Gwh81phT+67hg+KttniBr6UnEXOY8= golang.org/x/net v0.0.0-20220421235706-1d1ef9303861/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk= @@ -598,8 +601,6 @@ golang.org/x/sys v0.0.0-20210603081109-ebe580a85c40/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20210806184541-e5e7981a1069/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220227234510-4e6760a101f9 h1:nhht2DYV/Sn3qOayu8lM+cU1ii9sTLUeBQwQQfUHtrs= -golang.org/x/sys v0.0.0-20220227234510-4e6760a101f9/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220422013727-9388b58f7150 h1:xHms4gcpe1YE7A3yIllJXP16CMAGuqwO2lX1mTyyRRc= golang.org/x/sys v0.0.0-20220422013727-9388b58f7150/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw= @@ -726,8 +727,6 @@ google.golang.org/genproto v0.0.0-20200729003335-053ba62fc06f/go.mod h1:FWY/as6D google.golang.org/genproto v0.0.0-20200804131852-c06518451d9c/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20200825200019-8632dd797987/go.mod h1:FWY/as6DDZQgahTzZj3fqbO1CbirC29ZNUFHwi0/+no= google.golang.org/genproto v0.0.0-20210602131652-f16073e35f0c/go.mod h1:UODoCrxHCcBojKKwX1terBiRUaqAsFqJiF615XL43r0= -google.golang.org/genproto v0.0.0-20220228195345-15d65a4533f7 h1:ntPPoHzFW6Xp09ueznmahONZufyoSakK/piXnr2BU3I= -google.golang.org/genproto v0.0.0-20220228195345-15d65a4533f7/go.mod h1:kGP+zUP2Ddo0ayMi4YuN7C3WZyJvGLZRh8Z5wnAqvEI= google.golang.org/genproto v0.0.0-20220422154200-b37d22cd5731 h1:nquqdM9+ps0JZcIiI70+tqoaIFS5Ql4ZuK8UXnz3HfE= google.golang.org/genproto v0.0.0-20220422154200-b37d22cd5731/go.mod h1:8w6bsBMX6yCPbAVTeqQHvzxW0EIFigd5lZyahWgyfDo= google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= @@ -746,8 +745,6 @@ google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTp google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= google.golang.org/grpc v1.38.0/go.mod h1:NREThFqKR1f3iQ6oBuvc5LadQuXVGo9rkm5ZGrQdJfM= google.golang.org/grpc v1.41.0/go.mod h1:U3l9uK9J0sini8mHphKoXyaqDA/8VyGnDee1zzIUK6k= -google.golang.org/grpc v1.44.0 h1:weqSxi/TMs1SqFRMHCtBgXRs8k3X39QIDEZ0pRcttUg= -google.golang.org/grpc v1.44.0/go.mod h1:k+4IHHFw41K8+bbowsex27ge2rCb65oeWqe4jJ590SU= google.golang.org/grpc v1.45.0/go.mod h1:lN7owxKUQEqMfSyQikvvk5tf/6zMPsrK+ONuO11+0rQ= google.golang.org/grpc v1.46.0 h1:oCjezcn6g6A75TGoKYBPgKmVBLexhYLM6MebdrPApP8= google.golang.org/grpc v1.46.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= @@ -763,11 +760,11 @@ google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGj google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= -google.golang.org/protobuf v1.27.1 h1:SnqbnDw1V7RiZcXPx5MEeqPv2s79L9i7BJUlG/+RurQ= google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= google.golang.org/protobuf v1.28.0 h1:w43yiav+6bVFTBQFZX0r7ipe9JQ1QsbMgHwbBziscLw= google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= gopkg.in/alecthomas/kingpin.v2 v2.2.6/go.mod h1:FMv+mEhP44yOT+4EoQTLFTRgOQ1FBLkstjWtayDeSgw= +gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc/go.mod h1:m7x9LTH6d71AHyAX77c9yqWCCa3UKHcVEj9y7hAtKDk= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= @@ -776,6 +773,7 @@ gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EV gopkg.in/cheggaaa/pb.v1 v1.0.28/go.mod h1:V/YB90LKu/1FcN3WVnfiiE5oMCibMjukxqG/qStrOgw= gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= gopkg.in/fsnotify.v1 v1.4.7/go.mod h1:Tz8NjZHkW78fSQdbUxIjBTcgA1z1m8ZHf0WmKUhAMys= +gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df/go.mod h1:LRQQ+SO6ZHR7tOkpBDuZnXENFzX8qRjMDMyPD6BRkCw= gopkg.in/h2non/gock.v1 v1.1.2 h1:jBbHXgGBK/AoPVfJh5x4r/WxIrElvbLel8TCZkkZJoY= gopkg.in/h2non/gock.v1 v1.1.2/go.mod h1:n7UGz/ckNChHiK05rDoiC4MYSunEC/lyaUm2WWaDva0= gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw=