Im 542 get s3 region by analyzing the asset href

adapters/klab.ogc/src/main/java/org/integratedmodelling/klab/stac/STACCollectionParser.java

@@ -25,10 +25,6 @@ public static String readCollectionId(JSONObject collection) {
         return collection.getString("id");
     }
 
-    private static JSONObject readItemAssets(JSONObject collection) {
-        return collection.getJSONObject("item_assets");
-    }
-
     /**
      * Obtains the geometry from the collection data.
      * Currently, only available for dynamic collections.
@@ -82,14 +78,6 @@ public static JSONObject readAssetsFromCollection(String collectionUrl, JSONObje
             return collection.getJSONObject("assets");
         }
 
-        // item_assets is a shortcut for obtaining information about the assets
-        // https://github.com/stac-extensions/item-assets
-        if (collection.has("item_assets")) {
-            if (!collection.getJSONObject("item_assets").isEmpty()) {
-                return STACCollectionParser.readItemAssets(collection);
-            }
-        }
-
         // TODO Move the query to another place. 
         String parameters = "?collections=" + collectonId + "&limit=1";
         HttpResponse<JsonNode> response = Unirest.get(searchEndpoint.get() + parameters).asJson();

adapters/klab.ogc/src/main/java/org/integratedmodelling/klab/stac/STACEncoder.java

@@ -56,7 +56,6 @@
 import org.opengis.feature.simple.SimpleFeature;
 import org.opengis.feature.simple.SimpleFeatureType;
 
-import kong.unirest.apache.ApacheClient;
 import kong.unirest.json.JSONObject;
 import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
 import software.amazon.awssdk.auth.credentials.AwsCredentials;
@@ -274,8 +273,8 @@ public void getEncodedData(IResource resource, Map<String, String> urnParameters
                 scope.getMonitor().warn("Multiple EPSGs found on the items " + EPSGsAtItems.toString() + ". The transformation process could affect the data.");
             }
 
-            if (resource.getParameters().contains("s3BucketRegion")) {
-                String bucketRegion = resource.getParameters().get("s3BucketRegion", String.class);
+            if (resource.getParameters().contains("awsRegion")) {
+                String bucketRegion = resource.getParameters().get("awsRegion", String.class);
                 S3Client s3Client = buildS3Client(bucketRegion);
                 collection.setS3Client(s3Client);
             }

adapters/klab.ogc/src/main/java/org/integratedmodelling/klab/stac/STACImporter.java

@@ -24,8 +24,11 @@
 import org.integratedmodelling.klab.exceptions.KlabIOException;
 import org.integratedmodelling.klab.utils.Parameters;
 import org.integratedmodelling.klab.utils.Triple;
+import org.integratedmodelling.klab.utils.s3.S3RegionResolver;
+import org.integratedmodelling.klab.utils.s3.S3URLUtils;
 
 import kong.unirest.json.JSONObject;
+import software.amazon.awssdk.regions.Region;
 
 public class STACImporter implements IResourceImporter {
 
@@ -82,6 +85,12 @@ private void importCollection(List<Builder> ret, IParameters<String> parameters,
             }
             parameters.put("asset", assetId);
             String resourceUrn = collectionId + "-" + assetId;
+            String href = assetData.getString("href");
+            if (S3URLUtils.isS3Endpoint(href)) {
+                String[] bucketAndObject = href.split("://")[1].split("/", 2);
+                Region s3Region = S3RegionResolver.resolveBucketRegion(bucketAndObject[0], bucketAndObject[1]);
+                parameters.put("awsRegion", s3Region.id());
+            }
 
             Builder builder = buildResource(parameters, project, monitor, resourceUrn);
             if (builder != null) {

adapters/klab.ogc/src/main/resources/ogc/prototypes/stac.kdl

@@ -13,7 +13,4 @@
  	optional text 'asset'
  		"The asset that is going to be retrieved from the items."
 
- 	optional text 's3BucketRegion'
- 		"The Region for S3 elements."
-
  }

klab.engine/pom.xml

@@ -960,6 +960,18 @@
 				<version>${junit5.version}</version>
 				<scope>test</scope>
 			</dependency>
+		<!--- AWS dependencies-->
+		<dependency>
+			<artifactId>apache-client</artifactId> 
+			<groupId>software.amazon.awssdk</groupId> 
+			<version>${aws.version}</version> 
+ 			<exclusions>
+				<exclusion>
+					<groupId>commons-logging</groupId>
+					<artifactId>commons-logging</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
 
 	</dependencies>
 </project>

klab.engine/src/main/java/org/integratedmodelling/klab/utils/s3/S3RegionResolver.java

@@ -0,0 +1,97 @@
+package org.integratedmodelling.klab.utils.s3;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.integratedmodelling.klab.exceptions.KlabResourceAccessException;
+
+import software.amazon.awssdk.auth.credentials.AnonymousCredentialsProvider;
+import software.amazon.awssdk.http.apache.ApacheHttpClient;
+import software.amazon.awssdk.regions.Region;
+import software.amazon.awssdk.services.s3.S3Client;
+import software.amazon.awssdk.services.s3.model.GetBucketLocationRequest;
+import software.amazon.awssdk.services.s3.model.GetBucketLocationResponse;
+import software.amazon.awssdk.services.s3.model.HeadObjectRequest;
+
+public class S3RegionResolver {
+
+    public static Region resolveBucketRegion(String bucketName, String objectKey) {
+        // Default region to start with for GetBucketLocation
+        Region defaultRegion = Region.US_EAST_1;
+
+        // Step 1: Attempt to dynamically resolve the bucket's region
+        try (S3Client s3 = S3Client.builder()
+                .httpClientBuilder(ApacheHttpClient.builder())
+                .region(defaultRegion) // Use the default region
+                .credentialsProvider(AnonymousCredentialsProvider.create()) // Anonymous credentials
+                .build()) {
+
+            GetBucketLocationRequest request = GetBucketLocationRequest.builder()
+                    .bucket(bucketName)
+                    .build();
+
+            GetBucketLocationResponse response = s3.getBucketLocation(request);
+            String location = response.locationConstraintAsString();
+
+            // Handle "null" or "global" regions
+            if (location == null || location.equalsIgnoreCase("null")) {
+                return Region.US_EAST_1;
+            }
+
+            Region resolvedRegion = Region.of(location);
+            return resolvedRegion;
+
+        } catch (Exception e) {
+            // try another one
+        }
+
+        // Step 2: Iterate through all regions and test lightweight requests
+        return resolveRegionByTesting(bucketName, objectKey);
+    }
+
+    private static List<Region> getAwsRegions() {
+        // List of regions to exclude (e.g., isolated regions or restricted access regions)
+        List<Region> excludedRegions = List.of(
+                Region.US_ISO_EAST_1, // Restricted to isolated networks
+                Region.US_ISO_WEST_1, // Example of another restricted region
+                Region.CN_NORTH_1,    // China regions may require special accounts
+                Region.CN_NORTHWEST_1
+        );
+
+        // Get the list of all AWS regions, excluding problematic ones
+        return Region.regions().stream()
+                .filter(region -> !excludedRegions.contains(region))
+                .collect(Collectors.toList());
+    }
+
+    private static Region resolveRegionByTesting(String bucketName, String objectKey) {
+        // Get the list of all AWS regions
+        List<Region> regions = getAwsRegions();
+
+        // Iterate through regions to perform a lightweight test
+        for (Region region : regions) {
+            try (S3Client s3 = S3Client.builder()
+                    .region(region)
+                    .credentialsProvider(AnonymousCredentialsProvider.create())
+                    .build()) {
+
+                System.out.println("Testing region: " + region);
+
+                // Perform a lightweight HEAD request to check if the object exists
+                HeadObjectRequest request = HeadObjectRequest.builder()
+                        .bucket(bucketName)
+                        .key(objectKey)
+                        .build();
+
+                s3.headObject(request); // If no exception is thrown, the region is correct
+                System.out.println("Region confirmed by testing: " + region);
+                return region;
+            } catch (Exception e) {
+                // Continue testing other regions if the bucket is not found
+                continue;
+            }
+        }
+
+        throw new KlabResourceAccessException("Unable to resolve region for bucket: " + bucketName);
+    }
+}

klab.engine/src/test/java/org/integratedmodelling/klab/test/utils/S3RegionResolverTest.java

@@ -0,0 +1,33 @@
+package org.integratedmodelling.klab.test.utils;
+
+import org.integratedmodelling.klab.exceptions.KlabResourceAccessException;
+import org.integratedmodelling.klab.utils.s3.S3RegionResolver;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+import software.amazon.awssdk.regions.Region;
+
+public class S3RegionResolverTest {
+
+    @Test
+    public void resolveBucketRegion_resolutionSuccessful() {
+        String bucket = "deafrica-input-datasets";
+        String objectKey = "rainfall_chirps_monthly/chirps-v2.0_2024.03.tif";
+
+        Region ret = S3RegionResolver.resolveBucketRegion(bucket, objectKey);
+
+        Assertions.assertEquals(Region.AF_SOUTH_1, ret);
+    }
+
+    @Test
+    // Warning: a relatively costly test (sometimes over 30 seconds)
+    public void resolveBucketRegion_resolutionUnsuccessful() {
+        String bucket = "fake-bucket";
+        String objectKey = "fake-object.tif";
+
+        Assertions.assertThrows(KlabResourceAccessException.class, () -> {
+            S3RegionResolver.resolveBucketRegion(bucket, objectKey);
+        });
+    }
+
+}