in custos-services/custos-integration-services/resource-secret-management-service/src/main/java/org/apache/custos/resource/secret/management/interceptors/ResourceSecretManagementInputValidator.java [66:93]
public <ReqT> ReqT intercept(String method, Metadata headers, ReqT msg) {
if (method.equals("addSSHCredential") || method.equals("addPasswordCredential")
|| method.equals("addCertificateCredential")) {
validate(method, msg, headers);
validateSecretMetadata(msg, method);
} else if (method.equals("addKVCredential") || method.equals("getKVCredential") ||
method.equals("updateKVCredential") || method.equals("deleteKVCredential")) {
validate(method, msg, headers);
if (msg instanceof KVCredential) {
String key = ((KVCredential) msg).getKey();
String value = (((KVCredential) msg)).getValue();
String token = (((KVCredential) msg)).getToken();
if ((token == null || token.trim().equals("")) && (key == null || key.trim().equals(""))) {
throw new MissingParameterException("At least key or token should be added ", null);
}
if ((method.equals("addKVCredential") || method.equals("updateKVCredential")) && (value == null || value.trim().equals(""))) {
throw new MissingParameterException("Value should not be null ", null);
}
} else {
throw new RuntimeException("Unknown message type", null);
}
}
return msg;
}