4444import com .amazonaws .services .dynamodbv2 .model .KeyType ;
4545import com .amazonaws .services .dynamodbv2 .model .ProvisionedThroughput ;
4646import com .amazonaws .services .dynamodbv2 .model .PutItemRequest ;
47+ import com .amazonaws .services .identitymanagement .AmazonIdentityManagementClient ;
4748import com .amazonaws .services .identitymanagement .model .CreateRoleRequest ;
4849import com .amazonaws .services .identitymanagement .model .PutRolePolicyRequest ;
4950import com .amazonaws .services .kinesis .AmazonKinesisClient ;
5960import com .amazonaws .services .secretsmanager .model .DescribeSecretRequest ;
6061import com .amazonaws .services .secretsmanager .model .ListSecretsRequest ;
6162import com .amazonaws .services .secretsmanager .model .SecretListEntry ;
62- import com .amazonaws .services .stepfunctions .AWSStepFunctionsClient ;
63- import com .amazonaws .services .stepfunctions .model .*;
64- import com .amazonaws .services .identitymanagement .AmazonIdentityManagementClient ;
6563import com .amazonaws .services .sqs .AmazonSQSClient ;
6664import com .amazonaws .services .sqs .model .CreateQueueRequest ;
6765import com .amazonaws .services .sqs .model .ReceiveMessageRequest ;
6866import com .amazonaws .services .sqs .model .SendMessageRequest ;
67+ import com .amazonaws .services .stepfunctions .AWSStepFunctionsClient ;
68+ import com .amazonaws .services .stepfunctions .model .*;
6969import com .fasterxml .jackson .databind .ObjectMapper ;
7070import java .io .File ;
7171import java .io .IOException ;
@@ -570,22 +570,27 @@ private static void setupSecretsManager() {
570570 });
571571
572572 get (
573- "/secretsmanager/error" ,
573+ "/secretsmanager/error" ,
574574 (req , res ) -> {
575- setMainStatus (400 );
576- var errorClient =
577- AWSSecretsManagerClient .builder ()
578- .withCredentials (CREDENTIALS_PROVIDER )
579- .withEndpointConfiguration (new EndpointConfiguration ("http://error.test:8080" , Regions .US_WEST_2 .getName ()))
580- .build ();
575+ setMainStatus (400 );
576+ var errorClient =
577+ AWSSecretsManagerClient .builder ()
578+ .withCredentials (CREDENTIALS_PROVIDER )
579+ .withEndpointConfiguration (
580+ new EndpointConfiguration (
581+ "http://error.test:8080" , Regions .US_WEST_2 .getName ()))
582+ .build ();
581583
582- try {
583- var describeRequest = new DescribeSecretRequest ().withSecretId ("arn:aws:secretsmanager:us-west-2:000000000000:secret:nonexistent-secret-id" );
584- errorClient .describeSecret (describeRequest );
585- } catch (Exception e ) {
586- logger .debug ("Error describing secret" , e );
587- }
588- return "" ;
584+ try {
585+ var describeRequest =
586+ new DescribeSecretRequest ()
587+ .withSecretId (
588+ "arn:aws:secretsmanager:us-west-2:000000000000:secret:nonexistent-secret-id" );
589+ errorClient .describeSecret (describeRequest );
590+ } catch (Exception e ) {
591+ logger .debug ("Error describing secret" , e );
592+ }
593+ return "" ;
589594 });
590595
591596 get (
@@ -595,16 +600,21 @@ private static void setupSecretsManager() {
595600 var faultClient =
596601 AWSSecretsManagerClient .builder ()
597602 .withCredentials (CREDENTIALS_PROVIDER )
598- .withEndpointConfiguration (new EndpointConfiguration ("http://fault.test:8080" , Regions .US_WEST_2 .getName ()))
603+ .withEndpointConfiguration (
604+ new EndpointConfiguration (
605+ "http://fault.test:8080" , Regions .US_WEST_2 .getName ()))
599606 .build ();
600607
601608 try {
602- var describeRequest = new DescribeSecretRequest ().withSecretId ("arn:aws:secretsmanager:us-west-2:000000000000:secret:fault-secret-id" );
609+ var describeRequest =
610+ new DescribeSecretRequest ()
611+ .withSecretId (
612+ "arn:aws:secretsmanager:us-west-2:000000000000:secret:fault-secret-id" );
603613 faultClient .describeSecret (describeRequest );
604614 } catch (Exception e ) {
605615 logger .debug ("Error describing secret" , e );
606616 }
607- return "" ;
617+ return "" ;
608618 });
609619 }
610620
@@ -728,15 +738,17 @@ private static void setupStepFunctions() {
728738 get (
729739 "/sfn/describestatemachine/:name" ,
730740 (req , res ) -> {
731- var describeRequest = new DescribeStateMachineRequest ().withStateMachineArn (finalExistingStateMachineArn );
741+ var describeRequest =
742+ new DescribeStateMachineRequest ().withStateMachineArn (finalExistingStateMachineArn );
732743 stepFunctionsClient .describeStateMachine (describeRequest );
733744 return "" ;
734745 });
735746
736747 get (
737748 "/sfn/describeactivity/:name" ,
738749 (req , res ) -> {
739- var describeRequest = new DescribeActivityRequest ().withActivityArn (finalExistingActivityArn );
750+ var describeRequest =
751+ new DescribeActivityRequest ().withActivityArn (finalExistingActivityArn );
740752 stepFunctionsClient .describeActivity (describeRequest );
741753 return "" ;
742754 });
@@ -749,13 +761,15 @@ private static void setupStepFunctions() {
749761 AWSStepFunctionsClient .builder ()
750762 .withCredentials (CREDENTIALS_PROVIDER )
751763 .withEndpointConfiguration (
752- new EndpointConfiguration ("http://error.test:8080" , Regions .US_WEST_2 .getName ()))
764+ new EndpointConfiguration (
765+ "http://error.test:8080" , Regions .US_WEST_2 .getName ()))
753766 .build ();
754767
755768 try {
756769 var describeRequest =
757770 new DescribeActivityRequest ()
758- .withActivityArn ("arn:aws:states:us-west-2:000000000000:activity:nonexistent-activity" );
771+ .withActivityArn (
772+ "arn:aws:states:us-west-2:000000000000:activity:nonexistent-activity" );
759773 errorClient .describeActivity (describeRequest );
760774 } catch (Exception e ) {
761775 logger .error ("Error describing activity" , e );
@@ -771,13 +785,15 @@ private static void setupStepFunctions() {
771785 AWSStepFunctionsClient .builder ()
772786 .withCredentials (CREDENTIALS_PROVIDER )
773787 .withEndpointConfiguration (
774- new EndpointConfiguration ("http://fault.test:8080" , Regions .US_WEST_2 .getName ()))
788+ new EndpointConfiguration (
789+ "http://fault.test:8080" , Regions .US_WEST_2 .getName ()))
775790 .build ();
776791
777792 try {
778793 var describeRequest =
779794 new DescribeActivityRequest ()
780- .withActivityArn ("arn:aws:states:us-west-2:000000000000:activity:fault-activity" );
795+ .withActivityArn (
796+ "arn:aws:states:us-west-2:000000000000:activity:fault-activity" );
781797 faultClient .describeActivity (describeRequest );
782798 } catch (Exception e ) {
783799 logger .error ("Error describing activity" , e );
0 commit comments