@@ -26,6 +26,9 @@ class SnsToSqsStack extends cdk.Stack {
2626 lessThan : 1000 ,
2727 betweenStrict : { start : 2000 , stop : 3000 } ,
2828 } ) ) ,
29+ store : sns . Filter . filter ( sns . SubscriptionFilter . existsFilter ( true ) ) ,
30+ event : sns . Filter . filter ( sns . SubscriptionFilter . existsFilter ( false ) ) ,
31+ interests : sns . Filter . filter ( sns . SubscriptionFilter . existsFilter ( ) ) ,
2932 } ,
3033 } ) ) ;
3134 }
@@ -39,14 +42,14 @@ const integTest = new IntegTest(app, 'SNS Subscriptions', {
3942 ] ,
4043} ) ;
4144integTest . assertions . awsApiCall ( 'SNS' , 'publish' , {
42- Message : '{ background: { color: \'green\' }, price: 200 }' ,
45+ Message : '{ background: { color: \'green\' }, price: 200, store: \'fans\', interests: [] }' ,
4346 TopicArn : stack . topic . topicArn ,
4447} ) ;
4548const message = integTest . assertions . awsApiCall ( 'SQS' , 'receiveMessage' , {
4649 QueueUrl : stack . queue . queueUrl ,
4750 WaitTimeSeconds : 20 ,
4851} ) ;
4952message . expect ( ExpectedResult . objectLike ( {
50- Messages : [ { Body : '{color: "green", price: 200}' } ] ,
53+ Messages : [ { Body : '{color: "green", price: 200, store: "fans", interests: [] }' } ] ,
5154} ) ) ;
5255app . synth ( ) ;
0 commit comments