in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java [231:256]
private ConnectionResponse dataMasking(ConnectionResponse connectionResponse) {
if (connectionResponse.getAuthParameters() == null) {
return connectionResponse;
}
ApiKeyAuthParameters apiKeyAuthParameters = connectionResponse.getAuthParameters().getApiKeyAuthParameters();
BasicAuthParameters basicAuthParameters = connectionResponse.getAuthParameters().getBasicAuthParameters();
OAuthParameters oauthParameters = connectionResponse.getAuthParameters().getOauthParameters();
if (apiKeyAuthParameters != null) {
apiKeyAuthParameters.setApiKeyValue("**");
connectionResponse.getAuthParameters().setApiKeyAuthParameters(apiKeyAuthParameters);
return connectionResponse;
}
if (basicAuthParameters != null) {
basicAuthParameters.setPassword("**");
connectionResponse.getAuthParameters().setBasicAuthParameters(basicAuthParameters);
return connectionResponse;
}
if (oauthParameters != null) {
OAuthParameters.ClientParameters clientParameters = oauthParameters.getClientParameters();
if (clientParameters != null) {
clientParameters.setClientSecret("**");
oauthParameters.setClientParameters(clientParameters);
}
}
return connectionResponse;
}