Added updatePolicy metadata (#376)

Author: ammokhov

src/main/java/software/amazon/cloudformation/AbstractWrapper.java

@@ -271,6 +271,7 @@ public void processRequest(final InputStream inputStream, final OutputStream out
             resourceHandlerRequest.setRollback(request.getRollback());
             resourceHandlerRequest.setDriftable(request.getDriftable());
             resourceHandlerRequest.setFeatures(request.getFeatures());
+            resourceHandlerRequest.setUpdatePolicy(request.getUpdatePolicy());
             if (request.getRequestData() != null) {
                 resourceHandlerRequest.setPreviousSystemTags(request.getRequestData().getPreviousSystemTags());
             }
@@ -374,9 +375,10 @@ private void logUnhandledError(final String errorDescription,
             logUnhandledError(e.getMessage(), request, e);
             return ProgressEvent.defaultFailureHandler(e, e.getErrorCode());
         } catch (final AmazonServiceException | AwsServiceException e) {
-            if ((e instanceof AwsServiceException && ((AwsServiceException) e).isThrottlingException()) ||
-                (e instanceof AmazonServiceException && RetryUtils.isThrottlingException((AmazonServiceException) e))) {
-                this.log(String.format("%s [%s] call throttled by downstream service", request.getResourceType(), request.getAction()));
+            if ((e instanceof AwsServiceException && ((AwsServiceException) e).isThrottlingException())
+                || (e instanceof AmazonServiceException && RetryUtils.isThrottlingException((AmazonServiceException) e))) {
+                this.log(String.format("%s [%s] call throttled by downstream service", request.getResourceType(),
+                    request.getAction()));
                 publishExceptionMetric(request.getAction(), e, HandlerErrorCode.Throttling);
                 return ProgressEvent.defaultFailureHandler(e, HandlerErrorCode.Throttling);
             } else {

src/main/java/software/amazon/cloudformation/proxy/HandlerRequest.java

@@ -39,5 +39,6 @@ public class HandlerRequest<ResourceT, CallbackT, ConfigurationT> {
     private Boolean rollback;
     private Boolean driftable;
     private Map<String, Object> features;
+    private Map<String, Object> updatePolicy;
     private RequestContext<CallbackT> requestContext;
 }

src/main/java/software/amazon/cloudformation/proxy/ResourceHandlerRequest.java

@@ -47,6 +47,7 @@ public class ResourceHandlerRequest<T> {
     private Boolean rollback;
     private Boolean driftable;
     private Map<String, Object> features;
+    private Map<String, Object> updatePolicy;
     private String region;
     private String stackId;
 }

src/test/java/software/amazon/cloudformation/data/create.request.json

@@ -34,5 +34,8 @@
             "tag1": "def"
         }
     },
+    "updatePolicy": {
+        "Custom": "Term"
+    },
     "stackId": "arn:aws:cloudformation:us-east-1:123456789012:stack/SampleStack/e722ae60-fe62-11e8-9a0e-0ae8cc519968"
 }

src/test/java/software/amazon/cloudformation/resource/SerializerTest.java

@@ -23,7 +23,9 @@
 import java.io.FileNotFoundException;
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.Map;
 import org.apache.commons.io.IOUtils;
+import org.assertj.core.util.Maps;
 import org.junit.jupiter.api.Test;
 import software.amazon.cloudformation.Action;
 import software.amazon.cloudformation.TestConfigurationModel;
@@ -65,6 +67,7 @@ public void testDeserialize_AccuratePayload() throws IOException {
         final String in = loadRequestJson("create.request.json");
 
         final HandlerRequest<TestModel, TestContext, TestConfigurationModel> r = s.deserialize(in, typeReference);
+        Map<String, Object> updatePolicy = Maps.newHashMap("Custom", "Term");
 
         assertThat(r).isNotNull();
         assertThat(r.getAction()).isEqualTo(Action.CREATE);
@@ -75,6 +78,7 @@ public void testDeserialize_AccuratePayload() throws IOException {
         assertThat(r.getRequestData()).isNotNull();
         assertThat(r.getResourceType()).isEqualTo("AWS::Test::TestModel");
         assertThat(r.getResourceTypeVersion()).isEqualTo("1.0");
+        assertThat(r.getUpdatePolicy()).isEqualTo(updatePolicy);
         assertThat(r.getStackId())
             .isEqualTo("arn:aws:cloudformation:us-east-1:123456789012:stack/SampleStack/e722ae60-fe62-11e8-9a0e-0ae8cc519968");
         assertThat(r.getCallbackContext()).isNull();