private AuthParameters updateSecretData()

in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java [298:345]
46 lines of code
13 McCabe index (conditional complexity)

    private AuthParameters updateSecretData(AuthParameters authParameters, String accountId, String connectionName, ConnectionDTO oldConnection) {
        if (authParameters == null) {
            return null;
        }
        final BasicAuthParameters basicAuthParameters = authParameters.getBasicAuthParameters();
        if (basicAuthParameters != null) {
            String secretName = null;
            if (oldConnection.getAuthParameters() != null
                    && oldConnection.getAuthParameters().getBasicAuthParameters() != null) {
                if (StringUtils.isBlank(basicAuthParameters.getUsername())
                        || StringUtils.isBlank(basicAuthParameters.getPassword())) {
                    secretName = oldConnection.getAuthParameters().getBasicAuthParameters().getPassword();
                } else {
                    BasicAuthParameters oldBasicAuthParameters = oldConnection.getAuthParameters().getBasicAuthParameters();
                    secretName = secretManagerAPI.updateSecretValue(oldBasicAuthParameters.getPassword(), accountId, connectionName, basicAuthParameters.getUsername(), basicAuthParameters.getPassword());
                }
            } else {
                // old auth not basic
                secretName = secretManagerAPI.createSecretName(accountId, connectionName, new Gson().toJson(basicAuthParameters));
            }
            basicAuthParameters.setPassword(secretName);
            return authParameters;
        }
        final ApiKeyAuthParameters apiKeyAuthParameters = authParameters.getApiKeyAuthParameters();
        if (apiKeyAuthParameters != null) {
            String secretName = null;
            if (oldConnection.getAuthParameters() != null
                    && oldConnection.getAuthParameters().getApiKeyAuthParameters() != null) {
                if (StringUtils.isBlank(apiKeyAuthParameters.getApiKeyName()) || StringUtils.isBlank(apiKeyAuthParameters.getApiKeyValue())) {
                    secretName = oldConnection.getAuthParameters().getApiKeyAuthParameters().getApiKeyValue();
                } else {
                    ApiKeyAuthParameters oldApiKeyAuthParameters = oldConnection.getAuthParameters().getApiKeyAuthParameters();
                    secretName = secretManagerAPI.updateSecretValue(oldApiKeyAuthParameters.getApiKeyValue(), accountId, connectionName, apiKeyAuthParameters.getApiKeyName(), apiKeyAuthParameters.getApiKeyValue());
                }
            } else {
                // old auth not api key
                secretName = secretManagerAPI.createSecretName(accountId, connectionName, new Gson().toJson(apiKeyAuthParameters));
            }
            apiKeyAuthParameters.setApiKeyValue(secretName);
            return authParameters;
        }
        final OAuthParameters oauthParameters = authParameters.getOauthParameters();
        if (oauthParameters == null) {
            return authParameters;
        }
        updateClientByKms(accountId, connectionName, oauthParameters, oldConnection);
        return authParameters;
    }