3030import software .amazon .awssdk .services .s3 .model .GetObjectRequest ;
3131import software .amazon .awssdk .services .s3 .model .NoSuchKeyException ;
3232
33-
3433@ TestMethodOrder (MethodOrderer .OrderAnnotation .class )
3534public class LambdaIntegrationTest extends LocalStackSetupConfigurations {
3635
@@ -86,13 +85,13 @@ public String getFilename() {
8685 var headers = new HttpHeaders ();
8786 headers .setContentType (MediaType .MULTIPART_FORM_DATA );
8887 // request body with the file resource and headers
89- MultiValueMap < String , Object > requestBody = new LinkedMultiValueMap <> ();
88+ MultiValueMap < String , Object > requestBody = new LinkedMultiValueMap < > ();
9089 requestBody .add ("file" , resource );
91- HttpEntity < MultiValueMap < String , Object >> requestEntity = new HttpEntity <> (requestBody ,
92- headers );
90+ HttpEntity < MultiValueMap < String , Object >> requestEntity = new HttpEntity < > (requestBody ,
91+ headers );
9392
94- ResponseEntity < String > postResponse = restTemplate .exchange (BASE_URL + postUrl ,
95- HttpMethod .POST , requestEntity , String .class );
93+ ResponseEntity < String > postResponse = restTemplate .exchange (BASE_URL + postUrl ,
94+ HttpMethod .POST , requestEntity , String .class );
9695
9796 assertEquals (HttpStatus .OK , postResponse .getStatusCode ());
9897
@@ -104,8 +103,8 @@ public String getFilename() {
104103 e .printStackTrace ();
105104 }
106105
107- ResponseEntity < byte []> responseEntity = restTemplate .exchange (BASE_URL + getUrl ,
108- HttpMethod .GET , null , byte [].class );
106+ ResponseEntity < byte [] > responseEntity = restTemplate .exchange (BASE_URL + getUrl ,
107+ HttpMethod .GET , null , byte [].class );
109108
110109 assertEquals (HttpStatus .OK , responseEntity .getStatusCode ());
111110
@@ -119,30 +118,29 @@ public String getFilename() {
119118 @ Order (2 )
120119 void testFileProcessedInLambdaHasMetadata () {
121120 var getItemRequest = GetItemRequest .builder ()
122- .tableName ("shipment" )
123- .key (Map .of (
124- "shipmentId" ,
125- AttributeValue .builder ().s ("3317ac4f-1f9b-4bab-a974-4aa9876d5547" ).build ())).build ();
121+ .tableName ("shipment" )
122+ .key (Map .of (
123+ "shipmentId" ,
124+ AttributeValue .builder ().s ("3317ac4f-1f9b-4bab-a974-4aa9876d5547" ).build ())).build ();
126125
127126 var getItemResponse = dynamoDbClient .getItem (getItemRequest );
128127
129128 dynamoDbClient .getItem (getItemRequest );
130129 GetObjectRequest getObjectRequest = GetObjectRequest .builder ()
131- .bucket (BUCKET_NAME )
132- .key (getItemResponse .item ().get ("imageLink" ).s ())
133- .build ();
130+ .bucket (BUCKET_NAME )
131+ .key (getItemResponse .item ().get ("imageLink" ).s ())
132+ .build ();
134133 try {
135134 // already processed objects have a metadata field added, not be processed again
136135 var s3ObjectResponse = s3Client .getObject (getObjectRequest );
137136 assertTrue (s3ObjectResponse .response ().metadata ().entrySet ().stream ().anyMatch (
138- entry -> entry .getKey ().equals ("exclude-lambda" ) && entry .getValue ().equals ("true" )));
137+ entry -> entry .getKey ().equals ("exclude-lambda" ) && entry .getValue ().equals ("true" )));
139138 } catch (NoSuchKeyException noSuchKeyException ) {
140139 noSuchKeyException .printStackTrace ();
141140 }
142141 dynamoDbClient .close ();
143142 s3Client .close ();
144143
145-
146144 }
147145
148146 private String applyHash (byte [] data ) {
@@ -155,7 +153,7 @@ private String applyHash(byte[] data) {
155153
156154 // convert the hash bytes to a hexadecimal representation
157155 var hexString = new StringBuilder ();
158- for (byte b : hash ) {
156+ for (byte b : hash ) {
159157 var hex = Integer .toHexString (0xff & b );
160158 if (hex .length () == 1 ) {
161159 hexString .append ('0' );
0 commit comments