#!/bin/bash

echo 'Replace values in the CloudFormation for the Lambda streaming function with output values from setup CloudFormation'
# Replace values from the baseline CloudFormation 
replace [S3BUCKET_CFN] $(jq < cfn-output.json -r '.S3BucketName') -- change_streams_stack.yml 
replace [ARN_ROLE_CFN] $(jq < cfn-output.json -r '.RoleArn') -- change_streams_stack.yml 
replace [DOCDB_SECRETSMAN_NAME_CFN] $(jq < cfn-output.json -r '.DocDBSecretName') -- change_streams_stack.yml 
replace [DOCDB_URI_CFN] $(jq < cfn-output.json -r '.DocumentDBEndpoint') -- change_streams_stack.yml 
replace [SNS_TOPIC_ARN_ALERT_CNF] $(jq < cfn-output.json -r '.SNSTopicAlert') -- change_streams_stack.yml 
replace [ELASTICSEARCH_URI_CFN] $(jq < cfn-output.json -r '.ElasticsearchDomainEndpoint') -- change_streams_stack.yml 
replace [DOCDB_SG_CFN] $(jq < cfn-output.json -r '.DocumentDBSecurityGroup') -- change_streams_stack.yml 
replace [ELASTICSEARCH_SG_CFN] $(jq < cfn-output.json -r '.ElasticsearchSecurityGroup') -- change_streams_stack.yml 
replace [SUBNET_ONE_CFN] $(jq < cfn-output.json -r '.PrivateSubnetOne') -- change_streams_stack.yml 
replace [SUBNET_TWO_CFN] $(jq < cfn-output.json -r '.PrivateSubnetTwo') -- change_streams_stack.yml 
replace [SUBNET_THREE_CFN] $(jq < cfn-output.json -r '.PrivateSubnetThree') -- change_streams_stack.yml 
replace [SNS_TOPIC_ARN_TRIGGER_CNF] $(jq < cfn-output.json -r '.SNSTopicTrigger') -- change_streams_stack.yml 

echo 'Deploy CloudFormation for the Lambda streaming function'
# Deploy CloudFormation with Lambda streaming function
aws cloudformation deploy --template-file change_streams_stack.yml --stack-name change-streams-function

echo 'Setup testware'
# Setup testware
aws events enable-rule --name $(jq < cfn-output.json -r '.EventBridgeRule')
wget https://raw.githubusercontent.com/aws-samples/amazon-documentdb-samples/master/datasets/tweets.json
wget https://raw.githubusercontent.com/aws-samples/amazon-documentdb-samples/master/samples/change-streams/test/es-test.py