Added authorized upload/download

Author: gkatzioura

GoogleStorageWagon/src/main/java/com/gkatzioura/maven/cloud/gcs/wagon/StorageFactory.java renamed to GoogleStorageWagon/src/main/java/com/gkatzioura/maven/cloud/gcs/StorageFactory.java

@@ -1,4 +1,4 @@
-package com.gkatzioura.maven.cloud.gcs.wagon;
+package com.gkatzioura.maven.cloud.gcs;
 
 import java.io.File;
 import java.io.FileInputStream;
@@ -11,11 +11,11 @@
 import com.google.cloud.storage.Storage;
 import com.google.cloud.storage.StorageOptions;
 
-class StorageFactory {
+public class StorageFactory {
 
     private static final Logger LOGGER = Logger.getLogger(StorageFactory.class.getName());
 
-    Storage createWithKeyFile(String keyPath) throws IOException {
+    public Storage createWithKeyFile(String keyPath) throws IOException {
         File credentialsPath = new File(keyPath);
         try(FileInputStream serviceAccountStream = new FileInputStream(credentialsPath)) {
             GoogleCredentials googleCredentials = ServiceAccountCredentials.fromStream(serviceAccountStream);
@@ -26,7 +26,7 @@ Storage createWithKeyFile(String keyPath) throws IOException {
         }
     }
 
-    Storage createDefault() {
+    public Storage createDefault() {
         return StorageOptions.getDefaultInstance().getService();
     }
 }

GoogleStorageWagon/src/main/java/com/gkatzioura/maven/cloud/gcs/plugin/download/GCSDownloadMojo.java

@@ -1,6 +1,7 @@
 package com.gkatzioura.maven.cloud.gcs.plugin.download;
 
 import java.io.File;
+import java.io.IOException;
 import java.util.Iterator;
 import java.util.List;
 import java.util.logging.Level;
@@ -14,11 +15,11 @@
 import org.apache.maven.plugins.annotations.Parameter;
 
 import com.gkatzioura.maven.cloud.KeyIteratorConcated;
+import com.gkatzioura.maven.cloud.gcs.StorageFactory;
 import com.gkatzioura.maven.cloud.gcs.plugin.PrefixKeysIterator;
 import com.google.cloud.storage.Blob;
 import com.google.cloud.storage.BlobId;
 import com.google.cloud.storage.Storage;
-import com.google.cloud.storage.StorageOptions;
 
 @Mojo(name = "gcs-download")
 public class GCSDownloadMojo extends AbstractMojo {
@@ -32,7 +33,11 @@ public class GCSDownloadMojo extends AbstractMojo {
     @Parameter(property = "gcs-download.downloadPath")
     private String downloadPath;
 
-    private Storage storage = StorageOptions.getDefaultInstance().getService();
+    @Parameter(property = "gcs-download.keyPath")
+    private String keyPath;
+
+    private final StorageFactory storageFactory = new StorageFactory();
+    private Storage storage;
 
     private static final Logger LOGGER = Logger.getLogger(GCSDownloadMojo.class.getName());
 
@@ -47,6 +52,8 @@ public GCSDownloadMojo(String bucket, List<String> keys, String downloadPath) th
 
     @Override
     public void execute() throws MojoExecutionException, MojoFailureException {
+        storage = initializeStorage();
+
         if (keys.size()==1) {
             downloadSingleFile(storage,keys.get(0));
             return;
@@ -65,6 +72,18 @@ public void execute() throws MojoExecutionException, MojoFailureException {
         }
     }
 
+    private Storage initializeStorage() throws MojoExecutionException {
+        if(keyPath==null) {
+            return storageFactory.createDefault();
+        } else {
+            try {
+                return storageFactory.createWithKeyFile(keyPath);
+            } catch (IOException e) {
+                throw new MojoExecutionException("Failed to set Authentication to Google Cloud");
+            }
+        }
+    }
+
     private void downloadSingleFile(Storage storage,String key) {
         File file = new File(downloadPath);
 

GoogleStorageWagon/src/main/java/com/gkatzioura/maven/cloud/gcs/plugin/upload/GCSUploadMojo.java

@@ -14,6 +14,7 @@
 import org.apache.maven.plugins.annotations.Mojo;
 import org.apache.maven.plugins.annotations.Parameter;
 
+import com.gkatzioura.maven.cloud.gcs.StorageFactory;
 import com.google.cloud.storage.BlobInfo;
 import com.google.cloud.storage.Storage;
 import com.google.cloud.storage.StorageOptions;
@@ -30,6 +31,11 @@ public class GCSUploadMojo extends AbstractMojo {
     @Parameter(property = "gcs-upload.key")
     private String key;
 
+    @Parameter(property = "gcs-upload.keyPath")
+    private String keyPath;
+
+    private final StorageFactory storageFactory = new StorageFactory();
+
     public GCSUploadMojo() {
     }
 
@@ -52,7 +58,7 @@ public void execute() throws MojoExecutionException, MojoFailureException {
             throw new MojoExecutionException("You need to specify a bucket");
         }
 
-        Storage storage = StorageOptions.getDefaultInstance().getService();
+        Storage storage = initializeStorage();
 
         if(isDirectory()){
             List<String> filesToUpload = findFilesToUpload(path);
@@ -65,6 +71,18 @@ public void execute() throws MojoExecutionException, MojoFailureException {
         }
     }
 
+    private Storage initializeStorage() throws MojoExecutionException {
+        if(keyPath==null) {
+            return storageFactory.createDefault();
+        } else {
+            try {
+                return storageFactory.createWithKeyFile(keyPath);
+            } catch (IOException e) {
+                throw new MojoExecutionException("Failed to set Authentication to Google Cloud");
+            }
+        }
+    }
+
     private List<String> findFilesToUpload(String filePath) {
         List<String> totalFiles = new ArrayList<>();
 

GoogleStorageWagon/src/main/java/com/gkatzioura/maven/cloud/gcs/wagon/GoogleStorageRepository.java

@@ -30,6 +30,7 @@
 import org.apache.maven.wagon.ResourceDoesNotExistException;
 import org.apache.maven.wagon.authentication.AuthenticationException;
 
+import com.gkatzioura.maven.cloud.gcs.StorageFactory;
 import com.gkatzioura.maven.cloud.resolver.KeyResolver;
 import com.gkatzioura.maven.cloud.wagon.PublicReadProperty;
 import com.google.api.gax.paging.Page;