Skip to content

Commit 891b22f

Browse files
Benedetta-fabbriBenedetta-fabbri
authored
feat: Promote to UAT (#372)
2 parents 6246bd0 + 463be6a commit 891b22f

26 files changed

+1055
-409
lines changed

‎.github/CODEOWNERS‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
# Add the repository's code owners here
2-
* @pagopa/p4pa-admins @pagopa/payments-cloud-admin @pagopa/p4pa-developers @antocalo @Benedetta-fabbri @RiccardoGiuliani @MScarsella @ElisKina-dev @Giuseppe-LaManna @dan-ntt @pelliccm @LeonardoPierangeliniNttData
2+
* @pagopa/p4pa-admins @pagopa/payments-cloud-admin @pagopa/p4pa-developers @antocalo @Benedetta-fabbri @ElisKina-dev @Giuseppe-LaManna @LeonardoPierangeliniNttData

‎build.gradle.kts‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ val commonsLang3Version = "3.20.0"
7676
val lz4JavaVersion = "1.10.1"
7777
val springCloudDepsVersion = "2025.1.0"
7878

79-
val p4paActivitiesVersion = "1.171.2"
79+
val p4paActivitiesVersion = "1.176.1"
8080

8181
dependencyManagement {
8282
imports {

‎gradle.lockfile‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ io.temporal:temporal-spring-boot-autoconfigure:1.32.1=compileClasspath
8080
io.temporal:temporal-spring-boot-starter:1.32.1=compileClasspath
8181
io.temporal:temporal-test-server:1.32.1=compileClasspath
8282
io.temporal:temporal-testing:1.32.1=compileClasspath
83-
it.gov.pagopa.payhub:p4pa-payhub-activities:1.171.2=compileClasspath
83+
it.gov.pagopa.payhub:p4pa-payhub-activities:1.176.1=compileClasspath
8484
jakarta.activation:jakarta.activation-api:2.1.4=compileClasspath
8585
jakarta.annotation:jakarta.annotation-api:3.0.0=compileClasspath
8686
jakarta.persistence:jakarta.persistence-api:3.2.0=compileClasspath

‎openapi/generated.openapi.json‎

Lines changed: 90 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -1682,6 +1682,47 @@
16821682
} ]
16831683
}
16841684
},
1685+
"/workflowhub/workflow/send-notification/streams/{streamId}/consume" : {
1686+
"get" : {
1687+
"tags" : [ "SendNotification" ],
1688+
"description" : "Start send stream events consume process.",
1689+
"operationId" : "consumeSendStream",
1690+
"parameters" : [ {
1691+
"name" : "streamId",
1692+
"in" : "path",
1693+
"description" : "The id of send stream.",
1694+
"required" : true,
1695+
"schema" : {
1696+
"type" : "string"
1697+
}
1698+
} ],
1699+
"responses" : {
1700+
"200" : {
1701+
"description" : "Consume of stream started",
1702+
"content" : {
1703+
"application/json" : {
1704+
"schema" : {
1705+
"$ref" : "#/components/schemas/WorkflowCreatedDTO"
1706+
}
1707+
}
1708+
}
1709+
},
1710+
"500" : {
1711+
"description" : "Server Error",
1712+
"content" : {
1713+
"application/json" : {
1714+
"schema" : {
1715+
"$ref" : "#/components/schemas/WorkflowErrorDTO"
1716+
}
1717+
}
1718+
}
1719+
}
1720+
},
1721+
"security" : [ {
1722+
"BearerAuth" : [ ]
1723+
} ]
1724+
}
1725+
},
16851726
"/workflowhub/schedules/{scheduleId}/info" : {
16861727
"get" : {
16871728
"tags" : [ "Schedule" ],
@@ -1832,27 +1873,6 @@
18321873
}
18331874
}
18341875
},
1835-
"PageMetadata" : {
1836-
"type" : "object",
1837-
"properties" : {
1838-
"size" : {
1839-
"type" : "integer",
1840-
"format" : "int64"
1841-
},
1842-
"totalElements" : {
1843-
"type" : "integer",
1844-
"format" : "int64"
1845-
},
1846-
"totalPages" : {
1847-
"type" : "integer",
1848-
"format" : "int64"
1849-
},
1850-
"number" : {
1851-
"type" : "integer",
1852-
"format" : "int64"
1853-
}
1854-
}
1855-
},
18561876
"DebtPositionSyncWfName" : {
18571877
"type" : "string",
18581878
"enum" : [ "fineWf" ]
@@ -1910,6 +1930,27 @@
19101930
}
19111931
}
19121932
},
1933+
"PageMetadata" : {
1934+
"type" : "object",
1935+
"properties" : {
1936+
"size" : {
1937+
"type" : "integer",
1938+
"format" : "int64"
1939+
},
1940+
"totalElements" : {
1941+
"type" : "integer",
1942+
"format" : "int64"
1943+
},
1944+
"totalPages" : {
1945+
"type" : "integer",
1946+
"format" : "int64"
1947+
},
1948+
"number" : {
1949+
"type" : "integer",
1950+
"format" : "int64"
1951+
}
1952+
}
1953+
},
19131954
"WorkflowTypeOrg" : {
19141955
"type" : "object",
19151956
"properties" : {
@@ -2053,15 +2094,15 @@
20532094
},
20542095
"required" : [ "runId", "status", "taskQueue", "workflowId", "workflowType" ]
20552096
},
2056-
"CodeEnum" : {
2097+
"CategoryEnum" : {
20572098
"type" : "string",
20582099
"enum" : [ "WORKFLOW_INGESTION_FLOW_FILE_NOT_SUPPORTED", "WORKFLOW_CONFLICT", "WORKFLOW_NOT_FOUND", "WORKFLOW_BAD_REQUEST", "WORKFLOW_GENERIC_ERROR", "WORKFLOW_INVALID_SYNC_DP_WF_EXECUTION_CONFIG", "WORKFLOW_REQUEST_TIMEOUT" ]
20592100
},
20602101
"WorkflowErrorDTO" : {
20612102
"type" : "object",
20622103
"properties" : {
2063-
"code" : {
2064-
"$ref" : "#/components/schemas/CodeEnum"
2104+
"category" : {
2105+
"$ref" : "#/components/schemas/CategoryEnum"
20652106
},
20662107
"message" : {
20672108
"type" : "string"
@@ -2070,7 +2111,7 @@
20702111
"type" : "string"
20712112
}
20722113
},
2073-
"required" : [ "code", "message" ]
2114+
"required" : [ "category", "message" ]
20742115
},
20752116
"WorkflowCreatedDTO" : {
20762117
"type" : "object",
@@ -2573,7 +2614,7 @@
25732614
},
25742615
"required" : [ "createdAt", "lastExecution", "lastUpdatedAt", "nextActionTimes", "numActions", "numActionsMissedCatchupWindow", "numActionsSkippedOverlap", "recentActions", "runningActions", "scheduleId" ]
25752616
},
2576-
"DebtPositionWorkflowType" : {
2617+
"WorkflowType" : {
25772618
"type" : "object",
25782619
"properties" : {
25792620
"creationDate" : {
@@ -2590,34 +2631,34 @@
25902631
"updateTraceId" : {
25912632
"type" : "string"
25922633
},
2593-
"debtPositionId" : {
2634+
"workflowTypeId" : {
25942635
"type" : "integer",
25952636
"format" : "int64"
25962637
},
2597-
"workflowTypeOrgId" : {
2598-
"type" : "integer",
2599-
"format" : "int64"
2638+
"description" : {
2639+
"type" : "string"
26002640
},
2601-
"executionConfig" : {
2602-
"type" : "string",
2603-
"format" : "byte"
2641+
"defaultExecutionConfig" : {
2642+
"oneOf" : [ {
2643+
"$ref" : "#/components/schemas/FineWfExecutionConfig"
2644+
} ]
26042645
},
26052646
"_links" : {
26062647
"$ref" : "#/components/schemas/Links"
26072648
}
26082649
},
2609-
"required" : [ "debtPositionId", "executionConfig" ]
2650+
"required" : [ "defaultExecutionConfig", "description" ]
26102651
},
2611-
"PagedModelDebtPositionWorkflowType" : {
2652+
"PagedModelWorkflowType" : {
26122653
"type" : "object",
26132654
"properties" : {
26142655
"_embedded" : {
26152656
"type" : "object",
26162657
"properties" : {
2617-
"debtPositionWorkflowTypes" : {
2658+
"workflowTypes" : {
26182659
"type" : "array",
26192660
"items" : {
2620-
"$ref" : "#/components/schemas/DebtPositionWorkflowType"
2661+
"$ref" : "#/components/schemas/WorkflowType"
26212662
}
26222663
}
26232664
}
@@ -2630,7 +2671,7 @@
26302671
}
26312672
}
26322673
},
2633-
"WorkflowType" : {
2674+
"DebtPositionWorkflowType" : {
26342675
"type" : "object",
26352676
"properties" : {
26362677
"creationDate" : {
@@ -2647,34 +2688,34 @@
26472688
"updateTraceId" : {
26482689
"type" : "string"
26492690
},
2650-
"workflowTypeId" : {
2691+
"debtPositionId" : {
26512692
"type" : "integer",
26522693
"format" : "int64"
26532694
},
2654-
"description" : {
2655-
"type" : "string"
2695+
"workflowTypeOrgId" : {
2696+
"type" : "integer",
2697+
"format" : "int64"
26562698
},
2657-
"defaultExecutionConfig" : {
2658-
"oneOf" : [ {
2659-
"$ref" : "#/components/schemas/FineWfExecutionConfig"
2660-
} ]
2699+
"executionConfig" : {
2700+
"type" : "string",
2701+
"format" : "byte"
26612702
},
26622703
"_links" : {
26632704
"$ref" : "#/components/schemas/Links"
26642705
}
26652706
},
2666-
"required" : [ "defaultExecutionConfig", "description" ]
2707+
"required" : [ "debtPositionId", "executionConfig" ]
26672708
},
2668-
"PagedModelWorkflowType" : {
2709+
"PagedModelDebtPositionWorkflowType" : {
26692710
"type" : "object",
26702711
"properties" : {
26712712
"_embedded" : {
26722713
"type" : "object",
26732714
"properties" : {
2674-
"workflowTypes" : {
2715+
"debtPositionWorkflowTypes" : {
26752716
"type" : "array",
26762717
"items" : {
2677-
"$ref" : "#/components/schemas/WorkflowType"
2718+
"$ref" : "#/components/schemas/DebtPositionWorkflowType"
26782719
}
26792720
}
26802721
}

‎openapi/p4pa-workflow-hub.openapi.yaml‎

Lines changed: 28 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -572,6 +572,32 @@ paths:
572572
application/json:
573573
schema:
574574
$ref: '#/components/schemas/WorkflowErrorDTO'
575+
/workflow/send-notification/streams/{streamId}/consume:
576+
get:
577+
tags:
578+
- SendNotification
579+
operationId: consumeSendStream
580+
description: Start send stream events consume process.
581+
parameters:
582+
- name: streamId
583+
in: path
584+
required: true
585+
description: The id of send stream.
586+
schema:
587+
type: string
588+
responses:
589+
'200':
590+
description: "Consume of stream started"
591+
content:
592+
application/json:
593+
schema:
594+
$ref: '#/components/schemas/WorkflowCreatedDTO'
595+
'500':
596+
description: Server Error
597+
content:
598+
application/json:
599+
schema:
600+
$ref: '#/components/schemas/WorkflowErrorDTO'
575601
/workflow/assessments/receipt/{receiptId}:
576602
post:
577603
tags:
@@ -704,10 +730,10 @@ components:
704730
WorkflowErrorDTO:
705731
type: object
706732
required:
707-
- code
733+
- category
708734
- message
709735
properties:
710-
code:
736+
category:
711737
type: string
712738
enum:
713739
- WORKFLOW_INGESTION_FLOW_FILE_NOT_SUPPORTED

‎src/main/java/it/gov/pagopa/pu/workflow/controller/wf/SendNotificationControllerImpl.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,9 @@ public ResponseEntity<WorkflowCreatedDTO> sendNotificationProcess(String sendNot
2626
}
2727

2828
@Override
29-
public ResponseEntity<WorkflowCreatedDTO> retrieveNotificationDate(String sendNotificationId) {
30-
log.info("Starting notification date retrieve for sendNotificationId: {}", sendNotificationId);
31-
WorkflowCreatedDTO createWorkflowResponseDTO = service.sendNotificationDateRetrieve(sendNotificationId);
29+
public ResponseEntity<WorkflowCreatedDTO> consumeSendStream(String sendStreamId) {
30+
log.info("Starting stream consuming workflow for sendStreamId: {}", sendStreamId);
31+
WorkflowCreatedDTO createWorkflowResponseDTO = service.sendNotificationStreamConsume(sendStreamId);
3232
return new ResponseEntity<>(createWorkflowResponseDTO, HttpStatus.OK);
3333
}
3434

0 commit comments

Comments
 (0)