Files
tasks/common/authorization/interceptor.go
Yu XiaandGitHub bda96b1a72 Fix replication task execution latency (#3671)
* Fix replication task execution latency

* Fix emit latency
2022-11-28 12:33:42 -08:00

236 lines
7.2 KiB
Go

// The MIT License
//
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
//
// Copyright (c) 2020 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
package authorization
import (
"context"
"crypto/x509"
"crypto/x509/pkix"
"time"
"go.temporal.io/api/serviceerror"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
"google.golang.org/grpc/metadata"
"google.golang.org/grpc/peer"
"go.temporal.io/server/common/log"
"go.temporal.io/server/common/log/tag"
"go.temporal.io/server/common/metrics"
)
type (
contextKeyMappedClaims struct{}
contextKeyAuthHeader struct{}
)
type (
// JWTAudienceMapper returns JWT audience for a given request
JWTAudienceMapper interface {
Audience(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo) string
}
)
const (
RequestUnauthorized = "Request unauthorized."
)
var (
errUnauthorized = serviceerror.NewPermissionDenied(RequestUnauthorized, "")
MappedClaims contextKeyMappedClaims
AuthHeader contextKeyAuthHeader
)
func (a *interceptor) Interceptor(
ctx context.Context,
req interface{},
info *grpc.UnaryServerInfo,
handler grpc.UnaryHandler,
) (interface{}, error) {
var claims *Claims
if a.claimMapper != nil && a.authorizer != nil {
var tlsSubject *pkix.Name
var authHeaders []string
var authExtraHeaders []string
var tlsConnection *credentials.TLSInfo
if md, ok := metadata.FromIncomingContext(ctx); ok {
authHeaders = md["authorization"]
authExtraHeaders = md["authorization-extras"]
}
tlsConnection = TLSInfoFormContext(ctx)
clientCert := PeerCert(tlsConnection)
if clientCert != nil {
tlsSubject = &clientCert.Subject
}
// Add auth info to context only if there's some auth info
if tlsSubject != nil || len(authHeaders) > 0 {
var authHeader string
var authExtraHeader string
var audience string
if len(authHeaders) > 0 {
authHeader = authHeaders[0]
}
if len(authExtraHeaders) > 0 {
authExtraHeader = authExtraHeaders[0]
}
if a.audienceGetter != nil {
audience = a.audienceGetter.Audience(ctx, req, info)
}
authInfo := AuthInfo{
AuthToken: authHeader,
TLSSubject: tlsSubject,
TLSConnection: tlsConnection,
ExtraData: authExtraHeader,
Audience: audience,
}
mappedClaims, err := a.claimMapper.GetClaims(&authInfo)
if err != nil {
a.logAuthError(err)
return nil, errUnauthorized // return a generic error to the caller without disclosing details
}
claims = mappedClaims
ctx = context.WithValue(ctx, MappedClaims, mappedClaims)
if authHeader != "" {
ctx = context.WithValue(ctx, AuthHeader, authHeader)
}
}
}
if a.authorizer != nil {
var namespace string
requestWithNamespace, ok := req.(hasNamespace)
if ok {
namespace = requestWithNamespace.GetNamespace()
}
handler := a.getMetricsHandler(metrics.AuthorizationScope, namespace)
result, err := a.authorize(ctx, claims, &CallTarget{
Namespace: namespace,
APIName: info.FullMethod,
Request: req,
}, handler)
if err != nil {
handler.Counter(metrics.ServiceErrAuthorizeFailedCounter.GetMetricName()).Record(1)
a.logAuthError(err)
return nil, errUnauthorized // return a generic error to the caller without disclosing details
}
if result.Decision != DecisionAllow {
handler.Counter(metrics.ServiceErrUnauthorizedCounter.GetMetricName()).Record(1)
// if a reason is included in the result, include it in the error message
if result.Reason != "" {
return nil, serviceerror.NewPermissionDenied(RequestUnauthorized, result.Reason)
}
return nil, errUnauthorized // return a generic error to the caller without disclosing details
}
}
return handler(ctx, req)
}
func (a *interceptor) authorize(
ctx context.Context,
claims *Claims,
callTarget *CallTarget,
metricsHandler metrics.MetricsHandler) (Result, error) {
startTime := time.Now().UTC()
defer func() {
metricsHandler.Timer(metrics.ServiceAuthorizationLatency.GetMetricName()).Record(time.Since(startTime))
}()
return a.authorizer.Authorize(ctx, claims, callTarget)
}
func (a *interceptor) logAuthError(err error) {
a.logger.Error("Authorization error", tag.Error(err))
}
type interceptor struct {
authorizer Authorizer
claimMapper ClaimMapper
metricsHandler metrics.MetricsHandler
logger log.Logger
audienceGetter JWTAudienceMapper
}
// NewAuthorizationInterceptor creates an authorization interceptor and return a func that points to its Interceptor method
func NewAuthorizationInterceptor(
claimMapper ClaimMapper,
authorizer Authorizer,
metricsHandler metrics.MetricsHandler,
logger log.Logger,
audienceGetter JWTAudienceMapper,
) grpc.UnaryServerInterceptor {
return (&interceptor{
claimMapper: claimMapper,
authorizer: authorizer,
metricsHandler: metricsHandler,
logger: logger,
audienceGetter: audienceGetter,
}).Interceptor
}
// getMetricsHandler return metrics handler with namespace tag
func (a *interceptor) getMetricsHandler(
operation string,
namespace string,
) metrics.MetricsHandler {
var handler metrics.MetricsHandler
if namespace != "" {
handler = a.metricsHandler.WithTags(metrics.OperationTag(operation), metrics.NamespaceTag(namespace))
} else {
handler = a.metricsHandler.WithTags(metrics.OperationTag(operation), metrics.NamespaceUnknownTag())
}
return handler
}
func TLSInfoFormContext(ctx context.Context) *credentials.TLSInfo {
p, ok := peer.FromContext(ctx)
if !ok {
return nil
}
if tlsInfo, ok := p.AuthInfo.(credentials.TLSInfo); ok {
return &tlsInfo
}
return nil
}
func PeerCert(tlsInfo *credentials.TLSInfo) *x509.Certificate {
if tlsInfo == nil || len(tlsInfo.State.VerifiedChains) == 0 || len(tlsInfo.State.VerifiedChains[0]) == 0 {
return nil
}
// The assumption here is that we only expect a single verified chain of certs (first[0]).
// It's unclear how we should handle a situation when more than one chain is presented,
// which subject to use. It's okay for us to limit ourselves to one chain.
// We can always extend this logic later.
// We take the first element in the chain ([0]) because that's the client cert
// (at the beginning of the chain), not intermediary CAs or the root CA (at the end of the chain).
return tlsInfo.State.VerifiedChains[0][0]
}