private void checkApiKeyAuthParameters()

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


    private void checkApiKeyAuthParameters(AuthParameters authParameters) {
        ApiKeyAuthParameters apiKeyAuthParameters = authParameters.getApiKeyAuthParameters();
        if (AuthorizationTypeEnum.API_KEY_AUTH.getType().equals(authParameters.getAuthorizationType()) && apiKeyAuthParameters == null) {
            throw new EventBridgeException(EventBridgeErrorCode.ApiKeyRequiredParameterIsEmpty);
        }
        if (apiKeyAuthParameters != null && AuthorizationTypeEnum.API_KEY_AUTH.getType().equals(authParameters.getAuthorizationType())) {
            if (StringUtils.isBlank(apiKeyAuthParameters.getApiKeyName()) || StringUtils.isBlank(apiKeyAuthParameters.getApiKeyValue())) {
                throw new EventBridgeException(EventBridgeErrorCode.ApiKeyRequiredParameterIsEmpty);
            }
            String apiKeyName = apiKeyAuthParameters.getApiKeyName();
            String apiKeyValue = apiKeyAuthParameters.getApiKeyValue();
            if (apiKeyName.length() > EventBridgeConstants.MAX_LENGTH_CONSTANT || apiKeyName.length() < EventBridgeConstants.MIN_LENGTH_CONSTANT) {
                throw new EventBridgeException(EventBridgeErrorCode.ApiKeyNameLengthExceed);
            }
            if (apiKeyValue.length() > EventBridgeConstants.MAX_LENGTH_CONSTANT || apiKeyValue.length() < EventBridgeConstants.MIN_LENGTH_CONSTANT) {
                throw new EventBridgeException(EventBridgeErrorCode.ApiKeyValueLengthExceed);
            }
        }
    }