add s3 storage option

Signed-off-by: Harsh Modi <hmodi@redhat.com>

Author: hjmodi

filers/default/src/main/java/org/commonjava/indy/filer/def/DefaultGalleyStorageProvider.java

@@ -56,12 +56,15 @@
 import org.commonjava.maven.galley.transport.htcli.UploadMetadataGenTransferDecorator;
 import org.commonjava.storage.pathmapped.config.DefaultPathMappedStorageConfig;
 import org.commonjava.storage.pathmapped.config.PathMappedStorageConfig;
+import org.commonjava.storage.pathmapped.core.S3PhysicalStore;
 import org.commonjava.storage.pathmapped.pathdb.datastax.CassandraPathDB;
 import org.commonjava.storage.pathmapped.metrics.MeasuredPathDB;
 import org.commonjava.storage.pathmapped.spi.PathDB;
 import org.commonjava.storage.pathmapped.spi.PhysicalStore;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import software.amazon.awssdk.services.s3.S3Client;
+import software.amazon.awssdk.services.s3.model.S3Exception;
 
 import javax.annotation.PostConstruct;
 import javax.enterprise.context.ApplicationScoped;
@@ -236,7 +239,21 @@ protected boolean isMetricEnabled( String metricName )
         }
 
         File legacyBaseDir = config.getLegacyStorageBasedir();
-        PhysicalStore physicalStore = new LegacyReadonlyPhysicalStore( storeRoot, legacyBaseDir );
+        String storageType = config.getStorageType();
+        PhysicalStore physicalStore;
+        if (DefaultStorageProviderConfiguration.STORAGE_NFS.equals( storageType )) {
+            physicalStore = new LegacyReadonlyPhysicalStore( storeRoot, legacyBaseDir );
+        } else  {
+            try {
+                S3Client s3Client = S3Client.builder().build();
+                String bucketName = config.getBucketName();
+                physicalStore = new S3PhysicalStore( s3Client, bucketName );
+            } catch ( S3Exception e ) {
+                logger.error( "Ran into error during storage init e: ", e);
+                throw e;
+            }
+
+        }
 
         logger.info( "Create cacheProviderFactory, pathDB: {}, physicalStore: {}", pathDB, physicalStore );
         PathMappedCacheProviderConfig cacheProviderConfig =

filers/default/src/main/java/org/commonjava/indy/filer/def/conf/DefaultStorageProviderConfiguration.java

@@ -38,6 +38,12 @@ public class DefaultStorageProviderConfiguration
 
     public static final String STORAGE_DIR = "indy.storage.dir";
 
+    public static final String STORAGE_S3 = "s3";
+
+    public static final String STORAGE_NFS = "nfs";
+
+    public static final String DEFAULT_STORAGE = STORAGE_NFS;
+
     public static final String NFS_STORAGE_DIR = "indy.storage.nfs.dir";
 
     private File storageBasedir;
@@ -46,6 +52,10 @@ public class DefaultStorageProviderConfiguration
 
     private File nfsStoreBasedir;
 
+    private String storageType;
+
+    private String bucketName;
+
     private boolean storageTimeoutEnabled = true;
 
     private boolean physicalFileExistenceCheckEnabled = false;
@@ -220,6 +230,31 @@ public void setLegacyStorageBasedir( File legacyStorageBasedir )
         this.legacyStorageBasedir = legacyStorageBasedir;
     }
 
+    public String getStorageType()
+    {
+        if (storageType == null) {
+            return DEFAULT_STORAGE;
+        }
+        return storageType;
+    }
+
+    @ConfigName( "storage.type" )
+    public void setStorageType( String storageType )
+    {
+        this.storageType = storageType;
+    }
+
+    public String getBucketName()
+    {
+        return bucketName;
+    }
+
+    @ConfigName( "storage.bucket.name" )
+    public void setBucketName( String bucketName )
+    {
+        this.bucketName = bucketName;
+    }
+
     public boolean isStorageTimeoutEnabled()
     {
         return storageTimeoutEnabled;

pom.xml

@@ -83,7 +83,7 @@
     <otelInstrumentationVersion>1.19.0-alpha</otelInstrumentationVersion>
     <cassandraUnitVersion>3.7.1.0</cassandraUnitVersion>
     <datastaxVersion>3.11.3</datastaxVersion>
-    <pathmappedStorageVersion>2.6</pathmappedStorageVersion>
+    <pathmappedStorageVersion>2.7-SNAPSHOT</pathmappedStorageVersion>
     <o11yphantVersion>1.9.1</o11yphantVersion>
     <swaggerVersion>1.6.6</swaggerVersion>
     <agroalVersion>1.16</agroalVersion>