adding webhook sending of full wrp message

xmidt-org · Dec 4, 2018 · 7ca7d0e · 7ca7d0e
1 parent ce1a924
commit 7ca7d0e
Showing 1 changed file with 16 additions and 1 deletion.
diff --git a/src/caduceus/outboundSender.go b/src/caduceus/outboundSender.go
@@ -517,7 +517,22 @@ func (obs *CaduceusOutboundSender) worker(id int) {
 		if now.After(dropUntil) {
 			if now.Before(deliverUntil) {
 				payload := msg.Payload
-				payloadReader := bytes.NewReader(payload)
+				var payloadReader *bytes.Reader
+				if obs.listener.Config.ContentType == "wrp" {
+					buffer := bytes.NewBuffer([]byte{})
+					var f wrp.Format
+					switch msg.ContentType {
+					case "json":
+						f = wrp.JSON
+					default:
+						f = wrp.Msgpack
+					}
+					encoder := wrp.NewEncoder(buffer, f)
+					encoder.Encode(msg)
+					payloadReader = bytes.NewReader(buffer.Bytes())
+				} else {
+					payloadReader = bytes.NewReader(payload)
+				}
 				req, err := http.NewRequest("POST", obs.id, payloadReader)
 				if nil != err {
 					// Report drop