-
Notifications
You must be signed in to change notification settings - Fork 5
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
ff916ba
commit 91a8999
Showing
3 changed files
with
106 additions
and
108 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
101 changes: 101 additions & 0 deletions
101
...src/main/java/bio/terra/pearl/api/participant/service/file/ParticipantFileExtService.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,101 @@ | ||
| package bio.terra.pearl.api.participant.service.file; | ||
|
|
||
| import bio.terra.pearl.api.participant.service.AuthUtilService; | ||
| import bio.terra.pearl.core.model.EnvironmentName; | ||
| import bio.terra.pearl.core.model.file.ParticipantFile; | ||
| import bio.terra.pearl.core.model.participant.Enrollee; | ||
| import bio.terra.pearl.core.model.participant.ParticipantUser; | ||
| import bio.terra.pearl.core.service.exception.NotFoundException; | ||
| import bio.terra.pearl.core.service.file.ParticipantFileService; | ||
| import bio.terra.pearl.core.service.file.backends.FileStorageBackend; | ||
| import bio.terra.pearl.core.service.file.backends.FileStorageBackendProvider; | ||
| import java.io.IOException; | ||
| import java.io.InputStream; | ||
| import java.util.List; | ||
| import java.util.Set; | ||
| import lombok.extern.slf4j.Slf4j; | ||
| import org.springframework.stereotype.Service; | ||
| import org.springframework.web.multipart.MultipartFile; | ||
|
|
||
| @Service | ||
| @Slf4j | ||
| public class ParticipantFileExtService { | ||
|
|
||
| private final ParticipantFileService participantFileService; | ||
| private final AuthUtilService authUtilService; | ||
| private final FileStorageBackend fileStorageBackend; | ||
|
|
||
| public ParticipantFileExtService( | ||
| ParticipantFileService participantFileService, | ||
| AuthUtilService authUtilService, | ||
| FileStorageBackendProvider fileStorageBackendProvider) { | ||
| this.participantFileService = participantFileService; | ||
| this.authUtilService = authUtilService; | ||
| this.fileStorageBackend = fileStorageBackendProvider.get(); | ||
| } | ||
|
|
||
| public ParticipantFile get( | ||
| ParticipantUser participantUser, String enrolleeShortcode, String fileName) { | ||
| Enrollee enrollee = | ||
| authUtilService.authParticipantUserToEnrollee(participantUser.getId(), enrolleeShortcode); | ||
| return participantFileService | ||
| .findByEnrolleeIdAndFileName(enrollee.getId(), fileName) | ||
| .orElseThrow(() -> new NotFoundException("Could not find file")); | ||
| } | ||
|
|
||
| public InputStream downloadFile( | ||
| ParticipantUser participantUser, String enrolleeShortcode, String fileName) { | ||
| Enrollee enrollee = | ||
| authUtilService.authParticipantUserToEnrollee(participantUser.getId(), enrolleeShortcode); | ||
| ParticipantFile participantFile = | ||
| participantFileService | ||
| .findByEnrolleeIdAndFileName(enrollee.getId(), fileName) | ||
| .orElseThrow(() -> new NotFoundException("Could not find file")); | ||
|
|
||
| return fileStorageBackend.downloadFile(participantFile.getExternalFileId()); | ||
| } | ||
|
|
||
| public ParticipantFile uploadFile( | ||
| ParticipantUser participantUser, String enrolleeShortcode, MultipartFile file) { | ||
| Enrollee enrollee = | ||
| authUtilService.authParticipantUserToEnrollee(participantUser.getId(), enrolleeShortcode); | ||
|
|
||
| try { | ||
| return participantFileService.uploadFileAndCreate( | ||
| ParticipantFile.builder() | ||
| .enrolleeId(enrollee.getId()) | ||
| .fileName(cleanFileName(file.getOriginalFilename())) | ||
| .fileType(file.getContentType()) | ||
| .build(), | ||
| file.getInputStream()); | ||
| } catch (IOException e) { | ||
| throw new RuntimeException("Error uploading file"); | ||
| } | ||
| } | ||
|
|
||
| public List<ParticipantFile> list(ParticipantUser participantUser, String enrolleeShortcode) { | ||
| Enrollee enrollee = | ||
| authUtilService.authParticipantUserToEnrollee(participantUser.getId(), enrolleeShortcode); | ||
| return participantFileService.findByEnrolleeId(enrollee.getId()); | ||
| } | ||
|
|
||
| public String cleanFileName(String fileName) { | ||
| if (fileName == null) { | ||
| return ""; | ||
| } | ||
| String[] split = fileName.split("\\[/\\\\]"); | ||
| return split[split.length - 1]; | ||
| } | ||
|
|
||
| public void delete(ParticipantUser participantUser, String enrolleeShortcode, String fileName) { | ||
| Enrollee enrollee = | ||
| authUtilService.authParticipantUserToEnrollee(participantUser.getId(), enrolleeShortcode); | ||
| ParticipantFile participantFile = | ||
| participantFileService | ||
| .findByEnrolleeIdAndFileName(enrollee.getId(), fileName) | ||
| .orElseThrow(() -> new NotFoundException("Could not find file")); | ||
|
|
||
| participantFileService.delete(participantFile.getId(), Set.of()); | ||
| fileStorageBackend.deleteFile(participantFile.getExternalFileId()); | ||
| } | ||
| } |
100 changes: 0 additions & 100 deletions
100
...in/java/bio/terra/pearl/api/participant/service/fileupload/ParticipantFileExtService.java
This file was deleted.
Oops, something went wrong.