mirror of
https://github.com/zitadel/zitadel.git
synced 2024-12-14 03:54:21 +00:00
5abd5b0505
* feat(management): service accounts * chore: current go version * init * refactor: apis * feat(internal): start impl of service account * chore: start impl of machine/human users * code compiles * fix: tests * fix: tests * fix: add new event types to switches * chore: add cases to event types * fix(management): definitive proto messages * fix: machine/human * fix: add missing tables as todos * fix: remove unused permissions * fix: refactoring * fix: refactor * fix: human registered * fix: user id * fix: logid * fix: proto remove //equal * chore(management): remove no comment * fix: human mfas * fix: user subobjects * chore: rename existing to better name * fix: username in user (#634) * fix: username in user * fix: username * fix remove unused code * fix add validations * fix: use new user in all apis * fix: regexp for username in api * fix: fill user data for human and machine (#638) * fix: fill Display name grant/member handlers fix: add description to grant/member objects in api fix: check if user is human in login * fix: remove description from member and grant * chore: remove todos * feat: machine keys * fix: implement missing parts * feat: machine key management view * fix: remove keys from machine view * fix: set default expiration date * fix: get key by ids * feat: add machine keys in proto * feat: machine keys * fix: add migration * fix: mig * fix: correct method name * feat: user search * feat: user search * fix: log ids * fix partial authconfig prompt, domain c perm * membership read check * contributor refresh trigger, observe org write * fix: migrations * fix(console): machine build (#660) * frontend 1 * fix html bindings * trailing comma * user permissions, project deactivate * fix(console): human view (#661) * fix search user view, user detail form * rm log * feat(console): user services list and create (#663) * fix search user view, user detail form * rm log * machine list * generic table component * create user service * proove table for undefined values * tmp disable user link if machine * lint * lint styles * user table lint * Update console/src/assets/i18n/de.json Co-authored-by: Florian Forster <florian@caos.ch> * feat(console): service user detail view, keys cr_d, fix search user autocomplete (#664) * service users for sidenav, routing * i18n * back routes * machine detail form * update machine detail, fix svc user grants * keys table * add key dialog, timestamp creation * check permission on create, delete, fix selection * lint ts, scss * Update console/src/assets/i18n/de.json * Apply suggestions from code review Co-authored-by: Florian Forster <florian@caos.ch> * allow user grants for project.write * management service * fix mgmt service * feat: Machine keys (#655) * fix: memberships (#633) * feat: add iam members to memberships * fix: search project grants * fix: rename * feat: idp and login policy configurations (#619) * feat: oidc config * fix: oidc configurations * feat: oidc idp config * feat: add oidc config test * fix: tests * fix: tests * feat: translate new events * feat: idp eventstore * feat: idp eventstore * fix: tests * feat: command side idp * feat: query side idp * feat: idp config on org * fix: tests * feat: authz idp on org * feat: org idps * feat: login policy * feat: login policy * feat: login policy * feat: add idp func on login policy * feat: add validation to loginpolicy and idp provider * feat: add default login policy * feat: login policy on org * feat: login policy on org * fix: id config handlers * fix: id config handlers * fix: create idp on org * fix: create idp on org * fix: not existing idp config * fix: default login policy * fix: add login policy on org * fix: idp provider search on org * fix: test * fix: remove idp on org * fix: test * fix: test * fix: remove admin idp * fix: logo src as byte * fix: migration * fix: tests * Update internal/iam/repository/eventsourcing/iam.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/iam/repository/eventsourcing/iam_test.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/iam/repository/eventsourcing/iam_test.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/iam/repository/eventsourcing/model/login_policy.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/iam/repository/eventsourcing/model/login_policy.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/org/repository/eventsourcing/org_test.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/iam/repository/eventsourcing/model/login_policy_test.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * Update internal/iam/repository/eventsourcing/model/login_policy_test.go Co-authored-by: Silvan <silvan.reusser@gmail.com> * fix: pr comments * fix: tests * Update types.go * fix: merge request changes * fix: reduce optimization Co-authored-by: Silvan <silvan.reusser@gmail.com> Co-authored-by: Livio Amstutz <livio.a@gmail.com> * fix: reread user mfas, preferred loginname as otp account name (#636) * fix: reread user mfas * fix: use preferred login name as otp account name * fix: tests * fix: reduce (#635) * fix: management reduce optimization * fix: reduce optimization * fix: reduce optimization * fix: merge master * chore(deps): bump github.com/gorilla/schema from 1.1.0 to 1.2.0 (#627) Bumps [github.com/gorilla/schema](https://github.com/gorilla/schema) from 1.1.0 to 1.2.0. - [Release notes](https://github.com/gorilla/schema/releases) - [Commits](https://github.com/gorilla/schema/compare/v1.1.0...v1.2.0) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * chore(deps): bump github.com/gorilla/mux from 1.7.4 to 1.8.0 (#624) Bumps [github.com/gorilla/mux](https://github.com/gorilla/mux) from 1.7.4 to 1.8.0. - [Release notes](https://github.com/gorilla/mux/releases) - [Commits](https://github.com/gorilla/mux/compare/v1.7.4...v1.8.0) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * chore(deps): bump github.com/DATA-DOG/go-sqlmock from 1.4.1 to 1.5.0 (#591) Bumps [github.com/DATA-DOG/go-sqlmock](https://github.com/DATA-DOG/go-sqlmock) from 1.4.1 to 1.5.0. - [Release notes](https://github.com/DATA-DOG/go-sqlmock/releases) - [Commits](https://github.com/DATA-DOG/go-sqlmock/compare/v1.4.1...v1.5.0) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * chore: auto assign issues and PR to ZTIADEL project board (#643) * Create main.yml * Update main.yml Co-authored-by: Livio Amstutz <livio.a@gmail.com> * fix(console): project grant members, update deps (#645) * fix: searchprojectgrantmembers * chore(deps-dev): bump @angular/cli from 10.0.6 to 10.0.7 in /console (#622) Bumps [@angular/cli](https://github.com/angular/angular-cli) from 10.0.6 to 10.0.7. - [Release notes](https://github.com/angular/angular-cli/releases) - [Commits](https://github.com/angular/angular-cli/compare/v10.0.6...v10.0.7) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * chore(deps-dev): bump @angular-devkit/build-angular in /console (#626) Bumps [@angular-devkit/build-angular](https://github.com/angular/angular-cli) from 0.1000.6 to 0.1000.7. - [Release notes](https://github.com/angular/angular-cli/releases) - [Commits](https://github.com/angular/angular-cli/commits) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Max Peintner <max@caos.ch> * chore(deps-dev): bump @types/jasmine from 3.5.12 to 3.5.13 in /console (#623) Bumps [@types/jasmine](https://github.com/DefinitelyTyped/DefinitelyTyped/tree/HEAD/types/jasmine) from 3.5.12 to 3.5.13. - [Release notes](https://github.com/DefinitelyTyped/DefinitelyTyped/releases) - [Commits](https://github.com/DefinitelyTyped/DefinitelyTyped/commits/HEAD/types/jasmine) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * chore(deps-dev): bump ts-node from 8.10.2 to 9.0.0 in /console (#629) Bumps [ts-node](https://github.com/TypeStrong/ts-node) from 8.10.2 to 9.0.0. - [Release notes](https://github.com/TypeStrong/ts-node/releases) - [Commits](https://github.com/TypeStrong/ts-node/compare/v8.10.2...v9.0.0) Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * update packlock Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * chore: delete main.yml (#648) * fix: usergrant (#650) * fix(console): mfa refresh after verification, member eventemitter (#651) * refresh mfa * fix: detail link from contributors * lint * feat: add domain verification notification (#649) * fix: dont (re)generate client secret with auth type none * fix(cors): allow Origin from request * feat: add origin allow list and fix some core issues * rename migration * fix UserIDsByDomain * feat: send email to users after domain claim * username * check origin on userinfo * update oidc pkg * fix: add migration 1.6 * change username * change username * remove unique email aggregate * change username in mgmt * search global user by login name * fix test * change user search in angular * fix tests * merge * userview in angular * fix merge * Update pkg/grpc/management/proto/management.proto Co-authored-by: Fabi <38692350+fgerschwiler@users.noreply.github.com> * Update internal/notification/static/i18n/de.yaml Co-authored-by: Fabi <38692350+fgerschwiler@users.noreply.github.com> * fix Co-authored-by: Fabi <38692350+fgerschwiler@users.noreply.github.com> * fix: translation (#647) * fix: translation * fix: translation * fix: translation * fix: remove unused code * fix: log err * fix: migration numbers (#652) * chore: issue / feature templates (#642) * feat: machine keys * fix: implement missing parts * feat: machine key management view * fix: remove keys from machine view * feat: global org read (#657) * fix: set default expiration date * fix: get key by ids * feat: add machine keys in proto * feat: machine keys * fix: add migration * fix: mig * fix: correct method name * feat: user search * feat: user search * fix: log ids * fix: migrations * fix(console): machine build (#660) * frontend 1 * fix html bindings * trailing comma * fix(console): human view (#661) * fix search user view, user detail form * rm log * feat(console): user services list and create (#663) * fix search user view, user detail form * rm log * machine list * generic table component * create user service * proove table for undefined values * tmp disable user link if machine * lint * lint styles * user table lint * Update console/src/assets/i18n/de.json Co-authored-by: Florian Forster <florian@caos.ch> * feat(console): service user detail view, keys cr_d, fix search user autocomplete (#664) * service users for sidenav, routing * i18n * back routes * machine detail form * update machine detail, fix svc user grants * keys table * add key dialog, timestamp creation * check permission on create, delete, fix selection * lint ts, scss * Update console/src/assets/i18n/de.json * Apply suggestions from code review Co-authored-by: Florian Forster <florian@caos.ch> * refactor: protos * fix(management): key expiration date * fix: check if user is human * fix: marshal key details * fix: correct generate login names * fix: logid Co-authored-by: Fabi <38692350+fgerschwiler@users.noreply.github.com> Co-authored-by: Livio Amstutz <livio.a@gmail.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Max Peintner <max@caos.ch> Co-authored-by: Fabiennne <fabienne.gerschwiler@gmail.com> Co-authored-by: Florian Forster <florian@caos.ch> * fix: naming * refactor: findings * fix: username * fix: mfa upper case * fix: tests * fix: add translations * reactivatemyorg req typeö * fix: projectType for console * fix: user changes * fix: translate events * fix: event type translation * fix: remove unused types Co-authored-by: Fabiennne <fabienne.gerschwiler@gmail.com> Co-authored-by: Max Peintner <max@caos.ch> Co-authored-by: Florian Forster <florian@caos.ch> Co-authored-by: Fabi <38692350+fgerschwiler@users.noreply.github.com> Co-authored-by: Livio Amstutz <livio.a@gmail.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
1606 lines
44 KiB
Go
1606 lines
44 KiB
Go
package eventsourcing
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/golang/mock/gomock"
|
|
|
|
"github.com/caos/zitadel/internal/api/authz"
|
|
caos_errs "github.com/caos/zitadel/internal/errors"
|
|
es_models "github.com/caos/zitadel/internal/eventstore/models"
|
|
iam_model "github.com/caos/zitadel/internal/iam/model"
|
|
"github.com/caos/zitadel/internal/iam/repository/eventsourcing/model"
|
|
)
|
|
|
|
func TestIamByID(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
iam *model.IAM
|
|
}
|
|
type res struct {
|
|
iam *model.IAM
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "iam from events, ok",
|
|
args: args{
|
|
es: GetMockIamByIDOK(ctrl),
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
},
|
|
{
|
|
name: "iam from events, no events",
|
|
args: args{
|
|
es: GetMockIamByIDNoEvents(ctrl),
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
{
|
|
name: "iam from events, no id",
|
|
args: args{
|
|
es: GetMockIamByIDNoEvents(ctrl),
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.IAMByID(nil, tt.args.iam.AggregateID)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID != tt.res.iam.AggregateID {
|
|
t.Errorf("got wrong result name: expected: %v, actual: %v ", tt.res.iam.AggregateID, result.AggregateID)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestSetUpStarted(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
iamID string
|
|
}
|
|
type res struct {
|
|
iam *model.IAM
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "setup started iam, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
},
|
|
res: res{
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "iamID", Sequence: 1}, SetUpStarted: true},
|
|
},
|
|
},
|
|
{
|
|
name: "setup already started",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "setup iam no id",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.StartSetup(tt.args.ctx, tt.args.iamID)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if tt.res.errFunc == nil && result.SetUpStarted != tt.res.iam.SetUpStarted {
|
|
t.Errorf("got wrong result setupStarted: expected: %v, actual: %v ", tt.res.iam.SetUpStarted, result.SetUpStarted)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestSetUpDone(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
iamID string
|
|
}
|
|
type res struct {
|
|
iam *model.IAM
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "setup done iam, ok",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
},
|
|
res: res{
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "iamID", Sequence: 1}, SetUpStarted: true, SetUpDone: true},
|
|
},
|
|
},
|
|
{
|
|
name: "setup iam no id",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.SetupDone(tt.args.ctx, tt.args.iamID)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if tt.res.errFunc == nil && result.SetUpDone != tt.res.iam.SetUpDone {
|
|
t.Errorf("got wrong result SetUpDone: expected: %v, actual: %v ", tt.res.iam.SetUpDone, result.SetUpDone)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestSetGlobalOrg(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
iamID string
|
|
globalOrg string
|
|
}
|
|
type res struct {
|
|
iam *model.IAM
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "global org set, ok",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
globalOrg: "globalOrg",
|
|
},
|
|
res: res{
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "iamID", Sequence: 1}, SetUpStarted: true, GlobalOrgID: "globalOrg"},
|
|
},
|
|
},
|
|
{
|
|
name: "no iam id",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
globalOrg: "",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "no global org",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
globalOrg: "globalOrg",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.SetGlobalOrg(tt.args.ctx, tt.args.iamID, tt.args.globalOrg)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if tt.res.errFunc == nil && result.GlobalOrgID != tt.res.iam.GlobalOrgID {
|
|
t.Errorf("got wrong result GlobalOrgID: expected: %v, actual: %v ", tt.res.iam.GlobalOrgID, result.GlobalOrgID)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestSetIamProjectID(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
iamID string
|
|
iamProjectID string
|
|
}
|
|
type res struct {
|
|
iam *model.IAM
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "iam project set, ok",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
iamProjectID: "iamProjectID",
|
|
},
|
|
res: res{
|
|
iam: &model.IAM{ObjectRoot: es_models.ObjectRoot{AggregateID: "iamID", Sequence: 1}, SetUpStarted: true, IAMProjectID: "iamProjectID"},
|
|
},
|
|
},
|
|
{
|
|
name: "no iam id",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamProjectID: "",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "no global org",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
iamID: "iamID",
|
|
iamProjectID: "iamProjectID",
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.SetIAMProject(tt.args.ctx, tt.args.iamID, tt.args.iamProjectID)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if tt.res.errFunc == nil && result.IAMProjectID != tt.res.iam.IAMProjectID {
|
|
t.Errorf("got wrong result IAMProjectID: expected: %v, actual: %v ", tt.res.iam.IAMProjectID, result.IAMProjectID)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestAddIamMember(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
member *iam_model.IAMMember
|
|
}
|
|
type res struct {
|
|
result *iam_model.IAMMember
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "add iam member, ok",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
},
|
|
{
|
|
name: "no userid",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, Roles: []string{"Roles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "no roles",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID"},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "member already existing",
|
|
args: args{
|
|
es: GetMockManipulateIamWithMember(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsErrorAlreadyExists,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.AddIAMMember(tt.args.ctx, tt.args.member)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if tt.res.errFunc == nil && result.UserID != tt.res.result.UserID {
|
|
t.Errorf("got wrong result userid: expected: %v, actual: %v ", tt.res.result.UserID, result.UserID)
|
|
}
|
|
if tt.res.errFunc == nil && len(result.Roles) != len(tt.res.result.Roles) {
|
|
t.Errorf("got wrong result roles: expected: %v, actual: %v ", tt.res.result.Roles, result.Roles)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestChangeIamMember(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
member *iam_model.IAMMember
|
|
}
|
|
type res struct {
|
|
result *iam_model.IAMMember
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "add iam member, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithMember(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"ChangeRoles"}},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
},
|
|
{
|
|
name: "no userid",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, Roles: []string{"ChangeRoles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "no roles",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID"},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "member not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"ChangeRoles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.ChangeIAMMember(tt.args.ctx, tt.args.member)
|
|
|
|
if tt.res.errFunc == nil && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if tt.res.errFunc == nil && result.UserID != tt.res.result.UserID {
|
|
t.Errorf("got wrong result userid: expected: %v, actual: %v ", tt.res.result.UserID, result.UserID)
|
|
}
|
|
if tt.res.errFunc == nil && len(result.Roles) != len(tt.res.result.Roles) {
|
|
t.Errorf("got wrong result roles: expected: %v, actual: %v ", tt.res.result.Roles, result.Roles)
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestRemoveIamMember(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
existingIAM *model.IAM
|
|
member *iam_model.IAMMember
|
|
}
|
|
type res struct {
|
|
result *iam_model.IAMMember
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "remove iam member, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithMember(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
existingIAM: &model.IAM{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
Members: []*model.IAMMember{{UserID: "UserID", Roles: []string{"Roles"}}},
|
|
},
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID"},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
},
|
|
{
|
|
name: "no userid",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
existingIAM: &model.IAM{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
Members: []*model.IAMMember{{UserID: "UserID", Roles: []string{"Roles"}}},
|
|
},
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, Roles: []string{"ChangeRoles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "member not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
existingIAM: &model.IAM{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
},
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"Roles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
member: &iam_model.IAMMember{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}, UserID: "UserID", Roles: []string{"ChangeRoles"}},
|
|
},
|
|
res: res{
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
err := tt.args.es.RemoveIAMMember(tt.args.ctx, tt.args.member)
|
|
|
|
if tt.res.errFunc == nil && err != nil {
|
|
t.Errorf("should not get err")
|
|
}
|
|
if tt.res.errFunc != nil && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestAddIdpConfiguration(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
idp *iam_model.IDPConfig
|
|
}
|
|
type res struct {
|
|
result *iam_model.IDPConfig
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "add idp, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithCrypto(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
Type: iam_model.IDPConfigTypeOIDC,
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
ClientSecretString: "ClientSecret",
|
|
Issuer: "Issuer",
|
|
Scopes: []string{"scope"},
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
Name: "Name",
|
|
Type: iam_model.IDPConfigTypeOIDC,
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
Issuer: "Issuer",
|
|
Scopes: []string{"scope"},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "invalid idp config",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
ClientSecretString: "ClientSecret",
|
|
Issuer: "Issuer",
|
|
Scopes: []string{"scope"},
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.AddIDPConfig(tt.args.ctx, tt.args.idp)
|
|
|
|
if !tt.res.wantErr && result.IDPConfigID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if !tt.res.wantErr && result.OIDCConfig.IDPConfigID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if !tt.res.wantErr && result.OIDCConfig == nil && result.OIDCConfig.ClientSecret == nil {
|
|
t.Errorf("result has no client secret")
|
|
}
|
|
if !tt.res.wantErr && result.Name != tt.res.result.Name {
|
|
t.Errorf("got wrong result key: expected: %v, actual: %v ", tt.res.result.Name, result.Name)
|
|
}
|
|
if !tt.res.wantErr && result.OIDCConfig.ClientID != tt.res.result.OIDCConfig.ClientID {
|
|
t.Errorf("got wrong result key: expected: %v, actual: %v ", tt.res.result.OIDCConfig.ClientID, result.OIDCConfig.ClientID)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestChangeIdpConfiguration(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
idp *iam_model.IDPConfig
|
|
}
|
|
type res struct {
|
|
result *iam_model.IDPConfig
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "change idp, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithOIDCIdp(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "NameChanged",
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "NameChanged",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "invalid idp",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "idp not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing project not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.ChangeIDPConfig(tt.args.ctx, tt.args.idp)
|
|
|
|
if !tt.res.wantErr && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if !tt.res.wantErr && result.IDPConfigID != tt.res.result.IDPConfigID {
|
|
t.Errorf("got wrong result AppID: expected: %v, actual: %v ", tt.res.result.IDPConfigID, result.IDPConfigID)
|
|
}
|
|
if !tt.res.wantErr && result.Name != tt.res.result.Name {
|
|
t.Errorf("got wrong result name: expected: %v, actual: %v ", tt.res.result.Name, result.Name)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestRemoveIdpConfiguration(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
idp *iam_model.IDPConfig
|
|
}
|
|
type res struct {
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "remove idp, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithOIDCIdp(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "no IDPConfigID",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "idp not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing idp not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
err := tt.args.es.RemoveIDPConfig(tt.args.ctx, tt.args.idp)
|
|
|
|
if !tt.res.wantErr && err != nil {
|
|
t.Errorf("should not get err")
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
func TestDeactivateIdpConfiguration(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
idp *iam_model.IDPConfig
|
|
}
|
|
type res struct {
|
|
result *iam_model.IDPConfig
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "deactivate, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithOIDCIdp(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
State: iam_model.IDPConfigStateInactive,
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "no idp id",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "idp not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.DeactivateIDPConfig(tt.args.ctx, tt.args.idp.AggregateID, tt.args.idp.IDPConfigID)
|
|
|
|
if !tt.res.wantErr && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if !tt.res.wantErr && result.IDPConfigID != tt.res.result.IDPConfigID {
|
|
t.Errorf("got wrong result IDPConfigID: expected: %v, actual: %v ", tt.res.result.IDPConfigID, result.IDPConfigID)
|
|
}
|
|
if !tt.res.wantErr && result.State != tt.res.result.State {
|
|
t.Errorf("got wrong result state: expected: %v, actual: %v ", tt.res.result.State, result.State)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestReactivateIdpConfiguration(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
idp *iam_model.IDPConfig
|
|
}
|
|
type res struct {
|
|
result *iam_model.IDPConfig
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "reactivate, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithOIDCIdp(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
State: iam_model.IDPConfigStateActive,
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "no idp id",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1}},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "idp not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
idp: &iam_model.IDPConfig{ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 1},
|
|
IDPConfigID: "IDPConfigID",
|
|
Name: "Name",
|
|
OIDCConfig: &iam_model.OIDCIDPConfig{
|
|
ClientID: "ClientID",
|
|
},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.ReactivateIDPConfig(tt.args.ctx, tt.args.idp.AggregateID, tt.args.idp.IDPConfigID)
|
|
|
|
if !tt.res.wantErr && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if !tt.res.wantErr && result.IDPConfigID != tt.res.result.IDPConfigID {
|
|
t.Errorf("got wrong result IDPConfigID: expected: %v, actual: %v ", tt.res.result.IDPConfigID, result.IDPConfigID)
|
|
}
|
|
if !tt.res.wantErr && result.State != tt.res.result.State {
|
|
t.Errorf("got wrong result state: expected: %v, actual: %v ", tt.res.result.State, result.State)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestChangeOIDCIDPConfig(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
config *iam_model.OIDCIDPConfig
|
|
}
|
|
type res struct {
|
|
result *iam_model.OIDCIDPConfig
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "change oidc config, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithOIDCIdp(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
config: &iam_model.OIDCIDPConfig{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IDPConfigID: "IDPConfigID",
|
|
ClientID: "ClientIDChange",
|
|
Issuer: "Issuer",
|
|
Scopes: []string{"scope"},
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.OIDCIDPConfig{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IDPConfigID: "IDPConfigID",
|
|
ClientID: "ClientIDChange",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "invalid config",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
config: &iam_model.OIDCIDPConfig{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IDPConfigID: "IDPConfigID",
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "idp not existing",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
config: &iam_model.OIDCIDPConfig{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IDPConfigID: "IDPConfigID",
|
|
ClientID: "ClientID",
|
|
Issuer: "Issuer",
|
|
Scopes: []string{"scope"},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
config: &iam_model.OIDCIDPConfig{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IDPConfigID: "IDPConfigID",
|
|
ClientID: "ClientID",
|
|
Issuer: "Issuer",
|
|
Scopes: []string{"scope"},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.ChangeIDPOIDCConfig(tt.args.ctx, tt.args.config)
|
|
|
|
if !tt.res.wantErr && result.AggregateID == "" {
|
|
t.Errorf("result has no id")
|
|
}
|
|
if !tt.res.wantErr && result.IDPConfigID != tt.res.result.IDPConfigID {
|
|
t.Errorf("got wrong result AppID: expected: %v, actual: %v ", tt.res.result.IDPConfigID, result.IDPConfigID)
|
|
}
|
|
if !tt.res.wantErr && result.ClientID != tt.res.result.ClientID {
|
|
t.Errorf("got wrong result responsetype: expected: %v, actual: %v ", tt.res.result.ClientID, result.ClientID)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestAddLoginPolicy(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
policy *iam_model.LoginPolicy
|
|
}
|
|
type res struct {
|
|
result *iam_model.LoginPolicy
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "add login policy, ok",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
policy: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
AllowRegister: true,
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
AllowRegister: true,
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "invalid policy",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
policy: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{Sequence: 0},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
policy: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.AddLoginPolicy(tt.args.ctx, tt.args.policy)
|
|
|
|
if !tt.res.wantErr && result.AllowRegister != tt.res.result.AllowRegister {
|
|
t.Errorf("got wrong result AllowRegister: expected: %v, actual: %v ", tt.res.result.AllowRegister, result.AllowRegister)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestChangeLoginPolicy(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
policy *iam_model.LoginPolicy
|
|
}
|
|
type res struct {
|
|
result *iam_model.LoginPolicy
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "add login policy, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithLoginPolicy(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
policy: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
AllowRegister: true,
|
|
AllowExternalIdp: false,
|
|
AllowUsernamePassword: false,
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
AllowRegister: true,
|
|
AllowExternalIdp: false,
|
|
AllowUsernamePassword: false,
|
|
},
|
|
},
|
|
},
|
|
{
|
|
name: "invalid policy",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
policy: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{Sequence: 0},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
policy: &iam_model.LoginPolicy{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.ChangeLoginPolicy(tt.args.ctx, tt.args.policy)
|
|
|
|
if !tt.res.wantErr && result.AllowRegister != tt.res.result.AllowRegister {
|
|
t.Errorf("got wrong result AllowRegister: expected: %v, actual: %v ", tt.res.result.AllowRegister, result.AllowRegister)
|
|
}
|
|
if !tt.res.wantErr && result.AllowUsernamePassword != tt.res.result.AllowUsernamePassword {
|
|
t.Errorf("got wrong result AllowUsernamePassword: expected: %v, actual: %v ", tt.res.result.AllowUsernamePassword, result.AllowUsernamePassword)
|
|
}
|
|
if !tt.res.wantErr && result.AllowExternalIdp != tt.res.result.AllowExternalIdp {
|
|
t.Errorf("got wrong result AllowExternalIDP: expected: %v, actual: %v ", tt.res.result.AllowExternalIdp, result.AllowExternalIdp)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestAddIdpProviderToLoginPolicy(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
provider *iam_model.IDPProvider
|
|
}
|
|
type res struct {
|
|
result *iam_model.IDPProvider
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "add idp to login policy, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithLoginPolicy(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IdpConfigID: "IdpConfigID2",
|
|
Type: iam_model.IDPProviderTypeSystem,
|
|
},
|
|
},
|
|
res: res{
|
|
result: &iam_model.IDPProvider{IdpConfigID: "IdpConfigID2"},
|
|
},
|
|
},
|
|
{
|
|
name: "add idp to login policy, already existing",
|
|
args: args{
|
|
es: GetMockManipulateIamWithLoginPolicy(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IdpConfigID: "IDPConfigID",
|
|
Type: iam_model.IDPProviderTypeSystem,
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsErrorAlreadyExists,
|
|
},
|
|
},
|
|
{
|
|
name: "invalid provider",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IdpConfigID: "IdpConfigID2",
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
result, err := tt.args.es.AddIDPProviderToLoginPolicy(tt.args.ctx, tt.args.provider)
|
|
|
|
if !tt.res.wantErr && result.IdpConfigID != tt.res.result.IdpConfigID {
|
|
t.Errorf("got wrong result IDPConfigID: expected: %v, actual: %v ", tt.res.result.IdpConfigID, result.IdpConfigID)
|
|
}
|
|
if !tt.res.wantErr && result.Type != tt.res.result.Type {
|
|
t.Errorf("got wrong result Type: expected: %v, actual: %v ", tt.res.result.Type, result.Type)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestRemoveIdpProviderFromLoginPolicy(t *testing.T) {
|
|
ctrl := gomock.NewController(t)
|
|
type args struct {
|
|
es *IAMEventstore
|
|
ctx context.Context
|
|
provider *iam_model.IDPProvider
|
|
}
|
|
type res struct {
|
|
wantErr bool
|
|
errFunc func(err error) bool
|
|
}
|
|
tests := []struct {
|
|
name string
|
|
args args
|
|
res res
|
|
}{
|
|
{
|
|
name: "remove idp to login policy, ok",
|
|
args: args{
|
|
es: GetMockManipulateIamWithLoginPolicy(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IdpConfigID: "IDPConfigID",
|
|
Type: iam_model.IDPProviderTypeSystem,
|
|
},
|
|
},
|
|
res: res{},
|
|
},
|
|
{
|
|
name: "remove idp to login policy, not existing",
|
|
args: args{
|
|
es: GetMockManipulateIamWithLoginPolicy(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IdpConfigID: "IdpConfigID2",
|
|
Type: iam_model.IDPProviderTypeSystem,
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "invalid provider",
|
|
args: args{
|
|
es: GetMockManipulateIam(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsPreconditionFailed,
|
|
},
|
|
},
|
|
{
|
|
name: "existing iam not found",
|
|
args: args{
|
|
es: GetMockManipulateIamNotExisting(ctrl),
|
|
ctx: authz.NewMockContext("orgID", "userID"),
|
|
provider: &iam_model.IDPProvider{
|
|
ObjectRoot: es_models.ObjectRoot{AggregateID: "AggregateID", Sequence: 0},
|
|
IdpConfigID: "IdpConfigID2",
|
|
},
|
|
},
|
|
res: res{
|
|
wantErr: true,
|
|
errFunc: caos_errs.IsNotFound,
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
err := tt.args.es.RemoveIDPProviderFromLoginPolicy(tt.args.ctx, tt.args.provider)
|
|
|
|
if !tt.res.wantErr && err != nil {
|
|
t.Errorf("should not get err: %v ", err)
|
|
}
|
|
if tt.res.wantErr && !tt.res.errFunc(err) {
|
|
t.Errorf("got wrong err: %v ", err)
|
|
}
|
|
})
|
|
}
|
|
}
|