Please work
This commit is contained in:
@@ -109,17 +109,13 @@ public class ChatController {
|
|||||||
ObjectMapper mapper = new ObjectMapper();
|
ObjectMapper mapper = new ObjectMapper();
|
||||||
WebexWebhook payload = mapper.readValue(rawPayload, WebexWebhook.class);
|
WebexWebhook payload = mapper.readValue(rawPayload, WebexWebhook.class);
|
||||||
|
|
||||||
expectedMessages.compute(payload.getData().getId(), (key, seen) -> {
|
boolean firstTime = expectedMessages.putIfAbsent(payload.getData().getId(), 1) == null;
|
||||||
if (seen == null) {
|
if (!firstTime) {
|
||||||
Logger.displayInfo("Accepted message: " + key);
|
Logger.displayInfo("Rejected message: " + payload.getData().getId());
|
||||||
return 1;
|
return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body(result);
|
||||||
} else if (seen >= 1) {
|
}
|
||||||
Logger.displayInfo("Rejected message: " + key);
|
|
||||||
return null;
|
Logger.displayInfo("Accepted message: " + payload.getData().getId());
|
||||||
} else {
|
|
||||||
return seen + 1;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
Room room = webexService.getRoomById(payload.getData().getRoomId());
|
Room room = webexService.getRoomById(payload.getData().getRoomId());
|
||||||
Message msg = webexService.fetchMessage(payload.getData().getId());
|
Message msg = webexService.fetchMessage(payload.getData().getId());
|
||||||
|
|||||||
Reference in New Issue
Block a user