list entity users

Signed-off-by: Arvindh <[email protected]>
absmach · Jan 30, 2025 · e5dfdc9 · e5dfdc9
1 parent e69730d
commit e5dfdc9
Show file tree

Hide file tree

Showing 34 changed files with 1,746 additions and 205 deletions.
diff --git a/api/http/common.go b/api/http/common.go
@@ -20,62 +20,63 @@ import (
 )
 
 const (
-	MemberKindKey    = "member_kind"
-	PermissionKey    = "permission"
-	RelationKey      = "relation"
-	StatusKey        = "status"
-	OffsetKey        = "offset"
-	OrderKey         = "order"
-	LimitKey         = "limit"
-	MetadataKey      = "metadata"
-	ParentKey        = "parent_id"
-	OwnerKey         = "owner_id"
-	ClientKey        = "client"
-	UsernameKey      = "username"
-	NameKey          = "name"
-	GroupKey         = "group"
-	ActionKey        = "action"
-	ActionsKey       = "actions"
-	RoleIDKey        = "role_id"
-	RoleNameKey      = "role_name"
-	AccessTypeKey    = "access_type"
-	TagKey           = "tag"
-	FirstNameKey     = "first_name"
-	LastNameKey      = "last_name"
-	TotalKey         = "total"
-	SubjectKey       = "subject"
-	ObjectKey        = "object"
-	LevelKey         = "level"
-	StartLevelKey    = "start_level"
-	EndLevelKey      = "end_level"
-	TreeKey          = "tree"
-	DirKey           = "dir"
-	ListPerms        = "list_perms"
-	VisibilityKey    = "visibility"
-	EmailKey         = "email"
-	SharedByKey      = "shared_by"
-	TokenKey         = "token"
-	UserKey          = "user"
-	DomainKey        = "domain"
-	ChannelKey       = "channel"
-	ConnTypeKey      = "connection_type"
-	DefPermission    = "read_permission"
-	DefTotal         = uint64(100)
-	DefOffset        = 0
-	DefOrder         = "updated_at"
-	DefDir           = "asc"
-	DefLimit         = 10
-	DefLevel         = 0
-	DefStartLevel    = 1
-	DefEndLevel      = 0
-	DefStatus        = "enabled"
-	DefClientStatus  = clients.Enabled
-	DefUserStatus    = users.Enabled
-	DefGroupStatus   = groups.Enabled
-	DefListPerms     = false
-	SharedVisibility = "shared"
-	MyVisibility     = "mine"
-	AllVisibility    = "all"
+	MemberKindKey       = "member_kind"
+	PermissionKey       = "permission"
+	RelationKey         = "relation"
+	StatusKey           = "status"
+	OffsetKey           = "offset"
+	OrderKey            = "order"
+	LimitKey            = "limit"
+	MetadataKey         = "metadata"
+	ParentKey           = "parent_id"
+	OwnerKey            = "owner_id"
+	ClientKey           = "client"
+	UsernameKey         = "username"
+	NameKey             = "name"
+	GroupKey            = "group"
+	ActionKey           = "action"
+	ActionsKey          = "actions"
+	RoleIDKey           = "role_id"
+	RoleNameKey         = "role_name"
+	AccessProviderIDKey = "access_provider_id"
+	AccessTypeKey       = "access_type"
+	TagKey              = "tag"
+	FirstNameKey        = "first_name"
+	LastNameKey         = "last_name"
+	TotalKey            = "total"
+	SubjectKey          = "subject"
+	ObjectKey           = "object"
+	LevelKey            = "level"
+	StartLevelKey       = "start_level"
+	EndLevelKey         = "end_level"
+	TreeKey             = "tree"
+	DirKey              = "dir"
+	ListPerms           = "list_perms"
+	VisibilityKey       = "visibility"
+	EmailKey            = "email"
+	SharedByKey         = "shared_by"
+	TokenKey            = "token"
+	UserKey             = "user"
+	DomainKey           = "domain"
+	ChannelKey          = "channel"
+	ConnTypeKey         = "connection_type"
+	DefPermission       = "read_permission"
+	DefTotal            = uint64(100)
+	DefOffset           = 0
+	DefOrder            = "updated_at"
+	DefDir              = "asc"
+	DefLimit            = 10
+	DefLevel            = 0
+	DefStartLevel       = 1
+	DefEndLevel         = 0
+	DefStatus           = "enabled"
+	DefClientStatus     = clients.Enabled
+	DefUserStatus       = users.Enabled
+	DefGroupStatus      = groups.Enabled
+	DefListPerms        = false
+	SharedVisibility    = "shared"
+	MyVisibility        = "mine"
+	AllVisibility       = "all"
 	// ContentType represents JSON content type.
 	ContentType = "application/json"
 

diff --git a/api/http/util/errors.go b/api/http/util/errors.go
@@ -141,6 +141,9 @@ var (
 	// ErrInvalidComparator indicates an invalid comparator.
 	ErrInvalidComparator = errors.New("invalid comparator")
 
+	// ErrMissingMemberIDs indicates missing group member type.
+	ErrMissingMemberIDs = errors.New("missing member ids")
+
 	// ErrMissingMemberType indicates missing group member type.
 	ErrMissingMemberType = errors.New("missing group member type")
 

diff --git a/channels/mocks/repository.go b/channels/mocks/repository.go
diff --git a/channels/mocks/service.go b/channels/mocks/service.go
diff --git a/channels/postgres/channels.go b/channels/postgres/channels.go
@@ -18,6 +18,7 @@ import (
 	"github.com/absmach/supermq/pkg/connections"
 	"github.com/absmach/supermq/pkg/errors"
 	repoerr "github.com/absmach/supermq/pkg/errors/repository"
+	"github.com/absmach/supermq/pkg/policies"
 	"github.com/absmach/supermq/pkg/postgres"
 	rolesPostgres "github.com/absmach/supermq/pkg/roles/repo/postgres"
 	"github.com/jackc/pgtype"
@@ -40,7 +41,7 @@ type channelRepository struct {
 // NewChannelRepository instantiates a PostgreSQL implementation of channel
 // repository.
 func NewRepository(db postgres.Database) channels.Repository {
-	rolesRepo := rolesPostgres.NewRepository(db, rolesTableNamePrefix, entityTableName, entityIDColumnName)
+	rolesRepo := rolesPostgres.NewRepository(db, policies.ChannelType, rolesTableNamePrefix, entityTableName, entityIDColumnName)
 	return &channelRepository{
 		db:         db,
 		Repository: rolesRepo,

diff --git a/clients/mocks/repository.go b/clients/mocks/repository.go
diff --git a/clients/mocks/service.go b/clients/mocks/service.go