Skip to content

Commit a223fab

Browse files
committed
fix: Fix Temporal traceId occasionally empty
1 parent 85b3a07 commit a223fab

12 files changed

+36
-0
lines changed

src/test/java/it/gov/pagopa/pu/workflow/controller/ScheduleControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.pu.workflow.dto.generated.ScheduleInfoDTO;
45
import it.gov.pagopa.pu.workflow.enums.ScheduleEnum;
56
import it.gov.pagopa.pu.workflow.service.temporal.WorkflowScheduleService;
@@ -29,6 +30,8 @@ class ScheduleControllerTest {
2930

3031
@MockitoBean
3132
private WorkflowScheduleService serviceMock;
33+
@MockitoBean
34+
private Tracer tracerMock;
3235

3336
@Test
3437
void whenGetScheduleInfoThenOk() throws Exception {

src/test/java/it/gov/pagopa/pu/workflow/controller/WorkflowControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller;
22

3+
import io.micrometer.tracing.Tracer;
34
import io.temporal.api.enums.v1.WorkflowExecutionStatus;
45
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowStatusDTO;
56
import it.gov.pagopa.pu.workflow.service.temporal.WorkflowCompletionService;
@@ -30,6 +31,8 @@ class WorkflowControllerTest {
3031

3132
@MockitoBean
3233
private WorkflowService serviceMock;
34+
@MockitoBean
35+
private Tracer tracerMock;
3336

3437
@MockitoBean
3538
private WorkflowCompletionService workflowCompletionServiceMock;

src/test/java/it/gov/pagopa/pu/workflow/controller/WorkflowTypeOrgControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.payhub.activities.dto.debtposition.syncwfconfig.FineWfExecutionConfig;
45
import it.gov.pagopa.pu.workflow.model.WorkflowTypeOrg;
56
import it.gov.pagopa.pu.workflow.service.WorkflowTypeOrgSaveService;
@@ -26,6 +27,8 @@ class WorkflowTypeOrgControllerTest {
2627
private MockMvc mockMvc;
2728
@Autowired
2829
private JsonMapper jsonMapper;
30+
@MockitoBean
31+
private Tracer tracerMock;
2932

3033
@MockitoBean
3134
private WorkflowTypeOrgSaveService serviceMock;

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/AssessmentsControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowCreatedDTO;
45
import it.gov.pagopa.pu.workflow.utilities.SecurityUtils;
56
import it.gov.pagopa.pu.workflow.wf.assessments.CreateAssessmentsWFClient;
@@ -28,6 +29,8 @@ class AssessmentsControllerTest {
2829

2930
@Autowired
3031
private JsonMapper jsonMapper;
32+
@MockitoBean
33+
private Tracer tracerMock;
3134

3235
@MockitoBean
3336
private CreateAssessmentsWFClient createAssessmentsWFClientMock;

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/ClassificationControllerImplTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowCreatedDTO;
45
import it.gov.pagopa.pu.workflow.wf.classification.assessments.ClassifyAssessmentsWFClient;
56
import it.gov.pagopa.pu.workflow.wf.classification.assessments.dto.ClassifyAssessmentStartSignalDTO;
@@ -47,6 +48,8 @@ class ClassificationControllerImplTest {
4748

4849
@MockitoBean
4950
private IudClassificationWFClient iudClassificationWFClientMock;
51+
@MockitoBean
52+
private Tracer tracerMock;
5053

5154
@Test
5255
void givenIdWhenClassifyThenCreateTransferClassificationWFSuccessfully() throws Exception {

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/DebtPositionControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

33
import com.fasterxml.jackson.databind.ObjectMapper;
4+
import io.micrometer.tracing.Tracer;
45
import it.gov.pagopa.payhub.activities.connector.workflowhub.dto.WfExecutionParameters;
56
import it.gov.pagopa.payhub.activities.dto.IONotificationMessage;
67
import it.gov.pagopa.payhub.activities.dto.debtposition.syncwfconfig.GenericWfExecutionConfig;
@@ -42,6 +43,8 @@ class DebtPositionControllerTest {
4243

4344
@MockitoBean
4445
private DebtPositionService serviceMock;
46+
@MockitoBean
47+
private Tracer tracerMock;
4548

4649
@Test
4750
void whenSyncDebtPositionThenOk() throws Exception {

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/DebtPositionFineControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

33
import com.fasterxml.jackson.databind.ObjectMapper;
4+
import io.micrometer.tracing.Tracer;
45
import it.gov.pagopa.pu.workflow.config.json.JsonConfig;
56
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowCreatedDTO;
67
import it.gov.pagopa.pu.workflow.service.wf.debtposition.custom.fine.DebtPositionFineService;
@@ -32,6 +33,8 @@ class DebtPositionFineControllerTest {
3233

3334
@MockitoBean
3435
private DebtPositionFineService serviceMock;
36+
@MockitoBean
37+
private Tracer tracerMock;
3538

3639
@Test
3740
void whenHandleFineReductionExpirationThenOk() throws Exception {

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/ExportFileControllerImplTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.pu.processexecutions.dto.generated.ExportFile;
45
import it.gov.pagopa.pu.processexecutions.dto.generated.ExportFile.ExportFileTypeEnum;
56
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowCreatedDTO;
@@ -31,6 +32,8 @@ class ExportFileControllerImplTest {
3132
private JsonMapper jsonMapper;
3233
@MockitoBean
3334
private ExportFileService serviceMock;
35+
@MockitoBean
36+
private Tracer tracerMock;
3437

3538
@Test
3639
void givenExportFileIdWhenExpireExportFileThenOk() throws Exception {

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/IngestionFlowControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.pu.processexecutions.dto.generated.IngestionFlowFile;
45
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowCreatedDTO;
56
import it.gov.pagopa.pu.workflow.service.wf.ingestionflowfile.IngestionFlowFileStarterService;
@@ -32,6 +33,8 @@ class IngestionFlowControllerTest {
3233

3334
@MockitoBean
3435
private IngestionFlowFileStarterService serviceMock;
36+
@MockitoBean
37+
private Tracer tracerMock;
3538

3639
@MockitoBean
3740
private TreasuryOpiIngestionWFClient treasuryOpiIngestionWFClientMock;

src/test/java/it/gov/pagopa/pu/workflow/controller/wf/PagoPaFetchControllerTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package it.gov.pagopa.pu.workflow.controller.wf;
22

3+
import io.micrometer.tracing.Tracer;
34
import it.gov.pagopa.pu.workflow.dto.generated.WorkflowCreatedDTO;
45
import it.gov.pagopa.pu.workflow.wf.pagopa.paymentsreporting.OrganizationPaymentsReportingPagoPaFetchWFClient;
56
import org.junit.jupiter.api.Test;
@@ -23,6 +24,8 @@ class PagoPaFetchControllerTest {
2324

2425
@MockitoBean
2526
private OrganizationPaymentsReportingPagoPaFetchWFClient serviceMock;
27+
@MockitoBean
28+
private Tracer tracerMock;
2629

2730
@Test
2831
void whenFetchOrganizationPaymentsReportingThenOk() throws Exception {

0 commit comments

Comments
 (0)