PIN-3985 Implemented Creation of the RiskAnalisys

project/Dependencies.scala

@@ -71,6 +71,10 @@ object Dependencies {
 
     lazy val catalogManagementClient =
       namespace %% "interop-be-catalog-management-client" % catalogManagementVersion
+
+    lazy val tenantManagementModels =
+      namespace %% "interop-be-tenant-management-models" % tenantManagementVersion  
+
     lazy val catalogManagementModels =
       namespace %% "interop-be-catalog-management-models" % catalogManagementVersion
 
@@ -80,10 +84,11 @@ object Dependencies {
     lazy val authorizationManagementClient =
       namespace %% "interop-be-authorization-management-client" % authorizationManagementVersion
 
-    lazy val commonsUtils = namespace %% "interop-commons-utils"        % commonsVersion
-    lazy val fileManager  = namespace %% "interop-commons-file-manager" % commonsVersion
-    lazy val commonsJWT   = namespace %% "interop-commons-jwt"          % commonsVersion
-    lazy val commonsCqrs  = namespace %% "interop-commons-cqrs"         % commonsVersion
+    lazy val commonsUtils = namespace %% "interop-commons-utils"          % commonsVersion
+    lazy val fileManager  = namespace %% "interop-commons-file-manager"   % commonsVersion
+    lazy val commonsJWT   = namespace %% "interop-commons-jwt"            % commonsVersion
+    lazy val commonsCqrs  = namespace %% "interop-commons-cqrs"           % commonsVersion
+    lazy val riskAnalysis = namespace %% "interop-commons-risk-analysis"  % commonsVersion
   }
 
   object Jars {
@@ -109,10 +114,12 @@ object Dependencies {
       pagopa.catalogManagementModels           % Compile,
       pagopa.agreementManagementModels         % Compile,
       pagopa.authorizationManagementClient     % Compile,
+      pagopa.tenantManagementModels            % Compile,
       pagopa.commonsUtils                      % Compile,
       pagopa.fileManager                       % Compile,
       pagopa.commonsJWT                        % Compile,
       pagopa.commonsCqrs                       % Compile,
+      pagopa.riskAnalysis                      % Compile,
       akka.testkit                             % Test,
       akka.httpTestkit                         % Test,
       scalatest.core                           % Test,

src/main/resources/interface-specification.yml

@@ -864,6 +864,150 @@ paths:
             application/problem+json:
               schema:
                 $ref: '#/components/schemas/Problem'
+  /eservices/{eServiceId}/riskAnalysis:
+    parameters:
+      - $ref: '#/components/parameters/CorrelationIdHeader'
+      - $ref: '#/components/parameters/IpAddress'
+    post:
+      security:
+        - bearerAuth: []
+      tags:
+        - process
+      summary: Create an e-service risk analysis
+      operationId: createRiskAnalysis
+      parameters:
+        - name: eServiceId
+          in: path
+          description: the eservice id
+          required: true
+          schema:
+            type: string
+            format: uuid
+      requestBody:
+        description: A payload containing the risk analysis
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/EServiceRiskAnalysisSeed'
+      responses:
+        '204':
+          description: EService Risk Analysis created.
+        '403':
+          description: Forbidden
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'    
+        '404':
+          description: EService not found
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'
+        '400':
+          description: Bad request
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'
+  /eservices/{eServiceId}/riskAnalysis/{riskAnalysisId}:
+    parameters:
+      - $ref: '#/components/parameters/CorrelationIdHeader'
+      - $ref: '#/components/parameters/IpAddress'
+    post:
+      security:
+        - bearerAuth: []
+      tags:
+        - process
+      summary: Update an e-service risk analysis
+      operationId: updateRiskAnalysis
+      parameters:
+        - name: eServiceId
+          in: path
+          description: the eservice id
+          required: true
+          schema:
+            type: string
+            format: uuid
+        - name: riskAnalysisId
+          in: path
+          description: the eservice id
+          required: true
+          schema:
+            type: string
+            format: uuid    
+      requestBody:
+        description: A payload containing the risk analysis to update
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/EServiceRiskAnalysisSeed'
+      responses:
+        '204':
+          description: EService Risk Analysis updated.
+        '403':
+          description: Forbidden
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'  
+        '404':
+          description: EService not found
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'
+        '400':
+          description: Bad request
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'
+    delete:
+      security:
+        - bearerAuth: []
+      tags:
+        - process
+      summary: Delete an e-service risk analysis
+      operationId: deleteRiskAnalysis
+      parameters:
+        - name: eServiceId
+          in: path
+          description: the eservice id
+          required: true
+          schema:
+            type: string
+            format: uuid
+        - name: riskAnalysisId
+          in: path
+          description: the eservice id
+          required: true
+          schema:
+            type: string
+            format: uuid    
+      responses:
+        '204':
+          description: EService Risk Analysis deleted.
+        '403':
+          description: Bad request
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'                          
+        '404':
+          description: EService not found
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'
+        '400':
+          description: Bad request
+          content:
+            application/problem+json:
+              schema:
+                $ref: '#/components/schemas/Problem'                          
   /status:
     get:
       security: []
@@ -1106,6 +1250,54 @@ components:
           format: uuid
         name:
           type: string
+    EServiceRiskAnalysisSeed:
+      type: object
+      required:
+        - name
+        - riskAnalysisForm
+      properties:
+        name:
+          type: string
+        riskAnalysisForm:
+          $ref:  '#/components/schemas/EServiceRiskAnalysisFormSeed'
+    EServiceRiskAnalysisFormSeed:
+      type: object
+      required:
+        - version
+        - singleAnswers
+        - multiAnswers
+      properties:
+        version:
+          type: string
+        singleAnswers:
+          type: array
+          items:
+            $ref: '#/components/schemas/EServiceRiskAnalysisSingleAnswerSeed'
+        multiAnswers:
+          type: array
+          items:
+            $ref: '#/components/schemas/EServiceRiskAnalysisMultiAnswerSeed'    
+    EServiceRiskAnalysisSingleAnswerSeed:
+      type: object
+      required:
+        - key
+      properties:
+        key:
+          type: string
+        value:
+          type: string
+    EServiceRiskAnalysisMultiAnswerSeed:
+      type: object
+      required:
+        - key
+        - values
+      properties:
+        key:
+          type: string
+        values:
+          type: array
+          items:
+            type: string            
     EService:
       type: object
       required:

src/main/scala/it/pagopa/interop/catalogprocess/api/impl/Converter.scala

@@ -3,8 +3,10 @@ package it.pagopa.interop.catalogprocess.api.impl
 import it.pagopa.interop.agreementmanagement.model.{agreement => AgreementPersistenceModel}
 import it.pagopa.interop.catalogmanagement.client.{model => CatalogManagementDependency}
 import it.pagopa.interop.catalogmanagement.{model => readmodel}
+import it.pagopa.interop.commons.riskanalysis.{model => Commons}
 import it.pagopa.interop.catalogprocess.model._
 import it.pagopa.interop.catalogprocess.common.readmodel.Consumers
+import it.pagopa.interop.tenantmanagement.model.tenant.PersistentTenantKind
 import it.pagopa.interop.catalogmanagement.model.{Deliver, Receive}
 
 import java.util.UUID
@@ -99,6 +101,48 @@ object Converter {
     )
   }
 
+  implicit class EServiceRiskAnalysisSeedWrapper(private val seed: EServiceRiskAnalysisSeed) extends AnyVal {
+    def toDependency: CatalogManagementDependency.RiskAnalysisSeed = CatalogManagementDependency.RiskAnalysisSeed(
+      name = seed.name,
+      riskAnalysisForm = seed.riskAnalysisForm.toDependency
+    )
+  }
+
+  implicit class EServiceRiskAnalysisFormSeedWrapper(private val seed: EServiceRiskAnalysisFormSeed) extends AnyVal {
+    def toDependency: CatalogManagementDependency.RiskAnalysisFormSeed =
+      CatalogManagementDependency.RiskAnalysisFormSeed(
+        version = seed.version,
+        singleAnswers = seed.singleAnswers.map(_.toDependency),
+        multiAnswers = seed.multiAnswers.map(_.toDependency)
+      )
+    def toTemplate: Commons.RiskAnalysisForm                           = Commons.RiskAnalysisForm(
+      version = seed.version,
+      answers = (seed.singleAnswers.map(_.toTemplate).flatten ++ seed.multiAnswers.map(_.toTemplate).flatten).toMap
+    )
+  }
+
+  implicit class PersistentTenantKindrapper(private val kind: PersistentTenantKind) extends AnyVal {
+    def toTemplate: Commons.RiskAnalysisTenantKind = kind match {
+      case PersistentTenantKind.PA      => Commons.RiskAnalysisTenantKind.PA
+      case PersistentTenantKind.GSP     => Commons.RiskAnalysisTenantKind.GSP
+      case PersistentTenantKind.PRIVATE => Commons.RiskAnalysisTenantKind.PRIVATE
+    }
+  }
+
+  implicit class EServiceRiskAnalysisSingleAnswerSeedWrapper(private val seed: EServiceRiskAnalysisSingleAnswerSeed)
+      extends AnyVal {
+    def toDependency: CatalogManagementDependency.RiskAnalysisSingleAnswerSeed =
+      CatalogManagementDependency.RiskAnalysisSingleAnswerSeed(key = seed.key, value = seed.value)
+    def toTemplate: Map[String, Seq[String]]                                   = Map(seed.key -> seed.value.toSeq)
+  }
+
+  implicit class EServiceRiskAnalysisMultiAnswerSeedWrapper(private val seed: EServiceRiskAnalysisMultiAnswerSeed)
+      extends AnyVal {
+    def toDependency: CatalogManagementDependency.RiskAnalysisMultiAnswerSeed =
+      CatalogManagementDependency.RiskAnalysisMultiAnswerSeed(key = seed.key, values = seed.values)
+    def toTemplate: Map[String, Seq[String]]                                  = Map(seed.key -> seed.values)
+  }
+
   implicit class EServiceDescriptorDocumentSeedWrapper(private val seed: UpdateEServiceDescriptorDocumentSeed)
       extends AnyVal {
     def toDependency: CatalogManagementDependency.UpdateEServiceDescriptorDocumentSeed =
@@ -355,18 +399,25 @@ object Converter {
       singleAnswers = p.singleAnswers.map(_.toApi),
       multiAnswers = p.multiAnswers.map(_.toApi)
     )
+
+    def toTemplate: Commons.RiskAnalysisForm = Commons.RiskAnalysisForm(
+      version = p.version,
+      answers = (p.singleAnswers.map(_.toTemplate).flatten ++ p.multiAnswers.map(_.toTemplate).flatten).toMap
+    )
   }
 
   implicit class CatalogRiskAnalysisSingleAnswerObjectWrapper(private val p: readmodel.CatalogRiskAnalysisSingleAnswer)
       extends AnyVal {
     def toApi: EServiceRiskAnalysisSingleAnswer =
       EServiceRiskAnalysisSingleAnswer(id = p.id, key = p.key, value = p.value)
+    def toTemplate: Map[String, Seq[String]]    = Map(p.key -> p.value.toSeq)
   }
 
   implicit class CatalogRiskAnalysisMultiAnswerObjectWrapper(private val p: readmodel.CatalogRiskAnalysisMultiAnswer)
       extends AnyVal {
     def toApi: EServiceRiskAnalysisMultiAnswer =
       EServiceRiskAnalysisMultiAnswer(id = p.id, key = p.key, values = p.values)
+    def toTemplate: Map[String, Seq[String]]   = Map(p.key -> p.values)
   }
 
   implicit class ReadModelModeWrapper(private val mode: readmodel.CatalogItemMode) extends AnyVal {

src/main/scala/it/pagopa/interop/catalogprocess/api/impl/ProcessApiMarshallerImpl.scala

@@ -44,4 +44,6 @@ object ProcessApiMarshallerImpl extends ProcessApiMarshaller with SprayJsonSuppo
   override implicit def toEntityMarshallerEServiceConsumers: ToEntityMarshaller[EServiceConsumers] =
     sprayJsonMarshaller[EServiceConsumers]
 
+  override implicit def fromEntityUnmarshallerEServiceRiskAnalysisSeed
+    : FromEntityUnmarshaller[EServiceRiskAnalysisSeed] = sprayJsonUnmarshaller[EServiceRiskAnalysisSeed]
 }