akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

rpcperms: export macaroon interceptor methods

Browse Source 
Since we need access to these methods from external subservers in some
cases, we export them.
This commit is contained in:
Johan T. Halseth 2021-02-15 10:55:08 +01:00
parent 2877511fce
commit b2e0a7d684
No known key found for this signature in database
GPG Key ID: 15BAADA29DA20D26
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
rpcperms/interceptor.go
View File

@ -193,10 +193,10 @@ func (r *InterceptorChain) CreateServerOpts() []grpc.ServerOption {
// We'll add the macaroon interceptors. If macaroons aren't disabled, // We'll add the macaroon interceptors. If macaroons aren't disabled,
// then these interceptors will enforce macaroon authentication. // then these interceptors will enforce macaroon authentication.
unaryInterceptors = append( unaryInterceptors = append(
unaryInterceptors, r.macaroonUnaryServerInterceptor(), unaryInterceptors, r.MacaroonUnaryServerInterceptor(),
) )
strmInterceptors = append( strmInterceptors = append(
strmInterceptors, r.macaroonStreamServerInterceptor(), strmInterceptors, r.MacaroonStreamServerInterceptor(),
) )
// Get interceptors for Prometheus to gather gRPC performance metrics. // Get interceptors for Prometheus to gather gRPC performance metrics.
@ -300,9 +300,9 @@ func (r *InterceptorChain) checkMacaroon(ctx context.Context,
return validator.ValidateMacaroon(ctx, uriPermissions, fullMethod) return validator.ValidateMacaroon(ctx, uriPermissions, fullMethod)
} }
// macaroonUnaryServerInterceptor is a GRPC interceptor that checks whether the // MacaroonUnaryServerInterceptor is a GRPC interceptor that checks whether the
// request is authorized by the included macaroons. // request is authorized by the included macaroons.
func (r *InterceptorChain) macaroonUnaryServerInterceptor() grpc.UnaryServerInterceptor { func (r *InterceptorChain) MacaroonUnaryServerInterceptor() grpc.UnaryServerInterceptor {
return func(ctx context.Context, req interface{}, return func(ctx context.Context, req interface{},
info *grpc.UnaryServerInfo, info *grpc.UnaryServerInfo,
handler grpc.UnaryHandler) (interface{}, error) { handler grpc.UnaryHandler) (interface{}, error) {
@ -316,9 +316,9 @@ func (r *InterceptorChain) macaroonUnaryServerInterceptor() grpc.UnaryServerInte
} }
} }
// macaroonStreamServerInterceptor is a GRPC interceptor that checks whether // MacaroonStreamServerInterceptor is a GRPC interceptor that checks whether
// the request is authorized by the included macaroons. // the request is authorized by the included macaroons.
func (r *InterceptorChain) macaroonStreamServerInterceptor() grpc.StreamServerInterceptor { func (r *InterceptorChain) MacaroonStreamServerInterceptor() grpc.StreamServerInterceptor {
return func(srv interface{}, ss grpc.ServerStream, return func(srv interface{}, ss grpc.ServerStream,
info *grpc.StreamServerInfo, handler grpc.StreamHandler) error { info *grpc.StreamServerInfo, handler grpc.StreamHandler) error {