unistack-org/micro-server-grpc
4
0
Fork 2
Code Issues 3 Pull Requests Actions Packages Projects Releases 48 Wiki Activity

remove auth provider

Browse Source
This commit is contained in:
Asim Aslam 2020-07-19 11:37:40 +01:00 committed by Vasiliy Tolstov
parent b1988daa4e
commit 04cfa870dd
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
grpc.go
View File

@ -17,6 +17,7 @@ import (
"github.com/golang/protobuf/proto" "github.com/golang/protobuf/proto"
"github.com/micro/go-micro/v2/broker" "github.com/micro/go-micro/v2/broker"
"github.com/micro/go-micro/v2/errors" "github.com/micro/go-micro/v2/errors"
pberr "github.com/micro/go-micro/v2/errors/proto"
"github.com/micro/go-micro/v2/logger" "github.com/micro/go-micro/v2/logger"
meta "github.com/micro/go-micro/v2/metadata" meta "github.com/micro/go-micro/v2/metadata"
"github.com/micro/go-micro/v2/registry" "github.com/micro/go-micro/v2/registry"
@ -400,10 +401,17 @@ func (g *grpcServer) processRequest(stream grpc.ServerStream, service *service,
var errStatus *status.Status var errStatus *status.Status
switch verr := appErr.(type) { switch verr := appErr.(type) {
case *errors.Error: case *errors.Error:
perr := &pberr.Error{
Id: verr.Id,
Code: verr.Code,
Detail: verr.Detail,
Status: verr.Status,
}
// micro.Error now proto based and we can attach it to grpc status // micro.Error now proto based and we can attach it to grpc status
statusCode = microError(verr) statusCode = microError(verr)
statusDesc = verr.Error() statusDesc = verr.Error()
errStatus, err = status.New(statusCode, statusDesc).WithDetails(verr) errStatus, err = status.New(statusCode, statusDesc).WithDetails(perr)
if err != nil { if err != nil {
return err return err
} }
@ -472,10 +480,16 @@ func (g *grpcServer) processStream(stream grpc.ServerStream, service *service, m
var errStatus *status.Status var errStatus *status.Status
switch verr := appErr.(type) { switch verr := appErr.(type) {
case *errors.Error: case *errors.Error:
perr := &pberr.Error{
Id: verr.Id,
Code: verr.Code,
Detail: verr.Detail,
Status: verr.Status,
}
// micro.Error now proto based and we can attach it to grpc status // micro.Error now proto based and we can attach it to grpc status
statusCode = microError(verr) statusCode = microError(verr)
statusDesc = verr.Error() statusDesc = verr.Error()
errStatus, err = status.New(statusCode, statusDesc).WithDetails(verr) errStatus, err = status.New(statusCode, statusDesc).WithDetails(perr)
if err != nil { if err != nil {
return err return err
} }