private void updateClientByKms()

in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java [347:368]

• 22 lines of code
• 7 McCabe index (conditional complexity)

    private void updateClientByKms(String accountId, String connectionName, OAuthParameters oauthParameters, ConnectionDTO oldConnection) {
        OAuthParameters.ClientParameters clientParameters = oauthParameters.getClientParameters();
        if (clientParameters == null) {
            return;
        }
        String clientSecretSecretValue = null;
        if (oldConnection.getAuthParameters() != null
                && oldConnection.getAuthParameters().getOauthParameters() != null
                && oldConnection.getAuthParameters().getOauthParameters().getClientParameters() != null) {
            if (StringUtils.isBlank(clientParameters.getClientID()) || StringUtils.isBlank(clientParameters.getClientSecret())) {
                clientSecretSecretValue = oldConnection.getAuthParameters().getOauthParameters().getClientParameters().getClientSecret();
            } else {
                OAuthParameters.ClientParameters oldClientParameters = oldConnection.getAuthParameters().getOauthParameters().getClientParameters();
                clientSecretSecretValue = secretManagerAPI.updateSecretValue(oldClientParameters.getClientSecret(),
                        accountId, connectionName, clientParameters.getClientID(), clientParameters.getClientSecret());
            }
        } else {
            clientSecretSecretValue = secretManagerAPI.createSecretName(accountId, connectionName, new Gson().toJson(clientParameters));
        }
        clientParameters.setClientSecret(clientSecretSecretValue);
        oauthParameters.setClientParameters(clientParameters);
    }