mirror of
https://github.com/zitadel/zitadel.git
synced 2025-10-21 15:29:37 +00:00
710652ef24
* feat: project role remove * feat: search queries * feat: search queries * feat: cascade remove/change project role * fix: comment in project grant * fix: remove projecr grant * fix: only search usergrants of my org * fix: delete usergrants * fix: delete usergrants * fix: check if role exists on project grant * feat: bulk add project role * fix: tests * fix: update user grants on project update * fix: return roles * feat: add resourceowner name on project grants * fix: migration number * fix: tests * fix: generate protos * fix: some unnecessary code
66 lines
2.5 KiB
Go
66 lines
2.5 KiB
Go
package eventstore
|
|
|
|
import (
|
|
"context"
|
|
"github.com/caos/zitadel/internal/management/repository/eventsourcing/view"
|
|
grant_model "github.com/caos/zitadel/internal/usergrant/model"
|
|
grant_event "github.com/caos/zitadel/internal/usergrant/repository/eventsourcing"
|
|
"github.com/caos/zitadel/internal/usergrant/repository/view/model"
|
|
)
|
|
|
|
type UserGrantRepo struct {
|
|
SearchLimit uint64
|
|
UserGrantEvents *grant_event.UserGrantEventStore
|
|
View *view.View
|
|
}
|
|
|
|
func (repo *UserGrantRepo) UserGrantByID(ctx context.Context, grantID string) (*grant_model.UserGrant, error) {
|
|
return repo.UserGrantEvents.UserGrantByID(ctx, grantID)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) AddUserGrant(ctx context.Context, grant *grant_model.UserGrant) (*grant_model.UserGrant, error) {
|
|
return repo.UserGrantEvents.AddUserGrant(ctx, grant)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) ChangeUserGrant(ctx context.Context, grant *grant_model.UserGrant) (*grant_model.UserGrant, error) {
|
|
return repo.UserGrantEvents.ChangeUserGrant(ctx, grant)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) DeactivateUserGrant(ctx context.Context, grantID string) (*grant_model.UserGrant, error) {
|
|
return repo.UserGrantEvents.DeactivateUserGrant(ctx, grantID)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) ReactivateUserGrant(ctx context.Context, grantID string) (*grant_model.UserGrant, error) {
|
|
return repo.UserGrantEvents.ReactivateUserGrant(ctx, grantID)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) RemoveUserGrant(ctx context.Context, grantID string) error {
|
|
return repo.UserGrantEvents.RemoveUserGrant(ctx, grantID)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) BulkAddUserGrant(ctx context.Context, grants ...*grant_model.UserGrant) error {
|
|
return repo.UserGrantEvents.AddUserGrants(ctx, grants...)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) BulkChangeUserGrant(ctx context.Context, grants ...*grant_model.UserGrant) error {
|
|
return repo.UserGrantEvents.ChangeUserGrants(ctx, grants...)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) BulkRemoveUserGrant(ctx context.Context, grantIDs ...string) error {
|
|
return repo.UserGrantEvents.RemoveUserGrants(ctx, grantIDs...)
|
|
}
|
|
|
|
func (repo *UserGrantRepo) SearchUserGrants(ctx context.Context, request *grant_model.UserGrantSearchRequest) (*grant_model.UserGrantSearchResponse, error) {
|
|
request.EnsureLimit(repo.SearchLimit)
|
|
grants, count, err := repo.View.SearchUserGrants(request)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &grant_model.UserGrantSearchResponse{
|
|
Offset: request.Offset,
|
|
Limit: request.Limit,
|
|
TotalResult: uint64(count),
|
|
Result: model.UserGrantsToModel(grants),
|
|
}, nil
|
|
}
|