PIN-4903 BKE - Error during selfcare information retrieve at the crea…

…tion of agreement contract
pagopa · May 16, 2024 · d94af22 · d94af22
1 parent 88402a0
commit d94af22
Show file tree

Hide file tree

Showing 2 changed files with 33 additions and 9 deletions.
diff --git a/src/main/scala/it/pagopa/interop/agreementprocess/error/AgreementProcessErrors.scala b/src/main/scala/it/pagopa/interop/agreementprocess/error/AgreementProcessErrors.scala
@@ -115,4 +115,11 @@ object AgreementProcessErrors {
 
   final case class SelfcareEntityNotFilled(className: String, field: String)
       extends ComponentError("0026", s"Selfcare entity $className with field $field not filled")
+
+  final case class MissingUsersInfo(consumerId: UUID, producerId: UUID)
+      extends ComponentError(
+        "0027",
+        s"Some mandatory info are missing for consumer ${consumerId.toString()} and producer ${producerId.toString()}"
+      )
+
 }
diff --git a/src/main/scala/it/pagopa/interop/agreementprocess/service/AgreementContractCreator.scala b/src/main/scala/it/pagopa/interop/agreementprocess/service/AgreementContractCreator.scala
@@ -4,7 +4,12 @@ import akka.http.scaladsl.model.MediaTypes
 import it.pagopa.interop.agreementprocess.common.Adapters._
 import it.pagopa.interop.agreementmanagement.client.model.{DocumentSeed, UpdateAgreementSeed}
 import it.pagopa.interop.agreementprocess.common.system.ApplicationConfiguration
-import it.pagopa.interop.agreementprocess.error.AgreementProcessErrors.{MissingUserInfo, StampNotFound}
+import it.pagopa.interop.agreementprocess.error.AgreementProcessErrors.{
+  MissingUserInfo,
+  StampNotFound,
+  MissingUsersInfo,
+  SelfcareIdNotFound
+}
 import it.pagopa.interop.agreementprocess.service.util.PDFPayload
 import it.pagopa.interop.commons.cqrs.service.ReadModelService
 import it.pagopa.interop.commons.files.service.FileManager
@@ -119,14 +124,26 @@ final class AgreementContractCreator(
 
   }
 
-  def getSubmissionInfo(
-    seed: UpdateAgreementSeed
-  )(implicit contexts: Seq[(String, String)], ec: ExecutionContext): Future[(String, OffsetDateTime)] =
+  def getSubmissionInfo(seed: UpdateAgreementSeed, consumer: PersistentTenant, producer: PersistentTenant)(implicit
+    contexts: Seq[(String, String)],
+    ec: ExecutionContext
+  ): Future[(String, OffsetDateTime)] =
     for {
-      selfcareUuidd   <- getSelfcareIdFutureUUID(contexts)
-      submission      <- seed.stamps.submission.toFuture(StampNotFound("submission"))
-      userResponse    <- selfcareV2ClientService.getUserById(selfcareUuidd, submission.who).map(_.toApi)
-      userResponseApi <- userResponse.toFuture.recoverWith { case _ => Future.failed(MissingUserInfo(submission.who)) }
+      submission                 <- seed.stamps.submission.toFuture(StampNotFound("submission"))
+      consumerSelfcareId         <- consumer.selfcareId.toFuture(SelfcareIdNotFound(consumer.id))
+      producerSelfcareId         <- producer.selfcareId.toFuture(SelfcareIdNotFound(producer.id))
+      consumerSelfcareUuid       <- consumerSelfcareId.toFutureUUID
+      producerSelfcareUuid       <- producerSelfcareId.toFutureUUID
+      consumerSelfcare           <- selfcareV2ClientService.getInstitution(consumerSelfcareUuid).map(_.toApi)
+      producerSelfcare           <- selfcareV2ClientService.getInstitution(producerSelfcareUuid).map(_.toApi)
+      (consumerApi, producerApi) <- consumerSelfcare.toFuture.zip(producerSelfcare.toFuture)
+      userResponse               <- selfcareV2ClientService
+        .getUserById(consumerSelfcareUuid, consumerApi.id)
+        .recoverWith { case _ => selfcareV2ClientService.getUserById(producerSelfcareUuid, producerApi.id) }
+        .map(_.toApi)
+      userResponseApi            <- userResponse.toFuture.recoverWith { case _ =>
+        Future.failed(MissingUsersInfo(consumerApi.id, producerApi.id))
+      }
       submitter = getUserText(userResponseApi)
     } yield (submitter, submission.when)
 
@@ -152,7 +169,7 @@ final class AgreementContractCreator(
   )(implicit contexts: Seq[(String, String)], ec: ExecutionContext): Future[PDFPayload] = {
     for {
       (certified, declared, verified)  <- getAttributeInvolved(consumer, seed)
-      (submitter, submissionTimestamp) <- getSubmissionInfo(seed)
+      (submitter, submissionTimestamp) <- getSubmissionInfo(seed, consumer, producer)
       (activator, activationTimestamp) <- getActivationInfo(seed)
     } yield PDFPayload(
       today = offsetDateTimeSupplier.get(),