Skip to content

Commit

Permalink
Modified endpoint generateAndPublish to accept array of events
Browse files Browse the repository at this point in the history
  • Loading branch information
@shudhansu-shekhar
shudhansu-shekhar committed Jul 16, 2024
1 parent 14a5f7f commit 2d55610
Showing 1 changed file with 43 additions and 44 deletions.
87 changes: 43 additions & 44 deletions ...rvice/src/main/java/com/ericsson/eiffel/remrem/publish/controller/ProducerController.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,9 @@ public class ProducerController {

public final String JSON_EVENT_MESSAGE_FIELD = "status message";

public final String JSON_EVENT_STATUS_VALUE = "status";
public final String STATUS_CODE = "Status code";

public static final String META = "meta";

public void setMsgServices(MsgService[] msgServices) {
this.msgServices = msgServices;
Expand Down Expand Up @@ -206,7 +208,7 @@ public ResponseEntity generateAndPublish(@ApiParam(value = "message protocol", r
JsonObject errorResponse = new JsonObject();
log.error("Unexpected exception caught due to parse json data", e.getMessage());
String exceptionMessage = e.getMessage();
errorResponse.addProperty("status code", HttpStatus.BAD_REQUEST.value());
errorResponse.addProperty(STATUS_CODE, HttpStatus.BAD_REQUEST.value());
errorResponse.addProperty(JSON_STATUS_RESULT, "fatal");
errorResponse.addProperty(JSON_EVENT_MESSAGE_FIELD, "Invalid JSON parse data format due to: " + exceptionMessage);
return new ResponseEntity<>(errorResponse, HttpStatus.INTERNAL_SERVER_ERROR);
Expand All @@ -223,11 +225,11 @@ public ResponseEntity generateAndPublish(final String msgProtocol, final String
MsgService msgService = PublishUtils.getMessageService(msgProtocol, msgServices);
List<JsonObject> events = new ArrayList<>();
if (bodyJson.isJsonObject()) {
events.add(bodyJson.getAsJsonObject());
events.add(getAsJsonObject(bodyJson));
} else if (bodyJson.isJsonArray()) {
for (JsonElement element : bodyJson.getAsJsonArray()) {
if (element.isJsonObject()) {
events.add(element.getAsJsonObject());
events.add(getAsJsonObject(element));
} else {
return new ResponseEntity<>("Invalid, array events must be a JSON object", HttpStatus.BAD_REQUEST);
}
Expand Down Expand Up @@ -284,25 +286,8 @@ public ResponseEntity generateAndPublish(final String msgProtocol, final String
if (msgService != null && msgProtocol != null) {
rmqHelper.rabbitMqPropertiesInit(msgProtocol);
}
JsonElement element = JsonParser.parseString(responseBody);

for (int i = 0; i < element.getAsJsonArray().size(); i++) {
eventResponse = new HashMap<>();
JsonElement jsonResponseEvent = element.getAsJsonArray().get(i);
if (isValid(jsonResponseEvent)) {
synchronized (this) {
JsonObject validResponse = jsonResponseEvent.getAsJsonObject();
String validResponseBody = validResponse.toString();
SendResult result = messageService.send(validResponseBody, msgService, userDomain, tag, routingKey);
eventResponse.put(JSON_STATUS_RESULT, result);
}
} else {
eventResponse.put(JSON_EVENT_STATUS_VALUE, HttpStatus.BAD_REQUEST);
eventResponse.put("like", HttpStatus.ACCEPTED);
eventResponse.put(JSON_EVENT_MESSAGE_FIELD, jsonResponseEvent);
}
responseEvents.add(eventResponse);
}
responseEvents = processingValidEvent(responseBody, msgProtocol, userDomain,
tag, routingKey);
} else {
return response;
}
Expand All @@ -311,37 +296,51 @@ public ResponseEntity generateAndPublish(final String msgProtocol, final String
eventResponse.put(JSON_EVENT_MESSAGE_FIELD, e.getMessage());
return new ResponseEntity(eventResponse, HttpStatus.NOT_FOUND);
} catch (HttpStatusCodeException e) {
JsonElement element = JsonParser.parseString(e.getResponseBodyAsString());

for (int i = 0; i < element.getAsJsonArray().size(); i++) {
eventResponse = new HashMap<>();
JsonElement JsonResponseEvent = element.getAsJsonArray().get(i);
if (isValid(JsonResponseEvent)) {
synchronized (this) {
JsonObject validResponse = JsonResponseEvent.getAsJsonObject();
String validResponseBody = validResponse.toString();
SendResult result = messageService.send(validResponseBody, msgService, userDomain, tag, routingKey);
eventResponse.put(JSON_STATUS_RESULT, result);
}
} else {
eventResponse.put(JSON_EVENT_MESSAGE_FIELD, JsonResponseEvent);
}
responseEvents.add(eventResponse);
}
responseEvents = processingValidEvent(e.getResponseBodyAsString(), msgProtocol, userDomain,
tag, routingKey);
return new ResponseEntity<>(responseEvents, HttpStatus.BAD_REQUEST);
}
return new ResponseEntity<>(responseEvents, HttpStatus.OK);
}

public List<Map<String, Object>> processingValidEvent(String eventMsg, final String msgProtocol, final String userDomain,
final String tag, final String routingKey) {
MsgService msgService = PublishUtils.getMessageService(msgProtocol, msgServices);
List<Map<String, Object>> responseEvent = new ArrayList<>();
Map<String, Object> eventResponse;
JsonElement element = JsonParser.parseString(eventMsg);
for (int i = 0; i < element.getAsJsonArray().size(); i++) {
eventResponse = new HashMap<>();
JsonElement jsonResponseEvent = element.getAsJsonArray().get(i);
if (isValid(jsonResponseEvent)) {
synchronized (this) {
JsonObject validResponse = jsonResponseEvent.getAsJsonObject();
String validResponseBody = validResponse.toString();
SendResult result = messageService.send(validResponseBody, msgService, userDomain, tag, routingKey);
eventResponse.put(JSON_STATUS_RESULT, result);
}
} else {
eventResponse.put(JSON_EVENT_MESSAGE_FIELD, jsonResponseEvent);
}
responseEvent.add(eventResponse);
}
return responseEvent;
}

public JsonObject getAsJsonObject(JsonElement jsonElement) {
JsonObject jsonObject = jsonElement.getAsJsonObject();
return jsonObject;
}

/**
* This helper method check the json event is valid or not
*/

private Boolean isValid(JsonElement jsonObject) {
private Boolean isValid(JsonElement jsonElement) {
try {
return jsonObject.getAsJsonObject().has("meta") && jsonObject.getAsJsonObject().has("data") &&
jsonObject.getAsJsonObject().has("links") && !jsonObject.getAsJsonObject().has("Status code");
} catch (Exception e) {
return getAsJsonObject(jsonElement).has(META) && getAsJsonObject(jsonElement).has("data") &&
getAsJsonObject(jsonElement).has("links") && !getAsJsonObject(jsonElement).has(STATUS_CODE);
} catch (IllegalStateException e) {
log.error("Error while validating event: ", e.getMessage());
return false;
}
Expand Down

0 comments on commit 2d55610

Please sign in to comment.