diff --git a/service/internal/auth/casbin_test.go b/service/internal/auth/casbin_test.go
index a67f45fb0b..89bd9d392c 100644
--- a/service/internal/auth/casbin_test.go
+++ b/service/internal/auth/casbin_test.go
@@ -617,3 +617,55 @@ func (s *AuthnCasbinSuite) newTokenWithCilentID() (string, jwt.Token) {
 	}
 	return "", tok
 }
+
+func (s *AuthnCasbinSuite) Test_AttributeBasedPolicy() {
+	// Create a Casbin enforcer with an attribute-aware model
+	modelConf := `
+[request_definition]
+r = sub, res, act, owner
+
+[policy_definition]
+p = sub, res, act, owner, eft
+
+[role_definition]
+g = _, _
+
+[policy_effect]
+e = some(where (p.eft == allow)) && !some(where (p.eft == deny))
+
+[matchers]
+m = g(r.sub, p.sub) && keyMatch(r.res, p.res) && keyMatch(r.act, p.act) && (p.owner == "*" || r.owner == p.owner)
+`
+
+	policyCSV := `
+p, role:admin, /policy/*, read, *, allow
+p, role:user, /policy/*, read, user123, allow
+g, admin-user, role:admin
+g, regular-user, role:user
+`
+
+	casbinCfg := CasbinConfig{
+		PolicyConfig: PolicyConfig{
+			Model: modelConf,
+			Csv:   policyCSV,
+		},
+	}
+	enforcer, err := NewCasbinEnforcer(casbinCfg, logger.CreateTestLogger())
+	s.Require().NoError(err)
+	s.Require().NotNil(enforcer)
+
+	// Test 1: Admin can access any resource
+	allowed, err := enforcer.Enforcer.Enforce("role:admin", "/policy/attributes", "read", "*")
+	s.Require().NoError(err)
+	s.Require().True(allowed, "admin should have access")
+
+	// Test 2: User can only access their own resources
+	allowed, err = enforcer.Enforcer.Enforce("role:user", "/policy/attributes", "read", "user123")
+	s.Require().NoError(err)
+	s.Require().True(allowed, "user should have access to their own resource")
+
+	// Test 3: User cannot access other user's resources
+	allowed, err = enforcer.Enforcer.Enforce("role:user", "/policy/attributes", "read", "user456")
+	s.Require().NoError(err)
+	s.Require().False(allowed, "user should NOT have access to other user's resource")
+}
diff --git a/service/internal/auth/protovalidate_interceptor.go b/service/internal/auth/protovalidate_interceptor.go
new file mode 100644
index 0000000000..324524521d
--- /dev/null
+++ b/service/internal/auth/protovalidate_interceptor.go
@@ -0,0 +1,203 @@
+package auth
+
+import (
+	"context"
+	"fmt"
+	"strconv"
+
+	"buf.build/go/protovalidate"
+	"connectrpc.com/connect"
+	"github.com/lestrrat-go/jwx/v2/jwt"
+	"google.golang.org/protobuf/proto"
+	"google.golang.org/protobuf/reflect/protoreflect"
+)
+
+// ProtoAttrMapper extracts selected proto fields and converts them to
+// casbin-request attributes. Enforces whitelist-only access to ensure
+// ONLY configured fields are available to authorization policies.
+type ProtoAttrMapper struct {
+	// Allowed fields to extract and expose to Casbin (whitelist-only)
+	Allowed []string
+	// RequiredFields that must exist on the request (subset of Allowed)
+	RequiredFields []string
+	// Validate controls whether to run protovalidate on the incoming message
+	Validate bool
+	// validator is initialized once and reused across all requests
+	validator protovalidate.Validator
+}
+
+// NewProtoAttrMapper creates a new ProtoAttrMapper with the given configuration.
+// If Validate is true, it initializes the protovalidate validator and panics on failure
+// to prevent the service from running in a misconfigured state.
+func NewProtoAttrMapper(allowed []string, requiredFields []string, validate bool) *ProtoAttrMapper {
+	p := &ProtoAttrMapper{
+		Allowed:        allowed,
+		RequiredFields: requiredFields,
+		Validate:       validate,
+	}
+
+	if validate {
+		v, err := protovalidate.New()
+		if err != nil {
+			panic(fmt.Sprintf("failed to initialize protovalidate validator: %v", err))
+		}
+		p.validator = v
+	}
+
+	return p
+}
+
+// Interceptor returns a ConnectRPC unary interceptor that validates the
+// request protobuf using protovalidate and attaches a map[string]string of
+// attributes to the context for downstream enforcement.
+func (p *ProtoAttrMapper) Interceptor(e *Enforcer) connect.UnaryInterceptorFunc {
+	interceptor := func(next connect.UnaryFunc) connect.UnaryFunc {
+		return connect.UnaryFunc(func(ctx context.Context, req connect.AnyRequest) (connect.AnyResponse, error) {
+			reqAny := req.Any()
+			if reqAny == nil {
+				return next(ctx, req)
+			}
+
+			m, ok := reqAny.(proto.Message)
+			if !ok {
+				return next(ctx, req)
+			}
+
+			// Validate proto message using protovalidate if enabled
+			if err := p.validateMessage(m); err != nil {
+				return nil, err
+			}
+
+			// Extract whitelisted attributes and validate required fields
+			attrs, err := p.extractAttributes(m)
+			if err != nil {
+				return nil, err
+			}
+
+			// Attach attrs to context for downstream enforcement
+			// SECURITY: Only whitelisted fields are in this map - no other request
+			// fields are accessible to Casbin policy evaluation
+			ctx = context.WithValue(ctx, casbinContextKey("casbin_attrs"), attrs)
+
+			// Optionally perform synchronous enforcement
+			if err := p.enforceAccess(ctx, req, e); err != nil {
+				return nil, err
+			}
+
+			return next(ctx, req)
+		})
+	}
+	return connect.UnaryInterceptorFunc(interceptor)
+}
+
+// validateMessage validates the proto message using protovalidate if enabled
+func (p *ProtoAttrMapper) validateMessage(m proto.Message) error {
+	if !p.Validate || p.validator == nil {
+		return nil
+	}
+
+	if err := p.validator.Validate(m); err != nil {
+		return connect.NewError(connect.CodeInvalidArgument, fmt.Errorf("protovalidate failed: %w", err))
+	}
+	return nil
+}
+
+// extractAttributes builds the attributes map from whitelisted fields
+func (p *ProtoAttrMapper) extractAttributes(m proto.Message) (map[string]string, error) {
+	attrs := map[string]string{}
+	mr := m.ProtoReflect()
+
+	// Extract whitelisted fields
+	for _, allow := range p.Allowed {
+		if val, valOK := lookupProtoFieldString(mr, allow); valOK {
+			attrs[allow] = val
+		}
+	}
+
+	// Validate required fields are present
+	for _, required := range p.RequiredFields {
+		if _, exists := attrs[required]; !exists {
+			return nil, connect.NewError(
+				connect.CodeInvalidArgument,
+				fmt.Errorf("required field %q is missing or invalid", required),
+			)
+		}
+	}
+
+	return attrs, nil
+}
+
+// enforceAccess performs Casbin enforcement if an enforcer is configured
+func (p *ProtoAttrMapper) enforceAccess(ctx context.Context, req connect.AnyRequest, e *Enforcer) error {
+	if e == nil {
+		return nil
+	}
+
+	tk, tkOK := ctx.Value(tokenContextKey{}).(jwt.Token)
+	if !tkOK {
+		return nil
+	}
+
+	res := req.Spec().Procedure
+	act := req.Spec().Procedure
+
+	allowed, err := e.Enforce(tk, res, act)
+	if allowed {
+		return nil
+	}
+
+	if err == nil {
+		err = fmt.Errorf("permission denied for %s", req.Spec().Procedure)
+	}
+	return connect.NewError(connect.CodePermissionDenied, err)
+}
+
+// helper to lookup a field on a protoreflect.Message and
+// return its string value if present.
+func lookupProtoFieldString(m protoreflect.Message, path string) (string, bool) {
+	// Only support single-level fields for now to keep simple
+	fld := m.Descriptor().Fields().ByName(protoreflect.Name(path))
+	if fld == nil {
+		return "", false
+	}
+	v := m.Get(fld)
+	if !v.IsValid() {
+		return "", false
+	}
+	// Convert scalar to string if possible
+	switch fld.Kind() { //nolint:exhaustive // only handle supported types
+	case protoreflect.StringKind:
+		s := v.String()
+		// Treat empty strings as missing for required field validation
+		if s == "" {
+			return "", false
+		}
+		return s, true
+	case protoreflect.Int32Kind, protoreflect.Int64Kind:
+		return strconv.FormatInt(v.Int(), 10), true
+	case protoreflect.Uint32Kind, protoreflect.Uint64Kind:
+		return strconv.FormatUint(v.Uint(), 10), true
+	case protoreflect.BoolKind:
+		return strconv.FormatBool(v.Bool()), true
+	default:
+		// Unsupported field types (enums, bytes, messages, etc.) are not extracted
+		return "", false
+	}
+}
+
+// context keys
+type (
+	casbinContextKey string
+	tokenContextKey  struct{}
+)
+
+// GetCasbinAttrsFromContext retrieves the extracted proto attributes from the context.
+// Returns the attributes map and true if present, or nil and false if not found.
+func GetCasbinAttrsFromContext(ctx context.Context) (map[string]string, bool) {
+	v := ctx.Value(casbinContextKey("casbin_attrs"))
+	if v == nil {
+		return nil, false
+	}
+	attrs, ok := v.(map[string]string)
+	return attrs, ok
+}
diff --git a/service/internal/auth/protovalidate_interceptor_test.go b/service/internal/auth/protovalidate_interceptor_test.go
new file mode 100644
index 0000000000..a711456293
--- /dev/null
+++ b/service/internal/auth/protovalidate_interceptor_test.go
@@ -0,0 +1,170 @@
+package auth
+
+import (
+	"context"
+	"testing"
+
+	"connectrpc.com/connect"
+	"github.com/opentdf/platform/protocol/go/common"
+	"github.com/stretchr/testify/suite"
+)
+
+func TestProtoAttrMapperSuite(t *testing.T) {
+	suite.Run(t, new(ProtoAttrMapperSuite))
+}
+
+type ProtoAttrMapperSuite struct {
+	suite.Suite
+}
+
+func (s *ProtoAttrMapperSuite) Test_Interceptor() {
+	mapper := NewProtoAttrMapper([]string{"name", "id"}, nil, false)
+
+	// create a simple proto message from policy namespace that has string fields
+	msg := &common.IdNameIdentifier{
+		Id:   "abc",
+		Name: "example",
+	}
+
+	// create a no-op next handler that checks context for attrs
+	next := func(ctx context.Context, _ connect.AnyRequest) (connect.AnyResponse, error) {
+		v := ctx.Value(casbinContextKey("casbin_attrs"))
+		s.Require().NotNil(v)
+		m, ok := v.(map[string]string)
+		s.Require().True(ok)
+		s.Require().Equal("example", m["name"])
+		s.Require().Equal("abc", m["id"])
+		return connect.NewResponse[any](nil), nil
+	}
+
+	interceptor := mapper.Interceptor(nil)
+	wrapped := interceptor(next)
+
+	// Build a connect request wrapper
+	req := connect.NewRequest(msg)
+	_, err := wrapped(context.Background(), req)
+	s.Require().NoError(err)
+}
+
+func (s *ProtoAttrMapperSuite) Test_RequiredFields_MissingFieldShouldFail() {
+	mapper := NewProtoAttrMapper(
+		[]string{"name", "id"},
+		[]string{"name", "id"},
+		false,
+	)
+
+	// Message missing 'name' field (empty string)
+	msg := &common.IdNameIdentifier{
+		Id:   "abc",
+		Name: "", // empty/missing
+	}
+
+	next := func(_ context.Context, _ connect.AnyRequest) (connect.AnyResponse, error) {
+		s.T().Fatal("should not reach next handler")
+		return connect.NewResponse[any](nil), nil
+	}
+
+	interceptor := mapper.Interceptor(nil)
+	wrapped := interceptor(next)
+
+	req := connect.NewRequest(msg)
+	_, err := wrapped(context.Background(), req)
+	s.Require().Error(err)
+	s.Require().Contains(err.Error(), "required field")
+	s.Require().Contains(err.Error(), "name")
+}
+
+func (s *ProtoAttrMapperSuite) Test_RequiredFields_AllPresentShouldSucceed() {
+	mapper := NewProtoAttrMapper(
+		[]string{"name", "id"},
+		[]string{"name"},
+		false,
+	)
+
+	msg := &common.IdNameIdentifier{
+		Id:   "abc",
+		Name: "example",
+	}
+
+	next := func(ctx context.Context, _ connect.AnyRequest) (connect.AnyResponse, error) {
+		v := ctx.Value(casbinContextKey("casbin_attrs"))
+		s.Require().NotNil(v)
+		return connect.NewResponse[any](nil), nil
+	}
+
+	interceptor := mapper.Interceptor(nil)
+	wrapped := interceptor(next)
+
+	req := connect.NewRequest(msg)
+	_, err := wrapped(context.Background(), req)
+	s.Require().NoError(err)
+}
+
+func (s *ProtoAttrMapperSuite) Test_WhitelistOnly() {
+	// Only allow 'name', not 'id'
+	mapper := NewProtoAttrMapper(
+		[]string{"name"},
+		nil,
+		false,
+	)
+
+	msg := &common.IdNameIdentifier{
+		Id:   "secret-id-should-not-be-exposed",
+		Name: "example",
+	}
+
+	next := func(ctx context.Context, _ connect.AnyRequest) (connect.AnyResponse, error) {
+		v := ctx.Value(casbinContextKey("casbin_attrs"))
+		s.Require().NotNil(v)
+		m, ok := v.(map[string]string)
+		s.Require().True(ok)
+
+		// SECURITY TEST: only 'name' should be present
+		s.Require().Equal("example", m["name"])
+		s.Require().NotContains(m, "id", "id should NOT be in attrs - security violation")
+		s.Require().Len(m, 1, "only whitelisted fields should be present")
+		return connect.NewResponse[any](nil), nil
+	}
+
+	interceptor := mapper.Interceptor(nil)
+	wrapped := interceptor(next)
+
+	req := connect.NewRequest(msg)
+	_, err := wrapped(context.Background(), req)
+	s.Require().NoError(err)
+}
+
+func (s *ProtoAttrMapperSuite) Test_AttributeExtraction() {
+	mapper := NewProtoAttrMapper(
+		[]string{"name", "id"},
+		[]string{"id"},
+		false,
+	)
+
+	msg := &common.IdNameIdentifier{
+		Id:   "user123",
+		Name: "test-resource",
+	}
+
+	next := func(ctx context.Context, _ connect.AnyRequest) (connect.AnyResponse, error) {
+		v := ctx.Value(casbinContextKey("casbin_attrs"))
+		s.Require().NotNil(v)
+		attrs, ok := v.(map[string]string)
+		s.Require().True(ok)
+
+		// Verify extracted attributes are ready for enforcement
+		s.Require().Equal("user123", attrs["id"])
+		s.Require().Equal("test-resource", attrs["name"])
+
+		// These attrs can now be passed to Casbin Enforce with extended signature
+		// e.g., enforcer.Enforce(subject, resource, action, attrs["id"])
+		return connect.NewResponse[any](nil), nil
+	}
+
+	interceptor := mapper.Interceptor(nil)
+	wrapped := interceptor(next)
+
+	req := connect.NewRequest(msg)
+	_, err := wrapped(context.Background(), req)
+	s.Require().NoError(err)
+}