This commit is contained in:
2026-01-02 23:14:53 +01:00
parent 137acc846a
commit 8fbe1eccea

View File

@@ -53,7 +53,7 @@ public class ChatController {
String messageId = this.webexService.post(model); String messageId = this.webexService.post(model);
model.setId(messageId); model.setId(messageId);
this.messageService.save(model); this.messageService.save(model);
expectedMessages.put(messageId, 0); expectedMessages.put(messageId, 1);
result.setSuccess(true); result.setSuccess(true);
result.setData(messageId); result.setData(messageId);
@@ -110,13 +110,16 @@ 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);
int seen = expectedMessages.get(payload.getData().getId()); Integer seen = expectedMessages.get(payload.getData().getId());
if (seen == 2) { if(seen != null){
Logger.displayInfo("Rejected"); if(seen > 1){
expectedMessages.remove(payload.getData().getId()); Logger.displayInfo("Rejected");
return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body(result); expectedMessages.remove(payload.getData().getId());
} else {
seen += 1;
expectedMessages.put(payload.getData().getId(), seen);
}
} }
Logger.displayInfo("Accepted");
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());