Function verifyRPCAuth

grpc_auth.go:191–216

(ctx context.Context, indexName string, req interface{})

}

func verifyRPCAuth(ctx context.Context, indexName string, req interface{}) error {
	if _, err := extractMetaHeader(ctx, rpcClusterActionKey); err == nil {
		return nil
	}

	var authHandler gRPCAuthHandler
	if aw := ctx.Value(gRPCAuthHandlerKey); aw != nil {
		authHandler = aw.(gRPCAuthHandler)
	}

	if authHandler == nil {
		return fmt.Errorf("grpc_auth: invalid authHandler")
	}

	v, err := authHandler(
		&rpcRequestParser{indexName: indexName,
			request: req})
	if err != nil {
		return fmt.Errorf("grpc_auth: auth err: %v", err)
	}
	if !v {
		return fmt.Errorf("grpc_auth: permission denied")
	}

	return nil
}