ing
This commit is contained in:
parent
780b3e3521
commit
8aa9dce840
|
@ -9,8 +9,6 @@ import (
|
|||
"git.loafle.net/commons_go/rpc/gateway"
|
||||
"git.loafle.net/commons_go/rpc/protocol"
|
||||
"git.loafle.net/commons_go/rpc/protocol/json"
|
||||
oogw "git.loafle.net/overflow/overflow_gateway_websocket"
|
||||
"google.golang.org/grpc/metadata"
|
||||
)
|
||||
|
||||
func newGatewayRPCServletHandler() GatewayRPCServletHandler {
|
||||
|
@ -37,7 +35,7 @@ func (sh *GatewayRPCServletHandlers) WriteNotification(servletCTX rpc.ServletCon
|
|||
}
|
||||
|
||||
func (sh *GatewayRPCServletHandlers) Invoke(servletCTX rpc.ServletContext, requestCodec protocol.RegistryCodec) (result interface{}, err error) {
|
||||
md := metadata.Pairs(oogw.GRPCUserIDKey, servletCTX.GetAttribute(oogw.SocketIDKey).(string))
|
||||
// md := metadata.Pairs(oogw.GRPCUserIDKey, servletCTX.GetAttribute(oogw.SocketIDKey).(string))
|
||||
// grpcCTX := metadata.NewOutgoingContext(context.Background(), md)
|
||||
|
||||
params, err := requestCodec.Params()
|
||||
|
|
Loading…
Reference in New Issue
Block a user