Add limitation in the array of events for the publish endpoint generateAndPublish

Author: shudhansu-shekhar

publish-service/src/main/java/com/ericsson/eiffel/remrem/publish/controller/ProducerController.java

@@ -78,6 +78,13 @@ public class ProducerController {
     @Value("${activedirectory.publish.enabled}")
     private boolean isAuthenticationEnabled;
 
+    @Value("${maxSizeOfInputArray:250}")
+    private int maxSizeOfInputArray;
+
+    public void setMaxSizeOfInputArray(int maxSizeOfInputArray) {
+        this.maxSizeOfInputArray = maxSizeOfInputArray;
+    }
+
     private RestTemplate restTemplate = new RestTemplate();
 
     private JsonParser parser = new JsonParser();
@@ -303,6 +310,14 @@ public ResponseEntity generateAndPublish(final String msgProtocol, final String
         if (bodyJson.isJsonObject()) {
             events.add(getAsJsonObject(bodyJson));
         } else if (bodyJson.isJsonArray()) {
+            //here add check for limitation for events in array is fetched from REMReM property and checked during publishing.
+            if (bodyJson.getAsJsonArray().size() > maxSizeOfInputArray) {
+                return createResponseEntity(HttpStatus.BAD_REQUEST, JSON_ERROR_STATUS,
+                        "The number of events in the input array is exceeded the allowed limit of 250 events. " +
+                                "This issue occurred because the input array contains more than 250 events, which is not supported by the system. "
+                                + "To resolve this, please divide the events in to smaller arrays, ensuring each array contains no more than 250 events,"
+                                + "and try to publish them again. This limitation helps to maintain system performance and stability.");
+            }
             for (JsonElement element : bodyJson.getAsJsonArray()) {
                 if (element.isJsonObject()) {
                     events.add(getAsJsonObject(element));

publish-service/src/main/resources/application.properties

@@ -44,5 +44,7 @@ activedirectory.connectionTimeOut:
 
 spring.mvc.pathmatch.matching-strategy: ANT_PATH_MATCHER
 
+#Maximum size of events in array is fetched from REMReM property and checked during publishing.
+maxSizeOfInputArray: 250