Update integration test to check for payload from SQS

aws · Sep 20, 2024 · 214765b · 214765b
1 parent 86b529d
commit 214765b
Show file tree

Hide file tree

Showing 11 changed files with 992 additions and 582 deletions.
diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/README.md b/packages/@aws-cdk/aws-pipes-targets-alpha/README.md
@@ -32,6 +32,7 @@ The following targets are supported:
 1. `targets.SqsTarget`: [Send event source to a Queue](#amazon-sqs)
 2. `targets.SfnStateMachine`: [Invoke a State Machine from an event source](#aws-step-functions-state-machine)
 3. `targets.LambdaFunction`: [Send event source to a Lambda Function](#aws-lambda-function)
+4. `targets.ApiDestinationTarget`: [Send event source to an EventBridge API Destination](#amazon-eventbridge-api-destination)
 
 ### Amazon SQS
 
@@ -181,7 +182,9 @@ The API destination will receive the (enriched/filtered) source payload.
 declare const sourceQueue: sqs.Queue;
 declare const dest: events.ApiDestination;
 
-const apiTarget = new targets.ApiDestinationTarget(dest);
+const apiTarget = new targets.ApiDestinationTarget(dest, {
+  inputTransformation: pipes.InputTransformation.fromObject({ body: "👀" }),
+});
 
 const pipe = new pipes.Pipe(this, 'Pipe', {
     source: new SomeSource(sourceQueue),

diff --git a/...db52eec8e467ce2a69454a41a.bundle/index.js → ...2367f5cbf9a26c60df1f3e718.bundle/index.js b/...db52eec8e467ce2a69454a41a.bundle/index.js → ...2367f5cbf9a26c60df1f3e718.bundle/index.js
diff --git a/...s-alpha/test/integ.api-destination.js.snapshot/aws-cdk-pipes-targets-api-dest.assets.json b/...s-alpha/test/integ.api-destination.js.snapshot/aws-cdk-pipes-targets-api-dest.assets.json
diff --git a/...alpha/test/integ.api-destination.js.snapshot/aws-cdk-pipes-targets-api-dest.template.json b/...alpha/test/integ.api-destination.js.snapshot/aws-cdk-pipes-targets-api-dest.template.json
@@ -318,7 +318,7 @@
        "x-api-key": "apiKeyFromHeaderParams"
       },
       "QueryStringParameters": {
-       "key": "harrypotter"
+       "key": "$.body"
       }
      }
     }

diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.js.snapshot/cdk.out b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.js.snapshot/cdk.out
diff --git a/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.js.snapshot/integ.json b/packages/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.js.snapshot/integ.json
diff --git a/...ination.js.snapshot/integtestpipetargetapidestDefaultTestDeployAssert6B876A1E.assets.json b/...ination.js.snapshot/integtestpipetargetapidestDefaultTestDeployAssert6B876A1E.assets.json
diff --git a/...ation.js.snapshot/integtestpipetargetapidestDefaultTestDeployAssert6B876A1E.template.json b/...ation.js.snapshot/integtestpipetargetapidestDefaultTestDeployAssert6B876A1E.template.json
diff --git a/...ges/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.js.snapshot/manifest.json b/...ges/@aws-cdk/aws-pipes-targets-alpha/test/integ.api-destination.js.snapshot/manifest.json