Skip to content

Commit 1b2d69a

Browse files
committed
Added core S3 region override
1 parent 984a8e8 commit 1b2d69a

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

src/main/java/com/uid2/shared/Const.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ public static class Config {
5252
public static final String CloudDownloadThreadsProp = "cloud_download_threads";
5353
public static final String CloudUploadThreadsProp = "cloud_upload_threads";
5454
public static final String CoreS3BucketProp = "core_s3_bucket";
55+
public static final String CoreS3RegionProp = "core_s3_aws_region";
5556
public static final String OptOutS3BucketProp = "optout_s3_bucket";
5657
public static final String ClientsMetadataPathProp = "clients_metadata_path";
5758
public static final String KeysMetadataPathProp = "keys_metadata_path";

src/main/java/com/uid2/shared/cloud/CloudUtils.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,9 +29,14 @@ public class CloudUtils {
2929
public static TaggableCloudStorage createStorage(String cloudBucket, JsonObject jsonConfig) {
3030
var accessKeyId = jsonConfig.getString(Const.Config.AccessKeyIdProp);
3131
var secretAccessKey = jsonConfig.getString(Const.Config.SecretAccessKeyProp);
32-
var region = jsonConfig.getString(Const.Config.AwsRegionProp);
3332
var s3Endpoint = jsonConfig.getString(Const.Config.S3EndpointProp, "");
3433

34+
var region = jsonConfig.getString(Const.Config.AwsRegionProp);
35+
var regionOverride = jsonConfig.getString(Const.Config.CoreS3RegionProp);
36+
if (regionOverride == null || regionOverride.isBlank()) {
37+
region = regionOverride;
38+
}
39+
3540
if (accessKeyId == null || secretAccessKey == null) {
3641
// IAM authentication
3742
return new CloudStorageS3(region, cloudBucket, s3Endpoint);

0 commit comments

Comments
 (0)