fix: pass client region through to StsWebIdentityCredentialsProvider …

…constructor (#1181)
awslabs · Jan 22, 2024 · 011cdc4 · 011cdc4
1 parent fc41fd4
commit 011cdc4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/.changes/6e770127-0656-465f-a526-85c125581891.json b/.changes/6e770127-0656-465f-a526-85c125581891.json
@@ -0,0 +1,5 @@
+{
+    "id": "6e770127-0656-465f-a526-85c125581891",
+    "type": "bugfix",
+    "description": "Pass client-configured region to StsWebIdentityCredentialsProvider"
+}
diff --git a/...fig/common/src/aws/sdk/kotlin/runtime/auth/credentials/DefaultChainCredentialsProvider.kt b/...fig/common/src/aws/sdk/kotlin/runtime/auth/credentials/DefaultChainCredentialsProvider.kt
@@ -56,7 +56,7 @@ public class DefaultChainCredentialsProvider constructor(
         EnvironmentCredentialsProvider(platformProvider::getenv),
         ProfileCredentialsProvider(profileName = profileName, platformProvider = platformProvider, httpClient = engine, region = region),
         // STS web identity provider can be constructed from either the profile OR 100% from the environment
-        StsWebIdentityProvider(platformProvider = platformProvider, httpClient = engine),
+        StsWebIdentityProvider(platformProvider = platformProvider, httpClient = engine, region = region),
         EcsCredentialsProvider(platformProvider, engine),
         ImdsCredentialsProvider(
             client = lazy {
@@ -88,9 +88,10 @@ public class DefaultChainCredentialsProvider constructor(
 private class StsWebIdentityProvider(
     val platformProvider: PlatformProvider = PlatformProvider.System,
     val httpClient: HttpClientEngine? = null,
+    val region: String? = null,
 ) : CloseableCredentialsProvider {
     override suspend fun resolve(attributes: Attributes): Credentials {
-        val wrapped = StsWebIdentityCredentialsProvider.fromEnvironment(platformProvider = platformProvider, httpClient = httpClient)
+        val wrapped = StsWebIdentityCredentialsProvider.fromEnvironment(platformProvider = platformProvider, httpClient = httpClient, region = region)
         return wrapped.resolve(attributes)
     }