add sfn fault path tests

Author: yiyuan-he

appsignals-tests/contract-tests/src/test/java/software/amazon/opentelemetry/appsignals/test/awssdk/base/AwsSdkBaseTest.java

@@ -2518,4 +2518,40 @@ protected void doTestStepFunctionsDescribeActivityError() throws Exception {
         cloudformationIdentifier,
         1.0);
   }
+
+  protected void doTestStepFunctionsDescribeActivityFault() throws Exception {
+    appClient.get("/sfn/fault").aggregate().join();
+    var traces = mockCollectorClient.getTraces();
+    var metrics = mockCollectorClient.getMetrics(
+        Set.of(
+            AppSignalsConstants.ERROR_METRIC,
+            AppSignalsConstants.FAULT_METRIC,
+            AppSignalsConstants.LATENCY_METRIC));
+
+    var localService = getApplicationOtelServiceName();
+    var localOperation = "GET /sfn/fault";
+    var type = "AWS::StepFunctions::Activity";
+    var identifier = "fault-activity";
+    var cloudformationIdentifier = "arn:aws:states:us-west-2:000000000000:activity:fault-activity";
+
+    assertSpanClientAttributes(
+        traces,
+        stepFunctionsSpanName("DescribeActivity"),
+        getStepFunctionsRpcServiceName(),
+        localService,
+        localOperation,
+        getStepFunctionsServiceName(),
+        "DescribeActivity",
+        type,
+        identifier,
+        cloudformationIdentifier,
+        "fault.test",
+        8080,
+        "http://fault.test:8080",
+        500,
+        List.of(
+            assertAttribute(
+                SemanticConventionsConstants.AWS_ACTIVITY_ARN,
+                "arn:aws:states:us-west-2:000000000000:activity:fault-activity")));
+  }
 }

appsignals-tests/contract-tests/src/test/java/software/amazon/opentelemetry/appsignals/test/awssdk/v1/AwsSdkV1Test.java

@@ -275,4 +275,9 @@ void testStepFunctionsDescribeActivity() throws Exception {
   void testStepFunctionsDescribeActivityError() throws Exception {
     doTestStepFunctionsDescribeActivityError();
   }
+
+  @Test
+  void testStepFunctionsDescribeActivityFault() throws Exception {
+    doTestStepFunctionsDescribeActivityFault();
+  }
 }

appsignals-tests/contract-tests/src/test/java/software/amazon/opentelemetry/appsignals/test/awssdk/v2/AwsSdkV2Test.java

@@ -280,4 +280,9 @@ void testStepFunctionsDescribeActivity() throws Exception {
   void testStepFunctionsDescribeActivityError() throws Exception {
     doTestStepFunctionsDescribeActivityError();
   }
+
+  @Test
+  void testStepFunctionsDescribeActivityFault() throws Exception {
+    doTestStepFunctionsDescribeActivityFault();
+  }
 }

appsignals-tests/images/aws-sdk/aws-sdk-v1/src/main/java/com/amazon/sampleapp/App.java

@@ -829,6 +829,7 @@ private static void setupStepFunctions() {
           var errorClient = AWSStepFunctionsClient.builder().withCredentials(CREDENTIALS_PROVIDER)
               .withEndpointConfiguration(new EndpointConfiguration("http://error.test:8080", Regions.US_WEST_2.getName()))
               .build();
+
           try {
             var describeRequest = new DescribeActivityRequest().withActivityArn("arn:aws:states:us-west-2:000000000000:activity:nonexistent-activity");
             errorClient.describeActivity(describeRequest);
@@ -837,5 +838,23 @@ private static void setupStepFunctions() {
           }
           return "";
         });
+
+    get(
+        "/sfn/fault",
+        (req, res) -> {
+          setMainStatus(500);
+          var faultClient = AWSStepFunctionsClient.builder().withCredentials(CREDENTIALS_PROVIDER)
+              .withEndpointConfiguration(new EndpointConfiguration("http://fault.test:8080", Regions.US_WEST_2.getName()))
+              .build();
+
+          try {
+            var describeRequest = new DescribeActivityRequest()
+                .withActivityArn("arn:aws:states:us-west-2:000000000000:activity:fault-activity");
+            faultClient.describeActivity(describeRequest);
+          } catch (Exception e) {
+            logger.info("Error caught in Sample App", e);
+          }
+          return"";
+        });
   }
 }

appsignals-tests/images/aws-sdk/aws-sdk-v2/src/main/java/com/amazon/sampleapp/App.java

@@ -872,5 +872,25 @@ private static void setupStepFunctions() {
           }
           return "";
         });
+
+    get(
+        "/sfn/fault",
+        (req, res) -> {
+          setMainStatus(500);
+          var faultClient = SfnClient.builder()
+              .endpointOverride(URI.create("http://fault.test:8080"))
+              .credentialsProvider(CREDENTIALS_PROVIDER)
+              .build();
+
+          try {
+            var describeRequest = DescribeActivityRequest.builder()
+                .activityArn("arn:aws:states:us-west-2:000000000000:activity:fault-activity")
+                .build();
+            faultClient.describeActivity(describeRequest);
+          } catch (Exception e) {
+            logger.info("Fault caught in Sample App", e);
+          }
+          return "";
+        });
   }
 }