in sessions/next24/books-genai-vertex-springai/src/main/java/services/utility/RequestValidationUtility.java [15:49]
public static String validateRequest(Map<String, Object> body, Map<String, String> headers) {
String errorMsg="";
logger.info("Header elements");
for (String field : CloudConfig.requiredFields) {
if (headers.get(field) == null) {
errorMsg = String.format("Missing expected header: %s.", field);
logger.info(errorMsg);
return errorMsg;
} else {
logger.info(field + " : " + headers.get(field));
}
}
logger.info("Body elements");
for (String bodyField : body.keySet()) {
logger.info(bodyField + " : " + body.get(bodyField));
}
if (headers.get("ce-subject") == null) {
errorMsg = "Missing expected header: ce-subject.";
logger.error(errorMsg);
return errorMsg;
}
String ceSubject = headers.get("ce-subject");
logger.info("Detected change in Cloud Storage bucket: (ce-subject) : " + ceSubject);
String fileName = (String)body.get("name");
if(fileName == null){
errorMsg = "Missing expected body element: file name";
logger.error(errorMsg);
return errorMsg;
}
return "";
}