From 8385dbe7df19019a8366040221b455d1566375f0 Mon Sep 17 00:00:00 2001
From: Kevin Franklin Kim <kevin.kim@bestbytes.com>
Date: Mon, 27 May 2024 11:04:57 +0200
Subject: [PATCH] wip: set debug mode

---
 integration/watermill/mpv2/publishermiddleware.go | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/integration/watermill/mpv2/publishermiddleware.go b/integration/watermill/mpv2/publishermiddleware.go
index 81521b5..acf4780 100644
--- a/integration/watermill/mpv2/publishermiddleware.go
+++ b/integration/watermill/mpv2/publishermiddleware.go
@@ -16,7 +16,18 @@ func PublisherMiddlewareDebugMode(next PublisherHandler) PublisherHandler {
 			return err
 		}
 		if payload.DebugMode {
+			for i, event := range payload.Events {
+				if params, ok := event.Params.(map[string]any); ok {
+					params["debug_mode"] = "1"
+				}
+				payload.Events[i] = event
+			}
 			spew.Dump(payload.Events)
+			out, err := json.Marshal(payload)
+			if err != nil {
+				return err
+			}
+			msg.Payload = out
 		}
 		return next(l, msg)
 	}