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);
}
}
}