PIN-4739: Add PurposeVersionRejected event (#80)

pagopa · Mar 25, 2024 · b6e4192 · b6e4192
1 parent b2f376a
commit b6e4192
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/main/scala/it/pagopa/interop/notifier/service/converters/PurposeEventsConverter.scala b/src/main/scala/it/pagopa/interop/notifier/service/converters/PurposeEventsConverter.scala
@@ -48,6 +48,8 @@ object PurposeEventsConverter {
       case PurposeVersionUpdated(purposeId, _)      => getMessageIdFromDynamo(dynamoIndexService)(purposeId).map(_.some)
       case PurposeVersionDeleted(purposeId, _)      => getMessageIdFromDynamo(dynamoIndexService)(purposeId).map(_.some)
       case PurposeDeleted(purposeId)                => getMessageIdFromDynamo(dynamoIndexService)(purposeId).map(_.some)
+      case PurposeVersionRejected(purpose, _)       =>
+        getMessageIdFromDynamo(dynamoIndexService)(purpose.id.toString).map(_.some)
     }
 
   def asNotificationPayload: PartialFunction[ProjectableEvent, Either[ComponentError, Option[NotificationPayload]]] = {
@@ -68,6 +70,7 @@ object PurposeEventsConverter {
       case PurposeVersionWaitedForApproval(purpose) =>
         PurposePayload(purpose.id.toString(), WAITING_FOR_APPROVAL.toString).some
       case PurposeVersionArchived(purpose)          => PurposePayload(purpose.id.toString(), ARCHIVED.toString()).some
+      case PurposeVersionRejected(purpose, _)       => PurposePayload(purpose.id.toString(), REJECTED.toString()).some
       // Only on Drafts, should not be notified
       case _: PurposeVersionUpdated                 => None
       // Only on Drafts, should not be notified

diff --git a/src/main/scala/it/pagopa/interop/notifier/service/converters/package.scala b/src/main/scala/it/pagopa/interop/notifier/service/converters/package.scala
@@ -27,7 +27,7 @@ package object converters {
 
   object EventType extends Enumeration {
     type EventType = Value
-    val ADDED, CREATED, CLONED, DELETED, UPDATED, SUSPENDED, ACTIVATED, ARCHIVED, WAITING_FOR_APPROVAL = Value
+    val ADDED, CREATED, CLONED, DELETED, UPDATED, SUSPENDED, ACTIVATED, ARCHIVED, WAITING_FOR_APPROVAL, REJECTED = Value
   }
 
   def getMessageIdFromDynamo(