adding sessions

pagopa · Feb 8, 2024 · fcabc6a · fcabc6a
1 parent 734f0e7
commit fcabc6a
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 0 deletions.
diff --git a/src/main/java/it/gov/pagopa/atmlayer/service/model/service/impl/BpmnBankConfigService.java b/src/main/java/it/gov/pagopa/atmlayer/service/model/service/impl/BpmnBankConfigService.java
@@ -31,10 +31,12 @@ public Uni<Void> saveList(List<BpmnBankConfig> bpmnBankConfigs) {
         return bankConfigRepository.persist(bpmnBankConfigs);
     }
 
+    @WithSession
     public Uni<List<BpmnBankConfig>> findByAcquirerIdAndFunctionType(String acquirerId, String functionType) {
         return this.bankConfigRepository.findByAcquirerIdAndFunctionType(acquirerId, functionType);
     }
 
+    @WithSession
     public Uni<List<BpmnBankConfig>> findByBpmnVersionPK(BpmnVersionPK bpmnVersionPK) {
         return this.bankConfigRepository.findByBpmnPK(bpmnVersionPK);
     }
@@ -49,6 +51,7 @@ public Uni<Long> deleteByAcquirerIdAndFunctionType(String acquirerId, String fun
         return this.bankConfigRepository.deleteByAcquirerIdAndFunctionType(acquirerId, functionType);
     }
 
+    @WithSession
     public Uni<Optional<BpmnBankConfig>> findByConfigurationsAndFunction(String acquirerId, String branchId, String terminalId, String functionType) {
         return this.bankConfigRepository.findByConfigAndFunctionType(acquirerId, branchId, terminalId, functionType)
                 .onItem().transformToUni(Unchecked.function(x -> {
@@ -59,6 +62,7 @@ public Uni<Optional<BpmnBankConfig>> findByConfigurationsAndFunction(String acqu
                 }));
     }
 
+    @WithSession
     public Uni<List<BpmnBankConfigDTO>> findByAcquirerId(String acquirerId) {
         return bankConfigRepository.findByAcquirerId(acquirerId)
                 .onItem()

diff --git a/src/main/java/it/gov/pagopa/atmlayer/service/model/service/impl/BpmnVersionServiceImpl.java b/src/main/java/it/gov/pagopa/atmlayer/service/model/service/impl/BpmnVersionServiceImpl.java
@@ -68,11 +68,13 @@ public class BpmnVersionServiceImpl implements BpmnVersionService {
     static final DeployableResourceType resourceType = DeployableResourceType.BPMN;
 
     @Override
+    @WithSession
     public Uni<List<BpmnVersion>> getAll() {
         return this.bpmnVersionRepository.findAll().list();
     }
 
     @Override
+    @WithSession
     public Uni<List<BpmnVersion>> findByPKSet(Set<BpmnVersionPK> bpmnVersionPKSet) {
         return this.bpmnVersionRepository.findByIds(bpmnVersionPKSet);
     }
@@ -352,6 +354,7 @@ public Uni<BpmnVersion> setDeployInfo(BpmnVersionPK key, DeployResponseDto respo
                 }));
     }
 
+    @WithSession
     public Uni<BpmnVersion> getLatestVersion(UUID uuid, String functionType) {
         return this.bpmnVersionRepository.findByIdAndFunction(uuid, functionType)
                 .onItem()

diff --git a/...ain/java/it/gov/pagopa/atmlayer/service/model/service/impl/ResourceEntityServiceImpl.java b/...ain/java/it/gov/pagopa/atmlayer/service/model/service/impl/ResourceEntityServiceImpl.java
@@ -171,6 +171,7 @@ public Uni<ResourceEntity> updateResource(UUID uuid, File file) {
     }
 
     @Override
+    @WithSession
     public Uni<PageInfo<ResourceEntity>> findResourceFiltered(int pageIndex, int pageSize, UUID resourceId, String sha256, NoDeployableResourceType noDeployableResourceType, String fileName, String storageKey, String extension) {
         Map<String, Object> filters = new HashMap<>();
         filters.put("resourceId", resourceId);

diff --git a/...n/java/it/gov/pagopa/atmlayer/service/model/service/impl/WorkflowResourceServiceImpl.java b/...n/java/it/gov/pagopa/atmlayer/service/model/service/impl/WorkflowResourceServiceImpl.java
@@ -290,6 +290,7 @@ public Uni<Boolean> delete(UUID uuid) {
     }
 
     @Override
+    @WithSession
     public Uni<List<WorkflowResource>> getAll() {
         return this.workflowResourceRepository.findAll().list();
     }