Chore/fix e2e (#102)

* chore: add parameter to CloyudBasedIntegrationTest for functionNameSuffix

* chore: enable e2e test workflow in current branch

* Revert "chore: enable e2e test workflow in current branch"

This reverts commit f55b2ff.

* chore: remove unused import

* chore: testSimpleInvokeExample takes name input so it can find the correct durable function to invoke

* chore:ran mvn spotless:apply

---------

Co-authored-by: hsilan <hsilan@amazon.com>

Author: SilanHe

.github/workflows/e2e-tests.yml

@@ -73,5 +73,5 @@ jobs:
       - name: Build locally
         run: mvn -B -q -Dmaven.test.skip=true install --file pom.xml
       - name: Cloud Based Integration Tests
-        run: mvn clean test -B -Dtest.cloud.enabled=true -Dtest=CloudBasedIntegrationTest
+        run: mvn clean test -B -Dtest.cloud.enabled=true -Dtest=CloudBasedIntegrationTest -Dtest.function.name.suffix='-java${{ matrix.java }}'
         working-directory: ./examples

examples/src/main/java/com/amazonaws/lambda/durable/examples/SimpleInvokeExample.java

@@ -18,13 +18,13 @@ public String handleRequest(GreetingRequest input, DurableContext context) {
         // invoke `simple-step-example` function
         var future = context.invokeAsync(
                 "call-greeting1",
-                "simple-step-example:$LATEST",
+                "simple-step-example" + input.getName() + ":$LATEST",
                 input,
                 String.class,
                 InvokeConfig.builder().build());
         var result2 = context.invoke(
                 "call-greeting2",
-                "simple-step-example:$LATEST",
+                "simple-step-example" + input.getName() + ":$LATEST",
                 input,
                 String.class,
                 InvokeConfig.builder().build());

examples/src/test/java/com/amazonaws/lambda/durable/examples/CloudBasedIntegrationTest.java

@@ -21,6 +21,7 @@ class CloudBasedIntegrationTest {
 
     private static String account;
     private static String region;
+    private static String functionNameSuffix;
 
     static boolean isEnabled() {
         var enabled = "true".equals(System.getProperty("test.cloud.enabled"));
@@ -40,6 +41,7 @@ static void setup() {
 
         account = System.getProperty("test.aws.account");
         region = System.getProperty("test.aws.region");
+        functionNameSuffix = System.getProperty("test.function.name.suffix", "");
 
         if (account == null || region == null) {
             var sts = StsClient.create();
@@ -52,7 +54,8 @@ static void setup() {
     }
 
     private static String arn(String functionName) {
-        return "arn:aws:lambda:" + region + ":" + account + ":function:" + functionName + ":$LATEST";
+        return "arn:aws:lambda:" + region + ":" + account + ":function:" + functionName + functionNameSuffix
+                + ":$LATEST";
     }
 
     @Test
@@ -71,7 +74,7 @@ void testSimpleStepExample() {
     @Test
     void testSimpleInvokeExample() {
         var runner = CloudDurableTestRunner.create(arn("simple-invoke-example"), Map.class, String.class);
-        var result = runner.run(Map.of("message", "test"));
+        var result = runner.run(Map.of("name", functionNameSuffix));
 
         assertEquals(ExecutionStatus.SUCCEEDED, result.getStatus());
         assertNotNull(result.getResult(String.class));