fix: implement copyObject and moveObject in MinIOConnector.java

Panzer1119 · Aug 3, 2021 · 68a39b1 · 68a39b1
1 parent 1ed9fbe
commit 68a39b1
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/src/main/java/de/codemakers/database/connectors/MinIOConnector.java b/src/main/java/de/codemakers/database/connectors/MinIOConnector.java
@@ -100,14 +100,26 @@ public boolean removeObject(String bucket, String object) {
     public boolean copyObject(String srcBucket, String srcObject, String destBucket, String destObject) {
         checkParameter(srcBucket, srcObject);
         checkParameter(destBucket, destObject);
-        return false;
+        try {
+            return connector.copyObject(CopyObjectArgs.builder()
+                    .source(CopySource.builder().bucket(srcBucket).object(srcObject).build())
+                    .bucket(destBucket)
+                    .object(destObject)
+                    .build()) != null;
+        } catch (ErrorResponseException | InsufficientDataException | InternalException | InvalidKeyException | InvalidResponseException | IOException | NoSuchAlgorithmException | ServerException | XmlParserException e) {
+            logger.error(String.format("Error while copying \"%s\" from \"%s\" to \"%s\" as \"%s\"", srcObject, srcBucket, destBucket, destObject), e);
+            return false;
+        }
     }
 
     @Override
     public boolean moveObject(String srcBucket, String srcObject, String destBucket, String destObject) {
         checkParameter(srcBucket, srcObject);
         checkParameter(destBucket, destObject);
-        return false;
+        if (!copyObject(srcBucket, srcObject, destBucket, destObject)) {
+            return false;
+        }
+        return removeObject(srcBucket, srcObject);
     }
 
 }