Feature/1442 move duplicate s3 logic to client libs

digiwf-engine/digiwf-engine-service/src/main/java/de/muenchen/oss/digiwf/legacy/dms/muc/domain/model/Vorgang.java

@@ -41,6 +41,7 @@ public class Vorgang {
      * Art des Vortgangs.
      * Default ist ELEKTRONISCH
      */
+    @Builder.Default
     private VorgangArt art = VorgangArt.ELEKTRONISCH;
 
     public Vorgang(final NeuerVorgang neuerVorgang, final String coo) {

digiwf-engine/digiwf-engine-service/src/main/java/de/muenchen/oss/digiwf/process/config/domain/model/ProcessConfig.java

@@ -36,6 +36,7 @@ public class ProcessConfig {
      * Example: "[email protected],[email protected]"
      */
     public static final String INCIDENT_NOTIFICATION_ADDRESSES = "app_incident_notification_addresses";
+    public static final String APP_FILE_S3_SYNC_CONFIG = "app_file_s3_sync_config";
 
     /**
      * key of the process config.

digiwf-engine/digiwf-engine-service/src/main/java/de/muenchen/oss/digiwf/process/definition/api/resource/ServiceStartFileRestController.java

@@ -5,6 +5,7 @@
 package de.muenchen.oss.digiwf.process.definition.api.resource;
 
 import de.muenchen.oss.digiwf.process.definition.domain.service.ServiceStartFileService;
+import de.muenchen.oss.digiwf.s3.integration.client.exception.PropertyNotSetException;
 import de.muenchen.oss.digiwf.shared.file.presignedUrlAdapters.PresignedUrlAction;
 import de.muenchen.oss.digiwf.shared.security.AppAuthenticationProvider;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -39,12 +40,12 @@
      * @return file names
      */
     @GetMapping("/{definitionKey}")
-    public ResponseEntity<List<String>> getFileNames(@PathVariable final String definitionKey, @RequestParam final String filePath) {
+    public ResponseEntity<List<String>> getFileNames(@PathVariable final String definitionKey, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final List<String> fileNames = this.serviceStartFileService.getFileNames(
                 definitionKey,
                 filePath,
-                this.authenticationProvider.getCurrentUserId(),
-                this.authenticationProvider.getCurrentUserGroups());
+                this.authenticationProvider.getCurrentUserId());
         return ResponseEntity.ok(fileNames);
     }
 
@@ -57,14 +58,14 @@
      * @return presignedUrl
      */
     @GetMapping("/{definitionKey}/{fileName}")
-    public ResponseEntity<String> getPresignedUrlForFileDownload(@PathVariable final String definitionKey, @PathVariable final String fileName, @RequestParam final String filePath) {
+    public ResponseEntity<String> getPresignedUrlForFileDownload(@PathVariable final String definitionKey, @PathVariable final String fileName, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final String presignedUrl = this.serviceStartFileService.getPresignedUrl(
                 PresignedUrlAction.GET,
                 definitionKey,
                 filePath,
                 fileName,
-                this.authenticationProvider.getCurrentUserId(),
-                this.authenticationProvider.getCurrentUserGroups());
+                this.authenticationProvider.getCurrentUserId());
         return ResponseEntity.ok(presignedUrl);
     }
 
@@ -77,14 +78,14 @@
      * @return presignedUrl
      */
     @PostMapping("/{definitionKey}/{filename}")
-    public ResponseEntity<String> getPresignedUrlForFileUpload(@PathVariable final String definitionKey, @PathVariable final String filename, @RequestParam final String filePath) {
+    public ResponseEntity<String> getPresignedUrlForFileUpload(@PathVariable final String definitionKey, @PathVariable final String filename, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final String presignedUrls = this.serviceStartFileService.getPresignedUrl(
                 PresignedUrlAction.POST,
                 definitionKey,
                 filePath,
                 filename,
-                this.authenticationProvider.getCurrentUserId(),
-                this.authenticationProvider.getCurrentUserGroups());
+                this.authenticationProvider.getCurrentUserId());
         return ResponseEntity.ok(presignedUrls);
     }
 
@@ -98,14 +99,14 @@
      */
     //TODO I guess this should be only one url?
     @DeleteMapping("/{definitionKey}/{filename}")
-    public ResponseEntity<String> getPresignedUrlForFileDeletion(@PathVariable final String definitionKey, @PathVariable final String filename, @RequestParam final String filePath) {
+    public ResponseEntity<String> getPresignedUrlForFileDeletion(@PathVariable final String definitionKey, @PathVariable final String filename, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final String presignedUrl = this.serviceStartFileService.getPresignedUrl(
                 PresignedUrlAction.DELETE,
                 definitionKey,
                 filePath,
                 filename,
-                this.authenticationProvider.getCurrentUserId(),
-                this.authenticationProvider.getCurrentUserGroups());
+                this.authenticationProvider.getCurrentUserId());
         return ResponseEntity.ok(presignedUrl);
     }
 

digiwf-engine/digiwf-engine-service/src/main/java/de/muenchen/oss/digiwf/process/definition/domain/service/ServiceStartFileService.java

@@ -6,9 +6,10 @@
 
 import de.muenchen.oss.digiwf.process.config.domain.model.ProcessConfig;
 import de.muenchen.oss.digiwf.process.config.domain.service.ProcessConfigService;
-import de.muenchen.oss.digiwf.process.config.process.ProcessConfigFunctions;
 import de.muenchen.oss.digiwf.process.definition.domain.model.StartContext;
+import de.muenchen.oss.digiwf.s3.integration.client.exception.PropertyNotSetException;
 import de.muenchen.oss.digiwf.s3.integration.client.repository.DocumentStorageFolderRepository;
+import de.muenchen.oss.digiwf.s3.integration.client.service.S3StorageUrlProvider;
 import de.muenchen.oss.digiwf.shared.exception.IllegalResourceAccessException;
 import de.muenchen.oss.digiwf.shared.exception.NoFileContextException;
 import de.muenchen.oss.digiwf.shared.file.AbstractFileService;
@@ -34,34 +35,38 @@
 
     private final ServiceStartContextService serviceStartContextService;
     private final ProcessConfigService processConfigService;
+    private final S3StorageUrlProvider s3StorageUrlProvider;
 
     public ServiceStartFileService(
             final DocumentStorageFolderRepository documentStorageFolderRepository,
             final ServiceStartContextService serviceStartContextService,
             final ProcessConfigService processConfigService,
             final List<PresignedUrlAdapter> presignedUrlAdapters,
-            final ProcessConfigFunctions processConfigFunctions
+            final S3StorageUrlProvider s3StorageUrlProvider
     ) {
-        super(documentStorageFolderRepository, presignedUrlAdapters, processConfigFunctions);
+        super(documentStorageFolderRepository, presignedUrlAdapters);
         this.serviceStartContextService = serviceStartContextService;
         this.processConfigService = processConfigService;
+        this.s3StorageUrlProvider = s3StorageUrlProvider;
     }
 
-    public List<String> getFileNames(final String definitionKey, final String filePath, final String userId, final List<String> groups) {
+    @Override
+    public List<String> getFileNames(final String definitionKey, final String filePath, final String userId) throws PropertyNotSetException {
         this.checkReadAccess(definitionKey, filePath);
         final String fileContext = this.getFileContext(userId, definitionKey);
-        return super.getFileNames(filePath, fileContext, this.getDocumentStorageUrl(definitionKey));
+        return super.getFileNames(filePath, fileContext, this.s3StorageUrlProvider.provideS3StorageUrl(definitionKey));
     }
 
-    public String getPresignedUrl(final PresignedUrlAction action, final String definitionKey, final String filePath, final String fileName, final String userId, final List<String> groups) {
+    public String getPresignedUrl(final PresignedUrlAction action, final String definitionKey, final String filePath, final String fileName,
+            final String userId) throws PropertyNotSetException {
         if (action.equals(PresignedUrlAction.GET)) {
             this.checkReadAccess(definitionKey, filePath);
         } else {
             this.checkWriteAccess(definitionKey, filePath);
         }
 
         final String fileContext = this.getFileContext(userId, definitionKey);
-        return super.getPresignedUrl(action, fileContext + "/" + filePath + "/" + fileName, this.getDocumentStorageUrl(definitionKey));
+        return super.getPresignedUrl(action, fileContext + "/" + filePath + "/" + fileName, this.s3StorageUrlProvider.provideS3StorageUrl(definitionKey));
     }
 
     //---------------------------------------- helper methods ---------------------------------------- //

digiwf-engine/digiwf-engine-service/src/main/java/de/muenchen/oss/digiwf/process/instance/api/resource/ServiceInstanceFileRestController.java

@@ -5,6 +5,7 @@
 package de.muenchen.oss.digiwf.process.instance.api.resource;
 
 import de.muenchen.oss.digiwf.process.instance.domain.service.ServiceInstanceFileService;
+import de.muenchen.oss.digiwf.s3.integration.client.exception.PropertyNotSetException;
 import de.muenchen.oss.digiwf.shared.file.presignedUrlAdapters.PresignedUrlAction;
 import de.muenchen.oss.digiwf.shared.security.AppAuthenticationProvider;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -39,7 +40,8 @@ public class ServiceInstanceFileRestController {
      * @return file names
      */
     @GetMapping("/{instanceId}")
-    public ResponseEntity<List<String>> getFileNames(@PathVariable final String instanceId, @RequestParam final String filePath) {
+    public ResponseEntity<List<String>> getFileNames(@PathVariable final String instanceId, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final List<String> fileNames = this.serviceInstanceFileService.getFileNames(
                 instanceId,
                 filePath,
@@ -56,7 +58,8 @@ public ResponseEntity<List<String>> getFileNames(@PathVariable final String inst
      * @return presignedUrl
      */
     @GetMapping("/{instanceId}/{fileName}")
-    public ResponseEntity<String> getPresignedUrlForFileDownload(@PathVariable final String instanceId, @PathVariable final String fileName, @RequestParam final String filePath) {
+    public ResponseEntity<String> getPresignedUrlForFileDownload(@PathVariable final String instanceId, @PathVariable final String fileName, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final String presignedUrl = this.serviceInstanceFileService.getPresignedUrl(
                 PresignedUrlAction.GET,
                 instanceId,
@@ -75,7 +78,8 @@ public ResponseEntity<String> getPresignedUrlForFileDownload(@PathVariable final
      * @return presignedUrl
      */
     @PostMapping("/{instanceId}/{filename}")
-    public ResponseEntity<String> getPresignedUrlForFileUpload(@PathVariable final String instanceId, @PathVariable final String filename, @RequestParam final String filePath) {
+    public ResponseEntity<String> getPresignedUrlForFileUpload(@PathVariable final String instanceId, @PathVariable final String filename, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final String presignedUrls = this.serviceInstanceFileService.getPresignedUrl(
                 PresignedUrlAction.POST,
                 instanceId,
@@ -94,7 +98,8 @@ public ResponseEntity<String> getPresignedUrlForFileUpload(@PathVariable final S
      * @return presignedUrl
      */
     @DeleteMapping("/{instanceId}/{filename}")
-    public ResponseEntity<String> getPresignedUrlForFileDeletion(@PathVariable final String instanceId, @PathVariable final String filename, @RequestParam final String filePath) {
+    public ResponseEntity<String> getPresignedUrlForFileDeletion(@PathVariable final String instanceId, @PathVariable final String filename, @RequestParam final String filePath)
+            throws PropertyNotSetException {
         final String presignedUrl = this.serviceInstanceFileService.getPresignedUrl(
                 PresignedUrlAction.DELETE,
                 instanceId,

digiwf-engine/digiwf-engine-service/src/main/java/de/muenchen/oss/digiwf/process/instance/domain/service/ServiceInstanceFileService.java

@@ -8,7 +8,9 @@
 import de.muenchen.oss.digiwf.process.config.domain.service.ProcessConfigService;
 import de.muenchen.oss.digiwf.process.config.process.ProcessConfigFunctions;
 import de.muenchen.oss.digiwf.process.instance.domain.model.ServiceInstance;
+import de.muenchen.oss.digiwf.s3.integration.client.exception.PropertyNotSetException;
 import de.muenchen.oss.digiwf.s3.integration.client.repository.DocumentStorageFolderRepository;
+import de.muenchen.oss.digiwf.s3.integration.client.service.S3StorageUrlProvider;
 import de.muenchen.oss.digiwf.shared.exception.IllegalResourceAccessException;
 import de.muenchen.oss.digiwf.shared.file.AbstractFileService;
 import de.muenchen.oss.digiwf.shared.file.presignedUrlAdapters.PresignedUrlAction;
@@ -34,6 +36,7 @@
     private final ServiceInstanceService serviceInstanceService;
     private final ServiceInstanceDataService serviceInstanceDataService;
     private final ServiceInstanceAuthService serviceInstanceAuthService;
+    private final S3StorageUrlProvider s3StorageUrlProvider;
 
     public ServiceInstanceFileService(
             final DocumentStorageFolderRepository documentStorageFolderRepository,
@@ -42,16 +45,17 @@
             final ServiceInstanceDataService serviceInstanceDataService,
             final ServiceInstanceAuthService serviceInstanceAuthService,
             final ProcessConfigService processConfigService,
-            final ProcessConfigFunctions processConfigFunctions
+            final S3StorageUrlProvider s3StorageUrlProvider
     ) {
-        super(documentStorageFolderRepository, presignedUrlAdapters, processConfigFunctions);
+        super(documentStorageFolderRepository, presignedUrlAdapters);
         this.serviceInstanceService = serviceInstanceService;
         this.processConfigService = processConfigService;
         this.serviceInstanceDataService = serviceInstanceDataService;
         this.serviceInstanceAuthService = serviceInstanceAuthService;
+        this.s3StorageUrlProvider = s3StorageUrlProvider;
     }
 
-    public List<String> getFileNames(final String infoId, final String filePath, final String userId) {
+    public List<String> getFileNames(final String infoId, final String filePath, final String userId) throws PropertyNotSetException {
         final ServiceInstance processInstance = this.getProcessInstanceId(infoId);
         final String processInstanceId = processInstance.getInstanceId();
         if (!this.serviceInstanceAuthService.hasAccess(processInstanceId, userId)) {
@@ -60,10 +64,11 @@
 
         this.checkReadAccess(processInstanceId, filePath);
         final String fileContext = this.getFileContext(processInstanceId);
-        return super.getFileNames(filePath, fileContext, this.getDocumentStorageUrl(processInstance.getDefinitionKey()));
+        return super.getFileNames(filePath, fileContext, s3StorageUrlProvider.provideS3StorageUrl(processInstance.getDefinitionKey()));
     }
 
-    public String getPresignedUrl(final PresignedUrlAction action, final String infoId, final String filePath, final String fileName, final String userId) {
+    public String getPresignedUrl(final PresignedUrlAction action, final String infoId, final String filePath, final String fileName, final String userId)
+            throws PropertyNotSetException {
         final ServiceInstance processInstance = this.getProcessInstanceId(infoId);
         final String processInstanceId = processInstance.getInstanceId();
         if (!this.serviceInstanceAuthService.hasAccess(processInstanceId, userId)) {
@@ -77,7 +82,7 @@
         }
 
         final String fileContext = this.getFileContext(processInstanceId);
-        return super.getPresignedUrl(action, fileContext + "/" + filePath + "/" + fileName, this.getDocumentStorageUrl(processInstance.getDefinitionKey()));
+        return super.getPresignedUrl(action, fileContext + "/" + filePath + "/" + fileName, this.s3StorageUrlProvider.provideS3StorageUrl(processInstance.getDefinitionKey()));
     }
 
     //---------------------------------------- helper methods ---------------------------------------- //