You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
56 lines
1.3 KiB
56 lines
1.3 KiB
// Package grpc generate by warden_gen |
|
package grpc |
|
|
|
import ( |
|
"context" |
|
|
|
"go-common/app/service/main/open/api/grpc/v1" |
|
"go-common/app/service/main/open/service" |
|
"go-common/library/ecode" |
|
"go-common/library/net/rpc/warden" |
|
) |
|
|
|
// New Open warden rpc server |
|
func New(c *warden.ServerConfig, svr *service.Service) *warden.Server { |
|
w := warden.NewServer(c) |
|
v1.RegisterOpenServer(w.Server(), &openService{svr}) |
|
|
|
ws, err := w.Start() |
|
if err != nil { |
|
panic(err) |
|
} |
|
return ws |
|
} |
|
|
|
type openService struct { |
|
svr *service.Service |
|
} |
|
|
|
var _ v1.OpenServer = &openService{} |
|
|
|
// Ping check dao health. |
|
func (s *openService) Ping(ctx context.Context, req *v1.PingReq) (*v1.PingReply, error) { |
|
return nil, ecode.MethodNotAllowed |
|
} |
|
|
|
// Close close all dao. |
|
func (s *openService) Close(ctx context.Context, req *v1.CloseReq) (*v1.CloseReply, error) { |
|
return nil, ecode.MethodNotAllowed |
|
} |
|
|
|
// Secret . |
|
func (s *openService) Secret(ctx context.Context, req *v1.SecretReq) (*v1.SecretReply, error) { |
|
return nil, ecode.MethodNotAllowed |
|
} |
|
|
|
// AppID . |
|
func (s *openService) AppID(ctx context.Context, req *v1.AppIDReq) (*v1.AppIDReply, error) { |
|
appID, err := s.svr.AppID(ctx, req.AppKey) |
|
if err != nil { |
|
return nil, err |
|
} |
|
appIDReply := &v1.AppIDReply{ |
|
AppId: appID, |
|
} |
|
return appIDReply, nil |
|
}
|
|
|