From 9406fcbec0234c31eb602fc9e95dca99d61cac98 Mon Sep 17 00:00:00 2001
From: Ricardo Linck <ricardo.linck@live.com>
Date: Fri, 12 Jan 2024 17:32:18 +0000
Subject: [PATCH] feat: Add input_template in target_parameters for pipes
 (#102)

Co-authored-by: Anton Babenko <anton@antonbabenko.com>
---
 examples/with-pipes/main.tf | 4 ++++
 main.tf                     | 1 +
 2 files changed, 5 insertions(+)

diff --git a/examples/with-pipes/main.tf b/examples/with-pipes/main.tf
index 08ded36..70dbbfd 100644
--- a/examples/with-pipes/main.tf
+++ b/examples/with-pipes/main.tf
@@ -134,6 +134,10 @@ module "eventbridge" {
         }
       }
 
+      target_parameters = {
+        input_template = "{\"data\":<$.dynamodb>}"
+      }
+
       tags = {
         Pipe = "dynamodb_stream_source_sqs_target"
       }
diff --git a/main.tf b/main.tf
index c8c98a9..d7e7624 100644
--- a/main.tf
+++ b/main.tf
@@ -698,6 +698,7 @@ resource "aws_pipes_pipe" "this" {
     for_each = try([each.value.target_parameters], [])
 
     content {
+      input_template = try(target_parameters.value.input_template, null)
       dynamic "sqs_queue_parameters" {
         for_each = try([target_parameters.value.sqs_queue_parameters], [])