fix: update default region

Author: aajtodd

services/s3/e2eTest/src/S3IntegrationTest.kt

@@ -35,12 +35,8 @@ import kotlin.time.ExperimentalTime
 @OptIn(ExperimentalTime::class, ExperimentalCoroutinesApi::class)
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class S3BucketOpsIntegrationTest {
-    companion object {
-        const val DEFAULT_REGION = "us-east-2"
-    }
-
     private val client = S3Client {
-        region = DEFAULT_REGION
+        region = S3TestUtils.DEFAULT_REGION
     }
 
     private lateinit var testBucket: String
@@ -216,58 +212,56 @@ class S3BucketOpsIntegrationTest {
 
     @Test
     fun testSelectObjectEventStream(): Unit = runBlocking {
-        S3Client.fromEnvironment().use { s3 ->
-            // upload our content to select from
-            val objKey = "developers.csv"
-
-            val content = """
-            Name,PhoneNumber,City,Occupation
-            Sam,(949) 555-6701,Irvine,Solutions Architect
-            Vinod,(949) 555-6702,Los Angeles,Solutions Architect
-            Jeff,(949) 555-6703,Seattle,AWS Evangelist
-            Jane,(949) 555-6704,Chicago,Developer
-            Sean,(949) 555-6705,Indianapolis,Developer
-            Mary,(949) 555-6706,Detroit,Developer
-            Kate,(949) 555-6707,Boston,Solutions Architect
-            """.trimIndent()
+        // upload our content to select from
+        val objKey = "developers.csv"
+
+        val content = """
+        Name,PhoneNumber,City,Occupation
+        Sam,(949) 555-6701,Irvine,Solutions Architect
+        Vinod,(949) 555-6702,Los Angeles,Solutions Architect
+        Jeff,(949) 555-6703,Seattle,AWS Evangelist
+        Jane,(949) 555-6704,Chicago,Developer
+        Sean,(949) 555-6705,Indianapolis,Developer
+        Mary,(949) 555-6706,Detroit,Developer
+        Kate,(949) 555-6707,Boston,Solutions Architect
+        """.trimIndent()
 
-            s3.putObject {
-                bucket = testBucket
-                key = objKey
-                body = ByteStream.fromString(content)
-            }
+        client.putObject {
+            bucket = testBucket
+            key = objKey
+            body = ByteStream.fromString(content)
+        }
 
-            // select content as an event stream
-            val req = SelectObjectContentRequest {
-                bucket = testBucket
-                key = objKey
-                expressionType = ExpressionType.Sql
-                expression = """SELECT * FROM s3object s where s."Name" = 'Jane'"""
-                inputSerialization {
-                    csv {
-                        fileHeaderInfo = FileHeaderInfo.Use
-                    }
-                    compressionType = CompressionType.None
-                }
-                outputSerialization {
-                    csv { }
+        // select content as an event stream
+        val req = SelectObjectContentRequest {
+            bucket = testBucket
+            key = objKey
+            expressionType = ExpressionType.Sql
+            expression = """SELECT * FROM s3object s where s."Name" = 'Jane'"""
+            inputSerialization {
+                csv {
+                    fileHeaderInfo = FileHeaderInfo.Use
                 }
+                compressionType = CompressionType.None
             }
-
-            val events = s3.selectObjectContent(req) { resp ->
-                // collect flow to list
-                resp.payload!!.toList()
+            outputSerialization {
+                csv { }
             }
+        }
 
-            assertEquals(3, events.size)
+        val events = client.selectObjectContent(req) { resp ->
+            // collect flow to list
+            resp.payload!!.toList()
+        }
 
-            val records = assertIs<SelectObjectContentEventStream.Records>(events[0])
-            assertIs<SelectObjectContentEventStream.Stats>(events[1])
-            assertIs<SelectObjectContentEventStream.End>(events[2])
+        assertEquals(3, events.size)
 
-            val expectedRecord = "Jane,(949) 555-6704,Chicago,Developer\n"
-            assertEquals(expectedRecord, records.value.payload?.decodeToString())
-        }
+        val records = assertIs<SelectObjectContentEventStream.Records>(events[0])
+        assertIs<SelectObjectContentEventStream.Stats>(events[1])
+        assertIs<SelectObjectContentEventStream.End>(events[2])
+
+        val expectedRecord = "Jane,(949) 555-6704,Chicago,Developer\n"
+        assertEquals(expectedRecord, records.value.payload?.decodeToString())
     }
 }
 
@@ -280,7 +274,7 @@ private fun File.chunk(partSize: Int): Sequence<LongRange> =
 internal suspend fun s3WithAllEngines(block: suspend (S3Client) -> Unit) {
     withAllEngines { engine ->
         S3Client {
-            region = S3BucketOpsIntegrationTest.DEFAULT_REGION
+            region = S3TestUtils.DEFAULT_REGION
             httpClientEngine = engine
         }.use {
             try {

services/s3/e2eTest/src/S3PresignerTest.kt

@@ -21,12 +21,9 @@ import kotlin.time.Duration.Companion.seconds
 @OptIn(ExperimentalCoroutinesApi::class)
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class S3PresignerTest {
-    companion object {
-        const val DEFAULT_REGION = "us-east-2"
-    }
 
     private val client = S3Client {
-        region = DEFAULT_REGION
+        region = S3TestUtils.DEFAULT_REGION
     }
 
     private lateinit var testBucket: String

services/s3/e2eTest/src/S3TestUtils.kt

@@ -26,6 +26,8 @@ import kotlin.time.Duration.Companion.seconds
 
 object S3TestUtils {
 
+    const val DEFAULT_REGION = "us-west-2"
+
     private const val TEST_BUCKET_PREFIX = "s3-test-bucket-"
 
     suspend fun getTestBucket(client: S3Client): String = getBucketWithPrefix(client, TEST_BUCKET_PREFIX)

services/sts/e2eTest/src/STSPresignerTest.kt

@@ -21,7 +21,7 @@ class StsPresignerTest {
 
     @Test
     fun testGetCallerIdentityPresigner() = runBlocking {
-        val c = StsClient { region = "us-east-2" }
+        val c = StsClient { region = "us-west-2" }
         val req = GetCallerIdentityRequest { }
         val presignedRequest = req.presign(c.config, 60.seconds)
 

services/transcribestreaming/e2eTest/src/TranscribeStreamingIntegrationTest.kt

@@ -26,7 +26,7 @@ class TranscribeStreamingIntegrationTest {
         val url = this::class.java.classLoader.getResource("hello-kotlin-8000.wav") ?: error("failed to load test resource")
         val audioFile = Paths.get(url.toURI()).toFile()
 
-        TranscribeStreamingClient { region = "us-east-2" }.use { client ->
+        TranscribeStreamingClient { region = "us-west-2" }.use { client ->
             val transcript = getTranscript(client, audioFile)
             assertTrue(transcript.startsWith("Hello from", true), "full transcript: $transcript")
         }