in TerraformCustomResourceHandler/src/main/java/com/amazon/servicecatalog/terraform/customresource/TerraformLaunchRequestHandler.java [50:68]
public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) {
MessageAttributeValue accountIdValue = new MessageAttributeValue()
.withDataType("String")
.withStringValue(getAccountId(context));
Map<String, MessageAttributeValue> messageAttributes =
ImmutableMap.of(ACCOUNT_ID_ATTRIBUTE_KEY, accountIdValue);
String hubSnsTopicArn = EnvConfig.getRequiredEnv(HUB_SNS_ARN_ENV_VAR);
String cfnRequest = toRequestString(inputStream);
try {
publishNotification(hubSnsTopicArn, cfnRequest, messageAttributes);
} catch (RuntimeException e) {
CustomResourceRequest request = CustomResourceMarshaller.readCustomResourceRequest(cfnRequest, true);
String message = String.format("Unable to publish SNS notification to hub account SNS topic. %s",
e.getMessage());
ResponsePoster.postFailure(request, message);
}
}