mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-11-25 15:50:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup: refactor deeply nested if statement in vault_tokens.go

Browse Source 
Refactored deeply nested if statement in vault_tokens.go to
reduce cognitive complexity by adding fetchTenantConfig function.

Signed-off-by: Rakshith R <rar@redhat.com>
This commit is contained in:
Rakshith R 2021-04-05 10:01:47 +05:30 committed by mergify[bot]
parent 2d1a572d11
commit d4cfd7bef9
1 changed files with 25 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
internal/util/vault_tokens.go
View File

@ -216,22 +216,14 @@ func initVaultTokensKMS(args KMSInitializerArgs) (EncryptionKMS, error) {
// fetch the configuration for the tenant
if args.Tenant != "" {
kms.Tenant = args.Tenant
tenantsMap, ok := config["tenants"]
if ok {
// tenants is a map per tenant, containing key/values
tenants, ok := tenantsMap.(map[string]map[string]interface{})
if ok {
// get the map for the tenant of the current operation
tenantConfig, ok := tenants[args.Tenant]
if ok {
tenantConfig, found := fetchTenantConfig(config, args.Tenant)
if found {
// override connection details from the tenant
err = kms.parseConfig(tenantConfig)
if err != nil {
return nil, err
}
}
}
}
err = kms.parseTenantConfig()
if err != nil {
@ -506,3 +498,22 @@ func (kms *VaultTokensKMS) parseTenantConfig() error {
return nil
}
// fetchTenantConfig fetches the configuration for the tenant if it exists.
func fetchTenantConfig(config map[string]interface{}, tenant string) (map[string]interface{}, bool) {
tenantsMap, ok := config["tenants"]
if !ok {
return nil, false
}
// tenants is a map per tenant, containing key/values
tenants, ok := tenantsMap.(map[string]map[string]interface{})
if !ok {
return nil, false
}
// get the map for the tenant of the current operation
tenantConfig, ok := tenants[tenant]
if !ok {
return nil, false
}
return tenantConfig, true
}