feat(policy): list attrs by namespace name

integration/attributes_test.go

@@ -248,19 +248,31 @@ func (s *AttributesSuite) Test_ListAttribute() {
 
 func (s *AttributesSuite) Test_ListAttributesByNamespace() {
 	// get all unique namespace_ids
-	nsIds := map[string]bool{}
+	namespaces := map[string]string{}
 	for _, f := range s.getAttributeFixtures() {
-		nsIds[f.NamespaceId] = true
+		namespaces[f.NamespaceId] = ""
 	}
-	// get all attributes by namespace
-	for nsId := range nsIds {
+	// list attributes by namespace id
+	for nsId := range namespaces {
 		list, err := s.db.PolicyClient.ListAllAttributes(s.ctx, policydb.StateAny, nsId)
 		assert.Nil(s.T(), err)
 		assert.NotNil(s.T(), list)
 		assert.NotEmpty(s.T(), list)
 		for _, l := range list {
 			assert.Equal(s.T(), nsId, l.Namespace.Id)
 		}
+		namespaces[nsId] = list[0].Namespace.Name
+	}
+
+	// list attributes by namespace name
+	for _, nsName := range namespaces {
+		list, err := s.db.PolicyClient.ListAllAttributes(s.ctx, policydb.StateAny, nsName)
+		assert.Nil(s.T(), err)
+		assert.NotNil(s.T(), list)
+		assert.NotEmpty(s.T(), list)
+		for _, l := range list {
+			assert.Equal(s.T(), nsName, l.Namespace.Name)
+		}
 	}
 }
 

services/policy/attributes/attributes.go

@@ -49,11 +49,11 @@ func (s *AttributesService) ListAttributes(ctx context.Context,
 	req *attributes.ListAttributesRequest,
 ) (*attributes.ListAttributesResponse, error) {
 	state := services.GetDbStateTypeTransformedEnum(req.State)
-	namespace_id := req.NamespaceId
+	namespace := req.Namespace
 	slog.Debug("listing attribute definitions", slog.String("state", state))
 	rsp := &attributes.ListAttributesResponse{}
 
-	list, err := s.dbClient.ListAllAttributes(ctx, state, namespace_id)
+	list, err := s.dbClient.ListAllAttributes(ctx, state, namespace)
 	if err != nil {
 		return nil, services.HandleError(err, services.ErrListRetrievalFailed)
 	}

services/policy/attributes/attributes.proto

@@ -29,7 +29,8 @@ message ValueKeyAccessServer {
 message ListAttributesRequest {
   // ACTIVE by default when not specified
   common.ActiveStateEnum state = 1;
-  string namespace_id = 2;
+  // can be id or name
+  string namespace = 2;
 }
 message ListAttributesResponse {
   repeated policy.Attribute attributes = 1;

services/policy/db/attributes.go

@@ -9,6 +9,7 @@ import (
 	"strings"
 
 	sq "github.com/Masterminds/squirrel"
+	"github.com/google/uuid"
 	"github.com/jackc/pgx/v5"
 	"github.com/opentdf/platform/internal/db"
 	"github.com/opentdf/platform/protocol/go/common"
@@ -59,7 +60,7 @@ type attributesSelectOptions struct {
 	withFqn           bool
 	withOneValueByFqn string
 	state             string
-	namespace_id      string
+	namespace         string
 }
 
 func attributesSelect(opts attributesSelectOptions) sq.SelectBuilder {
@@ -276,19 +277,24 @@ func listAllAttributesSql(opts attributesSelectOptions) (string, []interface{},
 		sb = sb.Where(sq.Eq{t.Field("active"): opts.state == StateActive})
 	}
 
-	if opts.namespace_id != "" {
-		sb = sb.Where(sq.Eq{t.Field("namespace_id"): opts.namespace_id})
+	if opts.namespace != "" {
+		_, err := uuid.Parse(opts.namespace)
+		if err == nil {
+			sb = sb.Where(sq.Eq{t.Field("namespace_id"): opts.namespace})
+		} else {
+			sb = sb.Where(sq.Eq{Tables.Namespaces.Field("name"): opts.namespace})
+		}
 	}
 	return sb.ToSql()
 }
 
-func (c PolicyDbClient) ListAllAttributes(ctx context.Context, state string, namespace_id string) ([]*policy.Attribute, error) {
+func (c PolicyDbClient) ListAllAttributes(ctx context.Context, state string, namespace string) ([]*policy.Attribute, error) {
 	opts := attributesSelectOptions{
 		withAttributeValues: true,
 		withKeyAccessGrants: false,
 		withFqn:             true,
 		state:               state,
-		namespace_id:        namespace_id,
+		namespace:           namespace,
 	}
 
 	sql, args, err := listAllAttributesSql(opts)