PIN-4727: Add notification for agreement upgrade

pagopa · Mar 21, 2024 · d31cfcc · d31cfcc
1 parent b2f376a
commit d31cfcc
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/main/scala/it/pagopa/interop/notifier/service/converters/AgreementEventsConverter.scala b/src/main/scala/it/pagopa/interop/notifier/service/converters/AgreementEventsConverter.scala
@@ -5,6 +5,7 @@ import it.pagopa.interop.commons.utils.errors.ComponentError
 import it.pagopa.interop.notifier.model.{AgreementPayload, MessageId, NotificationObjectType, NotificationPayload}
 import it.pagopa.interop.notifier.service.impl.DynamoNotificationResourcesService
 import cats.syntax.all._
+import it.pagopa.interop.agreementmanagement.model.agreement.Draft
 import it.pagopa.interop.notifier.service.converters.agreementsPartition
 
 import scala.concurrent.{ExecutionContext, Future}
@@ -47,8 +48,10 @@ object AgreementEventsConverter {
   }
 
   private[this] def getEventNotificationPayload(event: Event): Option[NotificationPayload] = event match {
-    // Agreements are created with status Draft, and should not be notified
-    case _: AgreementAdded                       => None
+    // This event is emitted both on Draft creation and upgrade.
+    //  Draft creation should not be notified
+    case AgreementAdded(a) if a.state != Draft   =>
+      AgreementPayload(agreementId = a.id.toString(), eventType = EventType.ADDED.toString()).some
     case AgreementUpdated(a)                     =>
       AgreementPayload(agreementId = a.id.toString(), eventType = EventType.UPDATED.toString()).some
     // Only agreements that have never been active can be deleted