public static String validateRequest()

in sessions/next24/books-genai-vertex-langchain4j/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 "";
    }