From e22b95e70ef86192e2ffa2efef535e0f73e094f5 Mon Sep 17 00:00:00 2001
From: vikash s <vikash.s@sw-lp00372.bundl.in>
Date: Thu, 17 Sep 2020 20:09:44 +0530
Subject: [PATCH]  parsing event details

---
 pkg/sinks/eventbridge.go | 27 +++++++++++++++++++++++++--
 1 file changed, 25 insertions(+), 2 deletions(-)

diff --git a/pkg/sinks/eventbridge.go b/pkg/sinks/eventbridge.go
index ae1006b..1c003c5 100644
--- a/pkg/sinks/eventbridge.go
+++ b/pkg/sinks/eventbridge.go
@@ -2,6 +2,7 @@ package sinks
 
 import (
 	"context"
+	"encoding/json"
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/session"
 	"github.com/aws/aws-sdk-go/service/eventbridge"
@@ -14,7 +15,7 @@ const retries = 3
 
 type EventBridgeConfig struct {
 	DetailType   string              `yaml:"detailTyp"`
-	Details   map[string]string `yaml:"details"`
+	Details   map[string]interface{} `yaml:"details"`
 	Source 	  string				`yaml:"source"`
 	EventBusName string			`yaml:"eventBusName"`
 	Region string				`yaml:"region"`
@@ -42,7 +43,29 @@ func NewEventBridgeSink(cfg *EventBridgeConfig) (Sink, error) {
 
 func (s *EventBridgeSink) Send(ctx context.Context, ev *kube.EnhancedEvent) error {
 	log.Println("[INFO] Sending event to EventBridge ")
-	req,out := s.svc.PutEventsRequest(nil)
+	var toSend string
+	if s.cfg.Details != nil {
+		res, err := convertLayoutTemplate(s.cfg.Details, ev)
+		if err != nil {
+			return err
+		}
+
+		byte, err := json.Marshal(res)
+		toSend = string(byte)
+		if err != nil {
+			return err
+		}
+	} else {
+		toSend = string(ev.ToJSON())
+	}
+	inputRequest := eventbridge.PutEventsRequestEntry{
+		Detail: &toSend,
+		DetailType:,
+		Time: ,
+		Source: ,
+		EventBusName: ,
+	}
+	req,out := s.svc.PutEventsRequest(&eventbridge.PutEventsInput{Entries: []*eventbridge.PutEventsRequestEntry{&inputRequest}})
 	err := req.Send()
 	var retry int64
 	retry = 0