From 043fc17935cfbb71edab9e3069f0f37283fcdf0c Mon Sep 17 00:00:00 2001 From: Pol Pinol Castuera Date: Wed, 28 May 2025 20:09:15 +0200 Subject: [PATCH] fix snake case --- .../infrastructure/listeners/PubsubEventMapper.java | 4 +--- .../infrastructure/listeners/PubsubNewsEventSubscriber.java | 6 ------ 2 files changed, 1 insertion(+), 9 deletions(-) diff --git a/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubEventMapper.java b/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubEventMapper.java index 8480848..3c1384e 100644 --- a/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubEventMapper.java +++ b/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubEventMapper.java @@ -11,9 +11,7 @@ @Component @RequiredArgsConstructor public class PubsubEventMapper { - - private final ObjectMapper mapper = - new ObjectMapper().setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE); + private final ObjectMapper mapper; public PubsubEvent fromMap(Map raw) { return mapper.convertValue(raw, PubsubEvent.class); diff --git a/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubNewsEventSubscriber.java b/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubNewsEventSubscriber.java index 694b45f..65eaf0f 100644 --- a/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubNewsEventSubscriber.java +++ b/src/main/java/io/autoinvestor/infrastructure/listeners/PubsubNewsEventSubscriber.java @@ -76,12 +76,6 @@ private void processMessage(PubsubMessage message, AckReplyConsumer consumer) { log.info("Processing event type={} msgId={}", event.getType(), msgId); if ("ASSET_FEELING_DETECTED".equals(event.getType())) { - if (event.getPayload() == null || !event.getPayload().containsKey("assetId") || !event.getPayload().containsKey("feeling")) { - log.warn("Event payload missing assetId or feeling, ignoring msgId={}", msgId); - consumer.ack(); - return; - } - Object rawFeeling = event.getPayload().get("feeling"); int feeling; if (rawFeeling instanceof Number) {