[SELC-5740] Fix: Added custom code to parse different format of date (#…

…199)

apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/UserGroupCdcService.java

@@ -15,7 +15,6 @@
 import io.quarkus.runtime.Startup;
 import io.quarkus.runtime.configuration.ConfigUtils;
 import io.smallrye.mutiny.Multi;
-import io.smallrye.mutiny.Uni;
 import it.pagopa.selfcare.user.client.EventHubRestClient;
 import it.pagopa.selfcare.user.event.entity.UserGroupEntity;
 import it.pagopa.selfcare.user.event.mapper.UserGroupNotificationMapper;
@@ -30,16 +29,17 @@
 import org.eclipse.microprofile.rest.client.inject.RestClient;
 
 import java.time.Duration;
-import java.util.*;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
 
 import static com.mongodb.client.model.Projections.fields;
 import static com.mongodb.client.model.Projections.include;
 import static it.pagopa.selfcare.user.UserUtils.mapPropsForTrackEvent;
 import static it.pagopa.selfcare.user.event.constant.CdcStartAtConstant.*;
-import static it.pagopa.selfcare.user.model.TrackEventInput.toTrackEventInput;
 import static it.pagopa.selfcare.user.model.TrackEventInput.toTrackEventInputForUserGroup;
 import static it.pagopa.selfcare.user.model.constants.EventsMetric.*;
-import static it.pagopa.selfcare.user.model.constants.EventsName.EVENT_USER_CDC_NAME;
 import static it.pagopa.selfcare.user.model.constants.EventsName.EVENT_USER_GROUP_CDC_NAME;
 import static java.util.Arrays.asList;
 

apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/config/DateCodec.java

@@ -0,0 +1,37 @@
+package it.pagopa.selfcare.user.event.config;
+
+import org.bson.BsonReader;
+import org.bson.BsonTimestamp;
+import org.bson.BsonType;
+import org.bson.BsonWriter;
+import org.bson.codecs.Codec;
+import org.bson.codecs.DecoderContext;
+import org.bson.codecs.EncoderContext;
+
+import java.time.Instant;
+
+public class DateCodec implements Codec<Instant> {
+
+    @Override
+    public Instant decode(BsonReader reader, DecoderContext decoderContext) {
+        BsonType currentType = reader.getCurrentBsonType();
+        if (currentType.equals(BsonType.DATE_TIME)) {
+            return Instant.ofEpochMilli(reader.readDateTime());
+        } else if (currentType.equals(BsonType.TIMESTAMP)) {
+            BsonTimestamp timestamp = reader.readTimestamp();
+            return Instant.ofEpochSecond(timestamp.getTime(), timestamp.getInc());
+        }
+        return null;
+    }
+
+
+    @Override
+    public void encode(BsonWriter bsonWriter, Instant aLong, EncoderContext encoderContext) {
+
+    }
+
+    @Override
+    public Class<Instant> getEncoderClass() {
+        return Instant.class;
+    }
+}

apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/config/MongoConfig.java

@@ -0,0 +1,20 @@
+package it.pagopa.selfcare.user.event.config;
+
+import jakarta.enterprise.context.ApplicationScoped;
+
+import jakarta.enterprise.inject.Produces;
+import org.bson.codecs.configuration.CodecRegistries;
+import org.bson.codecs.configuration.CodecRegistry;
+import com.mongodb.MongoClientSettings;
+
+@ApplicationScoped
+public class MongoConfig {
+
+    @Produces
+    public CodecRegistry produceCodecRegistry() {
+        CodecRegistry defaultCodecRegistry = MongoClientSettings.getDefaultCodecRegistry();
+        CodecRegistry customCodecRegistry = CodecRegistries.fromCodecs(new DateCodec());
+
+        return CodecRegistries.fromRegistries(customCodecRegistry, defaultCodecRegistry);
+    }
+}

apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/entity/UserGroupEntity.java

@@ -5,6 +5,7 @@
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.FieldNameConstants;
+import org.bson.types.ObjectId;
 
 import java.time.Instant;
 import java.util.Set;
@@ -15,7 +16,7 @@
 @FieldNameConstants(asEnum = true)
 public class UserGroupEntity extends ReactivePanacheMongoEntity {
 
-    private String id;
+    private ObjectId id;
     private String institutionId;
     private String productId;
     private String name;

apps/user-group-cdc/src/main/java/it/pagopa/selfcare/user/event/mapper/UserGroupNotificationMapper.java

@@ -3,9 +3,11 @@
 import it.pagopa.selfcare.user.event.entity.UserGroupEntity;
 import it.pagopa.selfcare.user.model.UserGroupNotificationToSend;
 import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
 
 @Mapper(componentModel = "cdi")
 public interface UserGroupNotificationMapper {
 
+    @Mapping(target = "id", expression = "java(java.util.Objects.nonNull(userGroupEntity.getId()) ? userGroupEntity.getId().toHexString() : null)")
     UserGroupNotificationToSend toUserGroupNotificationToSend(UserGroupEntity userGroupEntity);
 }

apps/user-group-cdc/src/main/resources/application.properties

@@ -18,4 +18,4 @@ user-group-cdc.retry=${USER_GROUP_CDC-RETRY:3}
 
 quarkus.rest-client.event-hub.url=${EVENT_HUB_BASE_PATH:test}
 eventhub.rest-client.keyName=${SHARED_ACCESS_KEY_NAME:test}
-eventhub.rest-client.key=${EVENTHUB-SC-USERS-GROUP-SELFCARE-WO-KEY-LC:test}
+eventhub.rest-client.key=${EVENTHUB-SC-USER-GROUPS-SELFCARE-WO-KEY-LC:test}

apps/user-group-cdc/src/test/java/it/pagopa/selfcare/user/event/service/UserGroupCdcServiceTest.java

@@ -12,6 +12,7 @@
 import it.pagopa.selfcare.user.model.UserGroupNotificationToSend;
 import jakarta.inject.Inject;
 import org.bson.BsonDocument;
+import org.bson.types.ObjectId;
 import org.eclipse.microprofile.rest.client.inject.RestClient;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
@@ -49,15 +50,15 @@ void consumerToSendScUserGroupEventTest() {
         userGroupCdcService.consumerToSendScUserGroupEvent(document);
         verify(eventHubRestClient, times(1)).
                 sendUserGroupMessage(notification.capture());
-        Assertions.assertEquals(userGroupEntity.getId(), notification.getValue().getId());
+        Assertions.assertEquals(userGroupEntity.getId().toString(), notification.getValue().getId());
         Assertions.assertEquals(userGroupEntity.getInstitutionId(), notification.getValue().getInstitutionId());
         Assertions.assertEquals(userGroupEntity.getProductId(), notification.getValue().getProductId());
         Assertions.assertEquals(2, notification.getValue().getMembers().size());
     }
 
     UserGroupEntity dummyUserGroup() {
         UserGroupEntity userGroupEntity = new UserGroupEntity();
-        userGroupEntity.setId("UserGroupId");
+        userGroupEntity.setId(new ObjectId());
         userGroupEntity.setInstitutionId("InstitutionId");
         userGroupEntity.setProductId("ProductId");
         userGroupEntity.setMembers(Set.of("Member1", "Member2"));

libs/user-sdk-event/src/main/java/it/pagopa/selfcare/user/UserUtils.java

@@ -62,6 +62,7 @@ public static Map<String, String> mapPropsForTrackEvent(TrackEventInput trackEve
         Optional.ofNullable(trackEventInput.getProductId()).ifPresent(value -> propertiesMap.put("productId", value));
         Optional.ofNullable(trackEventInput.getInstitutionId()).ifPresent(value -> propertiesMap.put("institutionId", value));
         Optional.ofNullable(trackEventInput.getProductRole()).ifPresent(value -> propertiesMap.put("productRole", value));
+        Optional.ofNullable(trackEventInput.getGroupMembers()).ifPresent(value -> propertiesMap.put("groupMembers", String.join(",", value)));
         Optional.ofNullable(trackEventInput.getException()).ifPresent(value -> propertiesMap.put("exec", value));
         return propertiesMap;
     }