updated the Kotlin SDK build number

scmacdon · scmacdon · commit 1ea5626e8530 · 2025-01-24T11:49:53.000-05:00
diff --git a/kotlin/services/stepfunctions/build.gradle.kts b/kotlin/services/stepfunctions/build.gradle.kts
@@ -27,9 +27,9 @@ repositories {
 }
 apply(plugin = "org.jlleitschuh.gradle.ktlint")
 dependencies {
-    implementation("aws.sdk.kotlin:sfn:1.2.28")
-    implementation("aws.sdk.kotlin:iam:1.2.28")
-    implementation("aws.sdk.kotlin:secretsmanager:1.2.28")
+    implementation("aws.sdk.kotlin:sfn:1.3.112")
+    implementation("aws.sdk.kotlin:iam:1.3.112")
+    implementation("aws.sdk.kotlin:secretsmanager:1.3.112")
     implementation("aws.smithy.kotlin:http-client-engine-okhttp:0.30.0")
     implementation("aws.smithy.kotlin:http-client-engine-crt:0.30.0")
     implementation("com.google.code.gson:gson:2.10")
diff --git a/kotlin/services/stepfunctions/src/main/kotlin/com/kotlin/stepfunctions/GetStream.kt b/kotlin/services/stepfunctions/src/main/kotlin/com/kotlin/stepfunctions/GetStream.kt
@@ -4,12 +4,13 @@ package com.kotlin.stepfunctions
 
 import com.fasterxml.jackson.databind.JsonNode
 import com.fasterxml.jackson.databind.ObjectMapper
+import java.io.FileInputStream
 import java.io.InputStream
 
 class GetStream {
-    suspend fun getStream(): String {
+    suspend fun getStream(location:String): String {
         // Get JSON to use for the state machine and place the activityArn value into it.
-        val input: InputStream = this::class.java.classLoader.getResourceAsStream("chat_sfn_state_machine.json")
+        val input: InputStream = FileInputStream(location)
         val mapper = ObjectMapper()
         val jsonNode: JsonNode = mapper.readValue(input, JsonNode::class.java)
         return mapper.writeValueAsString(jsonNode)
diff --git a/kotlin/services/stepfunctions/src/main/kotlin/com/kotlin/stepfunctions/StepFunctionsScenario.kt b/kotlin/services/stepfunctions/src/main/kotlin/com/kotlin/stepfunctions/StepFunctionsScenario.kt
@@ -67,16 +67,18 @@ suspend fun main(args: Array<String>) {
         roleName - The name of the IAM role to create for this state machine.
         activityName - The name of an activity to create.    
         stateMachineName - The name of the state machine to create.
+        jsonFile - The location of the chat_sfn_state_machine.json file. You can located it in resources/sample_files. 
     """
 
-    if (args.size != 3) {
+    if (args.size != 4) {
         println(usage)
         exitProcess(0)
     }
 
     val roleName = args[0]
     val activityName = args[1]
     val stateMachineName = args[2]
+    val jsonFile = args[3]
     val sc = Scanner(System.`in`)
     var action = false
 
@@ -116,7 +118,7 @@ suspend fun main(args: Array<String>) {
 
     // Get JSON to use for the state machine and place the activityArn value into it.
     val stream = GetStream()
-    val jsonString = stream.getStream()
+    val jsonString = stream.getStream(jsonFile)
 
     // Modify the Resource node.
     val objectMapper = ObjectMapper()
@@ -258,14 +260,14 @@ suspend fun describeExe(executionArnVal: String?) {
         SfnClient { region = "us-east-1" }.use { sfnClient ->
             val response = sfnClient.describeExecution(executionRequest)
             status = response.status.toString()
-            if (status.compareTo("RUNNING") == 0) {
+            if (status.compareTo("Running") == 0) {
                 println("The state machine is still running, let's wait for it to finish.")
                 Thread.sleep(2000)
-            } else if (status.compareTo("SUCCEEDED") == 0) {
+            } else if (status.compareTo("Succeeded") == 0) {
                 println("The Step Function workflow has succeeded")
                 hasSucceeded = true
             } else {
-                println("The Status is neither running or succeeded")
+                println("The Status is $status")
             }
         }
     }
diff --git a/kotlin/services/stepfunctions/src/test/kotlin/StepFunctionsKotlinTest.kt b/kotlin/services/stepfunctions/src/test/kotlin/StepFunctionsKotlinTest.kt
@@ -69,115 +69,13 @@ class StepFunctionsKotlinTest {
         }
 
     @Test
-    @Order(2)
+    @Order(1)
     fun listStateMachines() =
         runBlocking {
             listMachines()
             println("Test 4 passed")
         }
 
-    @Test
-    @Order(2)
-    fun testMVP() =
-        runBlocking {
-            val sc = Scanner(System.`in`)
-            var action = false
-
-            val polJSON = """{
-        "Version": "2012-10-17",
-        "Statement": [
-         {
-            "Sid": "",
-            "Effect": "Allow",
-            "Principal": {
-                "Service": "states.amazonaws.com"
-            },
-            "Action": "sts:AssumeRole"
-         }
-        ]
-        }"""
-
-            println(DASHES)
-            println("List activities using a Paginator.")
-            listActivitesPagnator()
-            println("Create an activity.")
-            val activityArn = createActivity(activityNameSC)
-            println("The ARN of the Activity is $activityArn")
-
-            println("List state machines using a paginator.")
-            listStatemachinesPagnator()
-            println(DASHES)
-
-            // Get JSON to use for the state machine and place the activityArn value into it.
-            val stream = GetStream()
-            val jsonString = stream.getStream()
-
-            // Modify the Resource node.
-            val objectMapper = ObjectMapper()
-            val root: JsonNode = objectMapper.readTree(jsonString)
-            (root.path("States").path("GetInput") as ObjectNode).put("Resource", activityArn)
-
-            // Convert the modified Java object back to a JSON string.
-            val stateDefinition = objectMapper.writeValueAsString(root)
-            println(stateDefinition)
-
-            println(DASHES)
-            println("Create a state machine.")
-            val roleARN = createIAMRole(roleNameSC, polJSON)
-            val stateMachineArn = createMachine(roleARN, stateMachineNameSC, stateDefinition)
-            println("The ARN of the state machine is $stateMachineArn")
-            println("The ARN of the state machine is")
-            println(DASHES)
-
-            println(DASHES)
-            println("Describe the state machine.")
-            describeStateMachine(stateMachineArn)
-            println("What should ChatSFN call you?")
-            val userName = "foo"
-            println("Hello $userName")
-            println(DASHES)
-
-            println(DASHES)
-            // The JSON to pass to the StartExecution call.
-            val executionJson = "{ \"name\" : \"$userName\" }"
-            println(executionJson)
-            println("Start execution of the state machine and interact with it.")
-            val runArn = startWorkflow(stateMachineArn, executionJson)
-            println("The ARN of the state machine execution is $runArn")
-            var myList: List<String>
-            while (!action) {
-                myList = getActivityTask(activityArn)
-                println("ChatSFN: " + myList[1])
-                println("$userName please specify a value.")
-                val myAction = "done"
-                action = true
-                val taskJson = "{ \"action\" : \"$myAction\" }"
-                println(taskJson)
-                sendTaskSuccess(myList[0], taskJson)
-            }
-            println(DASHES)
-
-            println(DASHES)
-            println("Describe the execution.")
-            describeExe(runArn)
-            println(DASHES)
-
-            println(DASHES)
-            println("Delete the activity.")
-            deleteActivity(activityArn)
-            println(DASHES)
-
-            println(DASHES)
-            println("Delete the state machines.")
-            deleteMachine(stateMachineArn)
-            println(DASHES)
-
-            println(DASHES)
-            println("The AWS Step Functions example scenario is complete.")
-            println(DASHES)
-            println("Test 4 passed")
-        }
-
     private suspend fun getSecretValues(): String {
         val secretName = "test/stepfunctions"
         val valueRequest =
