-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feature: Integration with OCI Object Storage temp
task: 8697bjvqr
- Loading branch information
Showing
36 changed files
with
478 additions
and
264 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
26 changes: 26 additions & 0 deletions
26
backend/src/main/java/meowhub/backend/ext/oci/OCIClientConfiguration.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,26 @@ | ||
| package meowhub.backend.ext.oci; | ||
|
|
||
| import com.oracle.bmc.ConfigFileReader; | ||
| import com.oracle.bmc.auth.ConfigFileAuthenticationDetailsProvider; | ||
| import com.oracle.bmc.objectstorage.ObjectStorage; | ||
| import com.oracle.bmc.objectstorage.ObjectStorageClient; | ||
| import org.springframework.context.annotation.Configuration; | ||
|
|
||
| import java.io.IOException; | ||
|
|
||
| @Configuration | ||
| public class OCIClientConfiguration { | ||
| // Path to OCI configs file | ||
| String configurationFilePath = "backend/src/main/resources/config"; | ||
| String profile = "DEFAULT"; | ||
|
|
||
| public ObjectStorage getObjectStorage() throws IOException { | ||
| //load configs file | ||
| final ConfigFileReader.ConfigFile configFile = ConfigFileReader.parse(configurationFilePath, profile); | ||
| final ConfigFileAuthenticationDetailsProvider provider = new ConfigFileAuthenticationDetailsProvider(configFile); | ||
|
|
||
| //build and return client | ||
| return ObjectStorageClient.builder().build(provider); | ||
| } | ||
|
|
||
| } |
42 changes: 42 additions & 0 deletions
42
backend/src/main/java/meowhub/backend/ext/oci/OCIController.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,42 @@ | ||
| package meowhub.backend.ext.oci; | ||
|
|
||
| import jakarta.annotation.security.RolesAllowed; | ||
| import org.springframework.beans.factory.annotation.Autowired; | ||
| import org.springframework.http.ResponseEntity; | ||
| import org.springframework.web.bind.annotation.GetMapping; | ||
| import org.springframework.web.bind.annotation.PathVariable; | ||
| import org.springframework.web.bind.annotation.PostMapping; | ||
| import org.springframework.web.bind.annotation.RequestMapping; | ||
| import org.springframework.web.bind.annotation.RequestParam; | ||
| import org.springframework.web.bind.annotation.RestController; | ||
| import org.springframework.web.multipart.MultipartFile; | ||
|
|
||
| @RestController | ||
| @RequestMapping("api/ext") | ||
| @Deprecated(since = "only to test connection with OCI Object Storage. Otherwise - don't use!!!", forRemoval = true) | ||
| @RolesAllowed("ROLE_ADMIN") | ||
| public class OCIController { | ||
| private static final String urlPrefix = "https://objectstorage.eu-frankfurt-1.oraclecloud.com"; | ||
|
|
||
| @Autowired | ||
| private OCIUploadService ociUploadService; | ||
|
|
||
| @PostMapping(path = "upload") | ||
| public ResponseEntity<Object> uploadFile(@RequestParam("file") MultipartFile file){ | ||
| try { | ||
| ociUploadService.upload(file, "TEST/"+file.getOriginalFilename()); | ||
| return ResponseEntity.ok().body("Uploaded File : "+file.getOriginalFilename()); | ||
| } catch (Exception e) { | ||
| return ResponseEntity.internalServerError().body(e.getMessage()); | ||
| } | ||
| } | ||
|
|
||
| @GetMapping(path = "file/{fileName}") | ||
| public ResponseEntity<Object> getURl(@PathVariable(value = "fileName") String fileName){ | ||
| try { | ||
| return ResponseEntity.ok().body(ociUploadService.getFileObjectUrl(fileName)); | ||
| } catch (Exception e) { | ||
| return ResponseEntity.internalServerError().body(e.getMessage()); | ||
| } | ||
| } | ||
| } |
84 changes: 84 additions & 0 deletions
84
backend/src/main/java/meowhub/backend/ext/oci/OCIUploadService.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,84 @@ | ||
| package meowhub.backend.ext.oci; | ||
|
|
||
| import com.oracle.bmc.objectstorage.model.CreatePreauthenticatedRequestDetails; | ||
| import com.oracle.bmc.objectstorage.model.PreauthenticatedRequest.BucketListingAction; | ||
| import com.oracle.bmc.objectstorage.requests.CreatePreauthenticatedRequestRequest; | ||
| import com.oracle.bmc.objectstorage.requests.PutObjectRequest; | ||
| import com.oracle.bmc.objectstorage.responses.CreatePreauthenticatedRequestResponse; | ||
| import org.springframework.beans.factory.annotation.Autowired; | ||
| import org.springframework.beans.factory.annotation.Value; | ||
| import org.springframework.stereotype.Service; | ||
| import org.springframework.web.multipart.MultipartFile; | ||
|
|
||
| import java.io.InputStream; | ||
| import java.time.Instant; | ||
| import java.time.OffsetDateTime; | ||
| import java.util.Date; | ||
| import java.util.UUID; | ||
|
|
||
| @Service | ||
| public class OCIUploadService { | ||
| private static final String urlPrefix = "https://objectstorage.eu-frankfurt-1.oraclecloud.com"; | ||
|
|
||
| @Value("${oci.objectstorage.bucket-name}") | ||
| private String bucketName; | ||
|
|
||
| @Value("${oci.objectstorage.namespaceName}") | ||
| private String namespaceName; | ||
|
|
||
| @Autowired | ||
| private OCIClientConfiguration configuration; | ||
|
|
||
| public void upload(MultipartFile file, String objectName) throws Exception { | ||
| InputStream inputStream = file.getInputStream(); | ||
|
|
||
| //build upload request | ||
| PutObjectRequest putObjectRequest = | ||
| PutObjectRequest.builder() | ||
| .namespaceName(namespaceName) | ||
| .bucketName(bucketName) | ||
| .objectName(objectName) | ||
| .contentLength(file.getSize()) | ||
| .putObjectBody(inputStream) | ||
| .build(); | ||
|
|
||
| //upload the file | ||
| try { | ||
| configuration.getObjectStorage().putObject(putObjectRequest); | ||
| } catch (Exception e) { | ||
| e.printStackTrace(); | ||
| throw e; | ||
| }finally{ | ||
| configuration.getObjectStorage().close(); | ||
| } | ||
| } | ||
|
|
||
| public String getFileObjectUrl(String objectName) throws Exception{ | ||
| OffsetDateTime expirationTime = OffsetDateTime.now().plusYears(10); | ||
|
|
||
| // Build request details | ||
| CreatePreauthenticatedRequestDetails createPreauthenticatedRequestDetails = CreatePreauthenticatedRequestDetails.builder() | ||
| .name("OCI_Request") | ||
| .bucketListingAction(BucketListingAction.Deny) | ||
| .objectName(objectName) | ||
| //readonly access | ||
| .accessType(CreatePreauthenticatedRequestDetails.AccessType.ObjectRead) | ||
| //here we set expiration time for | ||
| .timeExpires(Date.from(expirationTime.toInstant())).build(); | ||
|
|
||
| //Build request | ||
| CreatePreauthenticatedRequestRequest createPreauthenticatedRequestRequest = CreatePreauthenticatedRequestRequest.builder() | ||
| .namespaceName(namespaceName) | ||
| .bucketName(bucketName) | ||
| .createPreauthenticatedRequestDetails(createPreauthenticatedRequestDetails) | ||
| .opcClientRequestId(UUID.randomUUID().toString()).build(); | ||
|
|
||
| // send request to oci | ||
| CreatePreauthenticatedRequestResponse response = configuration.getObjectStorage().createPreauthenticatedRequest(createPreauthenticatedRequestRequest); | ||
| configuration.getObjectStorage().close(); | ||
|
|
||
| String accessUri = response.getPreauthenticatedRequest().getAccessUri(); | ||
|
|
||
| return urlPrefix + accessUri; | ||
| } | ||
| } |
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
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
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
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
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
Oops, something went wrong.