Skip to content

Commit

Permalink
Merge pull request Azure#38 from m1kola/dynamicValidator_refactoring
Browse files Browse the repository at this point in the history
Make dynamicValidator more testable
  • Loading branch information
jim-minter committed Dec 9, 2019
2 parents f3c3c38 + bed34e4 commit f772a49
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions pkg/api/v20191231preview/openshiftcluster_validatedynamic.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,12 +41,14 @@ func validateOpenShiftClusterDynamic(ctx context.Context, fpAuthorizer autorest.
return err
}

err = v.validateVnetPermissions(ctx, fpAuthorizer, api.CloudErrorCodeInvalidResourceProviderPermissions, "resource provider")
fpPermissions := authorization.NewPermissionsClient(v.r.SubscriptionID, fpAuthorizer)
err = v.validateVnetPermissions(ctx, fpPermissions, api.CloudErrorCodeInvalidResourceProviderPermissions, "resource provider")
if err != nil {
return err
}

err = v.validateVnetPermissions(ctx, spAuthorizer, api.CloudErrorCodeInvalidServicePrincipalPermissions, "provided service principal")
spPermissions := authorization.NewPermissionsClient(v.r.SubscriptionID, spAuthorizer)
err = v.validateVnetPermissions(ctx, spPermissions, api.CloudErrorCodeInvalidServicePrincipalPermissions, "provided service principal")
if err != nil {
return err
}
Expand All @@ -73,15 +75,13 @@ func (dv *dynamicValidator) validateServicePrincipalProfile() (autorest.Authoriz
return conf.Authorizer()
}

func (dv *dynamicValidator) validateVnetPermissions(ctx context.Context, authorizer autorest.Authorizer, code, typ string) error {
func (dv *dynamicValidator) validateVnetPermissions(ctx context.Context, client authorization.PermissionsClient, code, typ string) error {
vnetID, _, err := subnet.Split(dv.oc.Properties.MasterProfile.SubnetID)
if err != nil {
return err
}

cli := authorization.NewPermissionsClient(dv.r.SubscriptionID, authorizer)

permissions, err := cli.ListForResource(ctx, vnetID)
permissions, err := client.ListForResource(ctx, vnetID)
if err != nil {
if err, ok := err.(autorest.DetailedError); ok {
if err.StatusCode == http.StatusNotFound {
Expand Down

0 comments on commit f772a49

Please sign in to comment.