in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TransformValidator.java [32:57]
public static void validateTransform(TransformEnum form, String template,
String value) throws EventBridgeException {
ObjectUtil.checkNotNullOrEmpty(new EventBridgeException(TransformErrorCode.InvalidConfig, form), form);
switch (form) {
case ORIGINAL:
break;
case CONSTANT:
ObjectUtil.checkNotNullOrEmpty(new EventBridgeException(TransformErrorCode.InvalidConfig, value), value);
break;
case JSONPATH:
ObjectUtil.checkNotNullOrEmpty(new EventBridgeException(TransformErrorCode.InvalidConfig, value), value);
if (!JsonPathUtil.isValidAndDefinite(value)) {
throw new EventBridgeException(TransformErrorCode.InvalidConfig, value);
}
break;
case TEMPLATE:
ObjectUtil.checkNotNullOrEmpty(new EventBridgeException(TransformErrorCode.InvalidConfig, value), value);
ObjectUtil.checkNotNullOrEmpty(new EventBridgeException(TransformErrorCode.InvalidConfig, value),
new JsonPathExtract(value).getExtractList());
ObjectUtil.checkNotNullOrEmpty(new EventBridgeException(TransformErrorCode.InvalidConfig, value),
new StringSubstitutorTemplate(template));
break;
default:
break;
}
}